首页 > 经验记录 > java > 传统@ServerEndpoint方式开发WebSocket应用和SpringBoot构建WebSocket应用程序。

传统@ServerEndpoint方式开发WebSocket应用和SpringBoot构建WebSocket应用程序。

WebSocket一次握手就可以使客户端和服务端建立长连接,并进行双向数据传输。

由于其双向传输特性,服务端可主动向客户端发送信息,实时性很高。

而与HTTP协议比起来WebSocket 协议每次数据传输的头信息都较小,节约带宽。

在获取实时数据这方面时,那是比ajax轮询方式高到不知道哪去了。

 

在SpringBoot架构下进行WebSocket服务开发的话,首先还是要导入这个

就算是使用Tomcat 7 的@ServerEndpoint进行 WebSocket开发,也得导。不然在SpringBoot环境下会有bug。

普通java web应用开发WebSocket就不需要了,@ServerEndpoint直接用就行。

maven仓库: spring-boot-starter-websocket

 

这是使用@ServerEndpoint进行的传统WebSocket开发:

由于我是在SpringBoot环境,所以得先写个能扫描@ServerEndpoint的配置,不然在客户端连接的时候会一直连不上。不是在SpringBoot下开发的可以跳过这一环节。

ServerEndpointExporter这个类偏偏还是 spring-boot-starter-websocket 提供的。所以必须要导入这个依赖。

@ServerEndpoint 注解中写上客户端连接的地址。

在类层次上,还得加上 @Component 注解才行。普通java web项目不用加。

这个方式开发的WebSocket服务器,每个连接加入都会为该连接新建一个服务器对象绑定。

这时,一个传统的WebSocket应用就开发完毕了。由于我是在SpringBoot下开发的,所以有一些调整。

启动应用后搞个普通的html页面直接本地打开就可以试验是否能够连接上了。

 

 

不过…我既然都导入了spring-boot-starter-websocket 依赖,自然最好还是用SprinBoot推荐的方法比较好。

这是使用SpringBoot的形式构建WebSocket应用程序:

 

这是核心配置类。实现WebSocketConfigurer接口实现它提供的注册方法。

这个方法就厉害了, 可以配置websocket入口,允许访问的域、注册Handler、定义拦截器等等等等。

@EnableWebSocket用于开启注解接收和发送消息

关于他这个拦截器,是非常重要的,最好还是设置一个。他可以在连接进入到Handler处理时进行一些操作。

比如从session中拿出用户登陆信息作为唯一标识符等等…

我把我的拦截器实现写成内部类了,反正也没多少东西。

这个配置注册的处理器和拦截器,都是只有一个的,无论你多少连接进来,都是用相同的对象处理。

那么就不好用传统的WebSocket开发那样用个集合类容器来存了。

用前置拦截设置进去的某些唯一标识作为key,session作为value用键值对映射类容器来存储连接是比较好的方案。

 

这是我实现的处理器,也是WebSocket开发的核心:

需要实现WebSocketHandler 接口,该接口提供了五个方法。

1、 afterConnectionEstablished():建立新的socket连接后回调的方法。

2、handleMessage():接收客户端发送的Socket。

3、handleTransportError():连接出错时,回调的方法。

4、afterConnectionClosed():连接关闭时,回调的方法。

5、supportsPartialMessages():这个是WebSocketHandler是否处理部分消息,没什么卵用 返回false就完事了。

至此,SpringBoot 与 WebSocket 已经集成完了。客户端仍然使用我上边那个HTML文件就行,访问地址改一下就完事了。

我的这个WebSocket项目整体源码地址:  Github


EA PLAYER &

历史记录 [ 注意:部分数据仅限于当前浏览器 ]清空

      00:00/00:00