因为HTTP本身是基于TCP连接的,所以,WebSocket在HTTP协议的基础上做了一个简单的升级,即建立TCP连接后,浏览器发送请求时,附带几个头:
就表示客户端希望升级连接,变成长连接的WebSocket,服务器返回升级成功的响应:
收到成功响应后表示WebSocket“握手”成功,这样,代表WebSocket的这个TCP连接将不会被服务器关闭,而是一直保持,服务器可随时向浏览器推送消息,浏览器也可随时向服务器推送消息。双方推送的消息既可以是文本消息,也可以是二进制消息,一般来说,绝大部分应用程序会推送基于JSON的文本消息。
现代浏览器都已经支持WebSocket协议,服务器则需要底层框架支持。Java的Servlet规范从3.1开始支持WebSocket,所以,必须选择支持Servlet 3.1或更高规范的Servlet容器,才能支持WebSocket。最新版本的Tomcat、Jetty等开源服务器均支持WebSocket。
我们以实际代码演示如何在Spring MVC中实现对WebSocket的支持。首先,我们需要在中加入以下依赖:
- org.apache.tomcat.embed:tomcat-embed-websocket:9.0.26
- org.springframework:spring-websocket:5.2.0.RELEASE
第一项是嵌入式Tomcat支持WebSocket的组件,第二项是Spring封装的支持WebSocket的接口。
接下来,我们需要在AppConfig中加入Spring Web对WebSocket的配置,此处我们需要创建一个实例:
此实例在内部通过注册能处理WebSocket的,以及可选的WebSocket拦截器。我们注入的这两个类都是自己编写的业务逻辑,后面我们详细讨论如何编写它们,这里只需关注浏览器连接到WebSocket的URL是。
当浏览器请求一个WebSocket连接后,如果成功建立连接,Spring会自动调用方法,任何原因导致WebSocket连接中断时,Spring会自动调用方法,因此,覆写这两个方法即可处理连接成功和结束后的业务逻辑:
每个WebSocket会话以表示,且已分配唯一ID。和WebSocket相关的数据,例如用户名称等,均可放入关联的中。
用实例变量持有当前所有的是为了广播,即向所有用户推送同一消息时,可以这么写:
我们发送的消息是序列化后的JSON,可以用ChatMessage表示:
每收到一个用户的消息后,我们就需要广播给所有用户:
如果要推送给指定的几个用户,那就需要在中根据条件查找出某些,然后发送消息。
注意到我们在注册WebSocket时还传入了一个,这个类实际上可以从继承,它的主要作用是在WebSocket建立连接后,把HttpSession的一些属性复制到WebSocketSession,例如,用户的登录信息等:
这样,在中,可以从中获取到复制过来的属性。
用户可以在连接成功后任何时候给服务器发送消息:
最后,连调浏览器和服务器端,如果一切无误,可以开多个不同的浏览器测试WebSocket的推送和广播:
和上一节我们介绍的异步处理类似,Servlet的线程模型并不适合大规模的长链接。基于NIO的Netty等框架更适合处理WebSocket长链接,我们将在后面介绍。
从下载练习: (推荐使用IDE练习插件快速下载)
在Servlet中使用WebSocket需要3.1及以上版本;
通过可以简化WebSocket的开发。
版权声明:
本文来源网络,所有图片文章版权属于原作者,如有侵权,联系删除。
本文网址:https://www.bianchenghao6.com/java-jiao-cheng/17162.html