文档章节

Nutz-plugins-undertow配合WebSocket,模拟Room的方法

黄道坤
 黄道坤
发布于 2017/09/06 19:12
字数 463
阅读 19
收藏 0

使用WebSocket的时候,因为要推送消息,可能有多个客户端同时在线,一般的处理方法都是把这些Channel放进一个Room里,然后一起通知。 上一篇已经简单的说明基于Nutz的Undertow插件集成WebSocket的方法,这里跟进一步,看看如何模拟Room。

//添加WebSocket的Handler
PathHandler pathHandler = Handlers.path().addPrefixPath("/myWebsocket", websocket(new WebSocketConnectionCallback() {
    @Override
    public void onConnect(WebSocketHttpExchange exchange, WebSocketChannel channel) {
              channel.getReceiveSetter().set(new AbstractReceiveListener() {
              @Override
              protected void onFullTextMessage(WebSocketChannel channel, BufferedTextMessage message) {
                //获取页面传递的message里的数据,这里封装了Nutz的一个Map工具,NutMap,里面包含了动作和房间名
                //获取连接的channel
                //channel有一个setAttrbute方法,可以放一个UUID进去,以保证唯一。我自己是用“房间名@UUID”,用处后面会讲
                //使用一个全局的Map,存进这个channel,并放进获取的房间名为Key的Map中
                //这样就能在发送的时候,遍历某个房间里的所有channel,然后sendText了
              }
             @Override
             protected void onClose(WebSocketChannel channel){
                //在关闭的时候,记得找到房间,并移除这个channel
                //这个时候就需要这个channel里的attribute里的id了,解析出房间名,就可以在这个房间名为Key的Map里移除channel了
               //有时候,一些特殊的需求,需要按照Channel来通信,就是说一个用户一个Channel。这里无法直接获取Session,我们可以使用一种变通的方法:
                //用户登录成功之后,在Session里保存一个UUID,然后页面初始化的时候,用这个UUID作为房间名,就是唯一的了。
                //到时候,只要能找到Session里的这个UUID,就可以单独给这个房间发送消息了
            }
          });
        channel.resumeReceives();
      }
})).addPrefixPath(contextPath, servletHandler);           

暂时用文字说明一下,有空了补充代码。

© 著作权归作者所有

共有 人打赏支持
黄道坤
粉丝 1
博文 5
码字总数 13828
作品 0
成都
程序员
undertow 接收到 websocket 链接时报404错误

客户端在往服务器 建立 websocket 链接时,返回404错误。 链接地址为 /websocket/{param} 形式的。这个连接失败不是必现的,大部分是链接成功的,只有一部分不成功,打开undertow的日志 看到...

火枫001
前天
0
0
用jetty搭建websocket服务并与ie78兼容的方法

jetty8中已经自带有websocket功能,所以我们可以很方便搭建一个自己的websocket服务。 源程序:http://sdrv.ms/N5BuKw 启动类:org.noahx.websocket.WebSocketServer 访问地址:http://127....

NoahX
2012/08/09
0
6
android内置浏览器不支持websocket的解决方法

为了实现移动客户端实时通信,拟采用安卓webview内嵌html实现方式开发app,通信则采用最新的html5新特性websocket实现。经测试,android4.0以下内置浏览器都不支持websocket特性。经过googl...

chape
2014/03/01
0
2
python 爬取fcoin比特币交易市场 上文

爬取环境 win10 python3 scrapy 爬取思路 首先你得先了解以下 http(https)请求(百科) websocket通信协议 python 模拟websoket客户端 (一)websocket简要介绍 WebSocket是一种在单个TCP...

徐代龙
08/05
0
0
Spring消息之WebSocket

一、WebSocket简介 WebSocket 的定义?WebSocket是HTML5下一种全双工通信协议。在建立连接后,WebSocket服务器端和客户端都能主动的向对方发送和接收数据,就像Socket一样。 WebSocket 的由来...

jmcui
05/06
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

MySQL 乱七八糟的可重复读隔离级别实现

MySQL 乱七八糟的可重复读隔离级别实现 摘要: 原文可阅读 http://www.iocoder.cn/Fight/MySQL-messy-implementation-of-repeatable-read-isolation-levels 「shimohq」欢迎转载,保留摘要,谢...

DemonsI
今天
2
0
Spring源码阅读——2

在阅读源码之前,先了解下Spring的整体架构: 1、Spring的整体架构 1. Ioc(控制反转) Spring核心模块实现了Ioc的功能,它将类与类之间的依赖从代码中脱离出来,用配置的方式进行依赖关系描...

叶枫啦啦
今天
1
0
jQuery.post() 函数格式详解

jquery的Post方法$.post() $.post是jquery自带的一个方法,使用前需要引入jquery.js 语法:$.post(url,data,callback,type); url(必须):发送请求的地址,String类型 data(可选):发送给后台的...

森火
今天
0
0
referer是什么意思?

看看下面这个回答(打不开网页可以把网址复制到搜索栏): https://zhidao.baidu.com/question/577842068.html

杉下
今天
1
0
使用U盘安装CentOS-解决U盘找不到源

1. 使用UltraISO制作CentOS安装盘 如果需要安装带界面的系统,为保证安装顺利,可选择Everything版本的ISO制作安装盘。 2. 在BIOS中选择使用U盘安装 系统启动后,进入安装选择界面,其中有三...

Houor
今天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部