NutzCN Logo
问答 websocket主动给服务器发消息
发布于 2584天前 作者 wx_vjqsjg4om8803f2gnu54 1733 次浏览 复制 上一个帖子 下一个帖子
标签:
if(jedis.exists("home:"+buildingId)){
					myWebsocket.each("home:"+buildingId, new Each<Session>() {
				    	public void invoke(int index, Session ele, int length) {
				            myWebsocket.sendJson(ele.getId(), new NutMap("action", "layer").setv("notify", "你有新的待办事宜,请查看收件箱"));
				    	}
				    });
				}

您好,我把房间都房子redis里了,判断对应的房间的key是否存在,存在就发消息给对应的房间,但是这个方法debug的时候这段代码没执行,是什么原因?
public void invoke(int index, Session ele, int length) {
myWebsocket.sendJson(ele.getId(), new NutMap("action", "layer").setv("notify", "你有新的待办事宜,请查看收件箱"));
}

5 回复

那key是不是真的存在了呢??

debug一下JedisRoomProvider的wsids嘛

key存在,能进到myWebsocket.each("home:"+buildingId, new Each() {这行了,再往下走就直接出去了,没往下执行,是不是我房间名有问题?

哪里的问题?

添加回复
请先登陆
回到顶部