【WebSocket】在SSM项目中配置websocket
创始人
2024-05-31 14:26:36
0

在SSM项目中配置websocket

最近在ssm项目中配置了websocket,踩了很多坑,来分享一下

本文暂不提供发送消息等内容的代码逻辑(后续也许会补充),如果你直接复制这类可能会对配置造成更大的麻烦(博主就是复制了他人逻辑导致连接后秒断开连接,排查了很长时间),建议看完本文配置成功后,去其他文章或者github寻找相应代码逻辑

1.Maven依赖

首先是jackson的依赖

		com.fasterxml.jackson.corejackson-annotations2.3.0com.fasterxml.jackson.corejackson-core2.3.1com.fasterxml.jackson.corejackson-databind2.3.3

然后是spring关于websocket的依赖

		org.springframeworkspring-websocket${spring.version}org.springframeworkspring-messaging${spring.version}

这里的${spring.version}需要注意,一定要和自己的spring版本匹配,所以推荐用这种形式,而不是直接用x.x.x.RELEASE

另外在spring4.0.5.RELEASE之前与其以后,session获取参数的方法有些不同,需要注意

本文使用的是

4.2.5.RELEASE

注意:请删除所有关于javax的依赖,将本地的tomcat引入库中,否则可能会出现类型转换异常导致连接报错(你可以继续下面的步骤,如果在启动测试时出现该问题,再回来尝试解决)
在这里插入图片描述
在这里插入图片描述

2.配置类

首先在我们的项目中创建如下结构
在这里插入图片描述

当然也可以不使用这样的结构,如果你的项目中本来有config、Interceptor、handler包,可以将这些类放入其中

注意以下代码没有给出包名,如需复制请注意

首先是WebSocketConfig.java

import org.springframework.stereotype.Component;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;import javax.annotation.Resource;/*** WebScoket配置处理器*/
@Component
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {@ResourceMyWebSocketHandler handler;@ResourceHandShake handShake;public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {//浏览器支持websocketregistry.addHandler(handler, "/ws").addInterceptors(handShake);//浏览器不支持的话,需要socketjs引入支持registry.addHandler(handler, "/ws/sockjs").addInterceptors(handShake).withSockJS();}}

这个类的作用是配置websocket的链接地址,分为浏览器支持websocket和不支持websocket的情况,不支持可以引入sockjs(某些环境下使用这行代码会导致无法连接,不放心可以删去)

websocket连接地址是

ws://ip:端口号/项目名称/ws

ws与上述配置类相对应

这个连接地址是可以以?的形式传参数的,例如

"ws://ip:端口号/项目名称/ws?userId="+userId

第二个类是HandShake.java

import org.springframework.http.server.ServerHttpRequest;
import org.springframework.http.server.ServerHttpResponse;
import org.springframework.http.server.ServletServerHttpRequest;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.server.HandshakeInterceptor;import javax.servlet.http.HttpSession;
import java.util.Map;/*** Socket建立连接(握手)和断开*/
@Component
public class HandShake implements HandshakeInterceptor {@Overridepublic boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map attributes) throws Exception {// 1.获取sessionServletServerHttpRequest servletRequest = (ServletServerHttpRequest) request;HttpSession session = servletRequest.getServletRequest().getSession(false);// 2.从session中获取uidLong uid = (Long) session.getAttribute("uid");// 3.做正向判断,如果uid是空值直接返回false,拒绝握手if (uid == null){return false;}// 4.输出日志System.out.println("Websocket:用户[ID:" + uid + "]准备进行握手");// 5.将用户id存入mapattributes.put("uid", uid);// 6.可以进行握手return true;}@Overridepublic void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Exception exception) {System.out.println("after hand");}}

这个类是websocket的握手拦截器,会拦截websocket链接地址的请求,进行握手,不建议在该类中做业务处理

最后是MyWebSocketHandler.java

import org.springframework.stereotype.Component;
import org.springframework.web.socket.*;
import java.io.IOException;/*** Socket处理器*/
@Component
public class MyWebSocketHandler implements WebSocketHandler {@Overridepublic void afterConnectionEstablished(WebSocketSession session)throws Exception {System.out.println("ConnectionEstablished");}@Overridepublic void handleMessage(WebSocketSession session, WebSocketMessage message) throws Exception {}/*** 消息传输错误处理*/@Overridepublic void handleTransportError(WebSocketSession session,Throwable exception) throws Exception {System.out.println("TransportError");}/*** 关闭连接后*/@Overridepublic void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {System.out.println("ConnectionClosed");}@Overridepublic boolean supportsPartialMessages() {return false;}
}

这个类是对websocket的各种状态作出相应的处理,如开头所说,本文不会给出相应的逻辑,防止出现错误,这里真的很坑

大体思路就是通过方法中的WebSocketSession获取到session中的用户id,再注入自己的userService(或者其他service层)去完成业务,同时可以在本类中使用ConcurrentHashMap或者直接开一个线程来实现同时在线人数等功能

发送信息的逻辑推荐对信息进行封装,构建实体类

此外你还可以创建一个相应的Controller,通过注入MyWebSocketHandler来建立相应功能的请求地址

import com.webchat.websocket.MyWebSocketHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;@RestController
@RequestMapping("/websocket")
public class WebSocketController {@AutowiredMyWebSocketHandler handler;}

3.JS部分

最后是js部分

		let websocket = new WebSocket("ws://ip:端口号/项目名称/ws?userId="+userId);websocket.onmessage = function(event) {console.log(event.data)};websocket.onopen = function (event){console.log("连接成功")}websocket.onerror = function (event){console.log("连接错误")}websocket.onclose = function (event){console.log('websocket 断开: ' + event.code + ' ' + event.reason + ' ' + event.wasClean)}

注意更改地址

4.测试结果

测试结果如下
在这里插入图片描述
在这里插入图片描述
至此,ssm项目中配置websocket就完成了

如果在测试中出现其他错误,可以根据输出的event.code来匹配错误原因,如果连接后直接断开并显示1011请检查后端代码规范性

编码原因
1000正常关闭 当你的会话成功完成时发送这个代码
1001离开 因应用程序离开且不期望后续的连接尝试而关闭连接时,发送这一代码。服务器可能关闭,或者客户端应用程序可能关闭
1002协议错误 当因协议错误而关闭连接时发送这一代码
1003不可接受的数据类型 当应用程序接收到一条无法处理的意外类型消息时发送这一代码
1004保留 不要发送这一代码。根据 RFC 6455,这个状态码保留,可能在未来定义
1005保留 不要发送这一代码。WebSocket API 用这个代码表示没有接收到任何代码
1006保留 不要发送这一代码。WebSocket API 用这个代码表示连接异常关闭
1007无效数据 在接收一个格式与消息类型不匹配的消息之后发送这一代码。如果文本消息包含错误格式的 UTF-8 数据,连接应该用这个代码关闭
1008消息违反政策 当应用程序由于其他代码所不包含的原因终止连接,或者不希望泄露消息无法处理的原因时,发送这一代码
1009消息过大 当接收的消息太大,应用程序无法处理时发送这一代码(记住,帧的载荷长度最多为64 字节。即使你有一个大服务器,有些消息也仍然太大。)
1010需要扩展 当应用程序需要一个或者多个服务器无法协商的特殊扩展时,从客户端(浏览器)发送这一代码
1011意外情况 当应用程序由于不可预见的原因,无法继续处理连接时,发送这一代码
1015TLS失败(保留) 不要发送这个代码。WebSocket API 用这个代码表示 TLS 在 WebSocket 握手之前失败。
0 ~ 999禁止 1000 以下的代码是无效的,不能用于任何目的
1000 ~ 2999保留 这些代码保留以用于扩展和 WebSocket 协议的修订版本。按照标准规定使用这些代码,参见表 3-4
3000 ~ 3999需要注册 这些代码用于“程序库、框架和应用程序”。这些代码应该在 IANA(互联网编号分配机构)公开注册
4000 ~ 4999私有 在应用程序中将这些代码用于自定义用途。因为它们没有注册,所以不要期望它们能被其他 WebSocket广泛理解

相关内容

热门资讯

苹果电脑安卓系统很卡,卡顿背后... 你有没有发现,最近你的苹果电脑用起来有点慢吞吞的?别急,这可不是个例哦!很多小伙伴都在抱怨,他们的苹...
怎么解除系统禁止安装安卓 你是不是也遇到了这个让人头疼的问题:安卓系统突然禁止安装新的应用?别急,今天就来手把手教你如何解除这...
安卓12平板电脑系统,系统革新... 你有没有发现,最近安卓平板电脑界可是热闹非凡呢!安卓12平板电脑系统横空出世,带来了不少惊喜。今天,...
atv系统和安卓9.0,引领智... 你有没有想过,你的手机和你的ATV(全地形车)之间能有什么交集呢?别惊讶,今天就要给你揭秘这个奇妙的...
安卓最好用省电的系统,探索最佳... 你有没有发现,手机用着用着,电池就“咕咚咕咚”地叫唤起来?别急,今天就来给你揭秘,安卓世界里那些最好...
有哪些安卓类型的系统,多款定制... 你知道吗?在手机世界里,安卓系统就像是个万能的魔法师,它不仅能变出各种各样的手机,还能衍生出各种有趣...
安卓系统精简多少内存,提升运行... 你有没有想过,你的安卓手机为什么有时候会变得那么慢呢?是不是觉得内存不够用,总是卡卡的?别急,今天就...
高端安卓工控系统哪个好,揭秘最... 你有没有想过,家里的智能设备越来越多了,但它们之间的沟通却总是有点儿“鸡同鸭讲”?这不,最近我在研究...
安卓系统识别磁盘格式,磁盘格式... 你有没有遇到过这种情况:手机里突然多了一个陌生的磁盘,你好奇地想看看里面有什么宝贝,却发现安卓系统竟...
惠普平板怎么换安卓系统,惠普平... 你有没有发现,惠普平板电脑的安卓系统有时候用起来还挺不顺手的?别急,今天就来手把手教你如何给惠普平板...
手机显示安卓系统有攻击,揭秘手... 最近是不是发现你的手机屏幕上突然弹出了好多奇怪的提示,说是安卓系统有攻击?别慌,这可不是什么科幻电影...
安卓系统合并分区工具,高效优化... 你有没有想过,你的安卓手机里那些零零散散的存储空间,其实可以变得井井有条呢?没错,今天就要给你安利一...
超好玩安卓系统游戏,解锁无限游... 你有没有发现,最近手机里的游戏越来越好玩了?尤其是那些安卓系统上的游戏,简直让人停不下来!今天,就让...
mate关闭安卓系统通知,深度... 你是不是也和我一样,手机里通知乱糟糟的,有时候连个重要信息都找不到?别急,今天就来和你聊聊如何让你的...
安卓系统诺基亚n96 你有没有想过,那个曾经风靡一时的诺基亚N96,现在在安卓系统下还能焕发出怎样的光彩呢?今天,就让我带...
安卓类原生系统下载方法,安卓原... 你有没有想过,为什么你的手机总是那么卡,那么慢?是不是因为它的系统太老了,需要更新一下呢?别急,今天...
安卓系统车机界面,智能驾驶体验... 你有没有发现,现在越来越多的汽车都开始搭载智能系统了?没错,就是那种可以连接手机、导航、娱乐一应俱全...
神器系统和安卓内存对比,性能与... 你有没有想过,为什么你的手机有时候会卡得像蜗牛一样?其实,这背后有一个神秘的大脑在默默操控着——那就...
鸿蒙系统版本安卓版区别,安卓版... 你有没有发现,最近手机圈子里有个大热门,那就是鸿蒙系统。没错,就是那个华为自主研发的系统。不过,你知...
韶关安卓系统广告机,智能展示新... 韶关安卓系统广告机:点亮城市繁华的智慧之光想象当你走在韶关的街头,突然间,一块块屏幕如同魔法般亮起,...