SpringBoot + WebSocket 实现信息发送
2021/10/30 6:13:15
本文主要是介绍SpringBoot + WebSocket 实现信息发送,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
WebSocket使得客户端和服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送数据。在WebSocket API中,浏览器和服务器只需要完成一次握手,两者之间就直接可以创建持久性的连接,并进行双向数据传输。WebSocket相比使用轮询的方式更加节省资源。
适用场景:弹幕、定时系统信息、聊天等
1、POM依赖导入
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-websocket</artifactId> </dependency>
2、配置ServerEndpointExporter
@Configuration @EnableWebSocket @Service public class WebSocketConfig { @Bean public ServerEndpointExporter serverEndpointExporter() { return new ServerEndpointExporter(); } }
3、然后进行简单的连接、断开、消息接收等操作,此处只是简单展示,可根据实际业务功能扩展
@Component @ServerEndpoint(value = "/webSocket/{account}") @Slf4j public class WebSocket{ private static int loginCount = 0; private static Map<String, WebSocket> users = new ConcurrentHashMap<String, WebSocket>(); private Session session; private String account; // 收到消息触发事件 @OnMessage public void onMessage(String message, Session session) throws IOException, InterruptedException { //JSON数据 log.info("onMessage:{}",message); Map<String,String> map = JSON.parseObject(message, HashMap.class); //接收人 String to = map.get("to"); //内容 String info = map.get("info"); if (to.equals("All")){ sendMessageAll("ALL:"+info); }else{ sendMessageTo(info,to); } } // 打开连接触发事件 @OnOpen public void onOpen(@PathParam("account") String account, Session session, EndpointConfig config) { log.info("onOpen:{}",account); this.account = account; this.session = session; //添加登录用户数量 addLoginCount(); users.put(account, this); log.info("当前在线人数:"+loginCount); log.info("已连接:"+account); } // 关闭连接触发事件 @OnClose public void onClose(Session session, CloseReason closeReason) { log.info("onClose"); users.remove(account); //减少断开连接的用户 reduceLoginCount(); } // 传输消息错误触发事件 @OnError public void one rror(Throwable error) { log.info("onError:{}",error.getMessage()); } public void sendMessageTo(String message, String To) throws IOException { for (WebSocket item : users.values()) { if (item.account.equals(To) ) item.session.getAsyncRemote().sendText(message); } } public void sendMessageAll(String message) throws IOException { for (WebSocket item : users.values()) { item.session.getAsyncRemote().sendText(message); } } public static synchronized void addLoginCount() { WebSocket.loginCount++; } public static synchronized void reduceLoginCount() { WebSocket.loginCount--; } public static synchronized Map<String, WebSocket> getUsers() { return users; } }
- onOpen:前端连接到WebSocket时触发,可用作记录用户信息初始化。
- onClose:断开WebSocket连接时,清除用户数据。
- onMessage:收到消息时,进行处理。
- onError:出现异常时的处理。
效果图:
admin账户:
test1账户:
日志记录:
测试地址:http://www.websocket-test.com/
文章仅用学习记录,有不对的地方请各位大佬指导,毕竟也是头回写。
这篇关于SpringBoot + WebSocket 实现信息发送的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-10-06小米11i印度快充版ROM合集:极致体验,超越期待
- 2024-10-06【ROM下载】小米11i 5G 印度版系统, 疾速跃迁,定义新速度
- 2024-10-06【ROM下载】小米 11 青春活力版,青春无极限,活力全开
- 2024-10-05小米13T Pro系统合集:性能与摄影的极致融合,值得你升级的系统ROM
- 2024-10-01基于Python+Vue开发的医院门诊预约挂号系统
- 2024-10-01基于Python+Vue开发的旅游景区管理系统
- 2024-10-01RestfulAPI入门指南:打造简单易懂的API接口
- 2024-10-01初学者指南:了解和使用Server Action
- 2024-10-01Server Component入门指南:搭建与配置详解
- 2024-10-01React 中使用 useRequest 实现数据请求