用Scala实现简单的Web和API服务器(26)
varopenConnections = Set.empty[cask.WsChannelActor]
该集合包含当前等待更新的浏览器的列表。每当新消息出现时，我们就会向这个列表进行广播。
接下来，定义@cask.websocket处理函数，接收进入的websocket连接并处理：
@cask.websocket("/subscribe")
def subscribe = {
cask.WsHandler { connection =>
cask.WsActor {
casecask.Ws.Text(msg) =>
if(msg.toInt < messages.length){
connection.send(
cask.Ws.Text(
ujson.Obj("index"-> messages.length, "txt"-> messageList.render).render
)
)
}else{
推荐阅读
- 三国杀|三国杀：谁是技能最简单的武将，返璞归真，这就是武将基本元素！
- ag战队|关键的卡位赛，AG超玩会却上了猫神，原因很简单，但是却很心酸
- ps3|魔兽怀旧服：专业打“补丁”的装备，虽然获取简单，但能弥补短处
- 左慈|三国杀：技能缝接，超强发挥，用左慈就能实现
- 地下城堡|LOL手游上分总结，中单最简单上单没人帮，快手投大钱招新主播
- |《英雄联盟手游》当前版本最强上分英雄公布，阿克尚最强团战“利器”，上分很简单
- 商人|游戏商人的月入百万是真的吗？揭秘真实的剑三游戏商人真实现状
- 黄忠|五个能秒坦克的射手，香香仅排第五，榜首瞬秒脆皮太简单
- fly|从电竞迈向艺术：Fly选手实现人生跨越，成历史第一人！
- 炸弹人|英雄联盟手游：炸弹人+石头人走下，简单又强力啊