HTTP

提供了实时、低延迟的数据传输能力。

…springBoot整合webSocket超简单入门

webSocket简洁

协议的全双工通信协议它允许客户端和服务器之间建立持久的、双向的通信连接。

相比传统的

HTTP

WebSocket客户端和服务器可以在任意时间点互相发送消息实现实时更新和即时通信的功能。

WebSocket

Web

应用中常用的通信协议之一。

它广泛应用于聊天应用、实时数据更新、多人游戏等场景为

Web

dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-websocket/artifactId/dependency2、写配置类

Configuration

这个bean会自动注册使用了ServerEndpoint注解声明的Websocket

endpoint*/Beanpublic

ServerEndpointExporter();}}3、创建ServerEndpoint

服务端

种是实现规范所提供的各种接口通过接口定义的回调方法来处理新的连接、客户端消息、连接断开等等事件。

另一种方式是使用注解类似于

Spring

ServerEndpoint(/websocket/{userId})

接口路径

ws://localhost:8080/websocket/userId;

public

与某个客户端的连接会话需要通过它来给客户端发送数据private

Session

concurrent包的线程安全Set用来存放每个客户端对应的MyWebSocket对象。

//

虽然Component默认是单例模式的但springboot还是会为每个websocket连接初始化一个bean所以可以用一个静态set保存起来。

//

static

userId;webSockets.add(this);sessionPool.put(userId,

session);log.info(【websocket消息】有新的连接总数为:

webSockets.size());}

{webSockets.remove(this);sessionPool.remove(this.userId);log.info(【websocket消息】连接断开总数为:

webSockets.size());}

{log.info(【websocket消息】收到客户端消息:

message);}/***

{webSocket.session.getAsyncRemote().sendText(message);}}

catch

发给用户【{}】:【{}】,userId,message);session.getAsyncRemote().sendText(message);}

catch

发给用户【{}】:【{}】,userId,message);session.getAsyncRemote().sendText(message);}

catch

模仿其他的服务调用webSocket进行数据刷新PostMapping(/test)public

Results

JSONObject();obj.put(audience,Math.random()

100);obj.put(msg,dto.getMsg());//

全体发送

webSocket.sendAllMessage(obj.toJSONString());if

(StringUtils.isNotBlank(dto.getUserId())){//

单个用户发送

(userId为用户id)webSocket.sendOneMessage(dto.getUserId(),

(dto.getUserIds()

(userIds为多个用户id)webSocket.sendMoreMessage(dto.getUserIds(),

Results.success();}

{userId:,userIds:[456,789],msg:6666

}查看日志