使用spring boot +WebSocket实现(后台主动)消息推送

前言:使用此webscoket务必确保生产环境能兼容/支持!使用此webscoket务必确保生产环境能兼容/支持!使用此webscoket务必确保生产环境能兼容/支持!主要是tomcat的兼容与支持。

有个需求:APP用户产生某个操作,需要让后台管理系统部分人员感知(表现为一个页面消息)。

最早版本是后台管理系统轮训,每隔一段时间轮训一次,由于消息重要,每隔几秒就查一次。这样做明显很不雅!会消耗大量资源,并且大部分请求是没有用的(查不到数据进来),很蓝瘦。

后来,想着用消息推送的方式来处理这个逻辑。用户在app产生了目标操作,即产生一个消息,推送给后台管理系统的对应用户。

然后我就找各种资料,一开始同事推荐dwz,后来发现不太适用于目前的项目(也许能实现只是我不知道如何实现)。

后来了解到WebSocket,网上看了很多文档都是类似聊天室的场景,有些不同。在此,我主要侧重介绍下 服务器主动推送,由服务端来触发。

WebSocket 主要能实现的场景:

1、网页聊天室

2、服务器消息实时通知

WebSocket 使用方法应该有很多,在次介绍下使用 tomcat8+h5 环境下的实现。

ps:我自己的测试环境是tomcat7这样写是不行的。wang115032337《https://blog.csdn.net/wang115032337》这位朋友在他的环境下,tomcat7/8都可以用本文章的写法,只不过需要去除WebSocketConfig类(有文章表示tomcat7和8对websocket的支持是不同的,本人未深入了解)

话不多说,直接上代码,想深入了解WebSocket 的请查阅相关介绍。

1.pom

[html] view plain copy

  1. <dependency>
  2. <groupId>org.springframework.boot</groupId>
  3. <artifactId>spring-boot-starter-websocket</artifactId>
  4. </dependency>

2.使用@ServerEndpoint创立websocket endpoint( wang115032337这位朋友在他的环境下加入@ServerEndpoint类会报错,直接删除了仍可用

[java] view plain copy

  1. @Configuration
  2. public class WebSocketConfig {
  3. @Bean
  4. public ServerEndpointExporter serverEndpointExporter() {
  5. return new ServerEndpointExporter();
  6. }
  7. }

3.具体实现类可自己选择url要不要带参数

[java] view plain copy

  1. package com.star.manager.service;
  2. import java.io.IOException;
  3. import java.util.concurrent.CopyOnWriteArraySet;
  4. import javax.websocket.OnClose;
  5. import javax.websocket.OnError;
  6. import javax.websocket.OnMessage;
  7. import javax.websocket.OnOpen;
  8. import javax.websocket.Session;
  9. import javax.websocket.server.ServerEndpoint;
  10. import lombok.extern.slf4j.Slf4j;
  11. import org.springframework.stereotype.Component;
  12. @Slf4j
  13. //@ServerEndpoint("/websocket/{user}")
  14. @ServerEndpoint(value = "/websocket")
  15. <strong>@Component</strong>
  16. public class WebSocketServer {
  17. //静态变量,用来记录当前在线连接数。应该把它设计成线程安全的。
  18. private static int onlineCount = 0;
  19. //concurrent包的线程安全Set,用来存放每个客户端对应的MyWebSocket对象。
  20. <strong> </strong>private static CopyOnWriteArraySet<WebSocketServer> webSocketSet = new CopyOnWriteArraySet<WebSocketServer>();
  21. //与某个客户端的连接会话,需要通过它来给客户端发送数据
  22. private Session session;
  23. /**
  24. * 连接建立成功调用的方法*/
  25. @OnOpen
  26. public void onOpen(Session session) {
  27. this.session = session;
  28. webSocketSet.add(this); //加入set中
  29. addOnlineCount(); //在线数加1
  30. log.info("有新连接加入!当前在线人数为" + getOnlineCount());
  31. try {
  32. sendMessage("连接成功");
  33. } catch (IOException e) {
  34. log.error("websocket IO异常");
  35. }
  36. }
  37. // //连接打开时执行
  38. // @OnOpen
  39. // public void onOpen(@PathParam("user") String user, Session session) {
  40. // currentUser = user;
  41. // System.out.println("Connected ... " + session.getId());
  42. // }
  43. /**
  44. * 连接关闭调用的方法
  45. */
  46. @OnClose
  47. public void onClose() {
  48. webSocketSet.remove(this); //从set中删除
  49. subOnlineCount(); //在线数减1
  50. log.info("有一连接关闭!当前在线人数为" + getOnlineCount());
  51. }
  52. /**
  53. * 收到客户端消息后调用的方法
  54. *
  55. * @param message 客户端发送过来的消息*/
  56. @OnMessage
  57. public void onMessage(String message, Session session) {
  58. log.info("来自客户端的消息:" + message);
  59. //群发消息
  60. for (WebSocketServer item : webSocketSet) {
  61. try {
  62. item.sendMessage(message);
  63. } catch (IOException e) {
  64. e.printStackTrace();
  65. }
  66. }
  67. }
  68. /**
  69. *
  70. * @param session
  71. * @param error
  72. */
  73. @OnError
  74. public void onError(Session session, Throwable error) {
  75. log.error("发生错误");
  76. error.printStackTrace();
  77. }
  78. <strong> public void sendMessage(String message) throws IOException {
  79. this.session.getBasicRemote().sendText(message);
  80. }
  81. /**
  82. * 群发自定义消息
  83. * */
  84. public static void sendInfo(String message) throws IOException {
  85. log.info(message);
  86. for (WebSocketServer item : webSocketSet) {
  87. try {
  88. item.sendMessage(message);
  89. } catch (IOException e) {
  90. continue;
  91. }
  92. }
  93. }</strong>
  94. public static synchronized int getOnlineCount() {
  95. return onlineCount;
  96. }
  97. public static synchronized void addOnlineCount() {
  98. WebSocketServer.onlineCount++;
  99. }
  100. public static synchronized void subOnlineCount() {
  101. WebSocketServer.onlineCount--;
  102. }
  103. }

产生一个消息:产生消息场景有多种,http(s),定时任务,mq等,这贴一个httpq请求的controller代码

[java] view plain copy

  1. @RequestMapping(value="/pushVideoListToWeb",method=RequestMethod.POST,consumes = "application/json")
  2. public @ResponseBody Map<String,Object> pushVideoListToWeb(@RequestBody Map<String,Object> param) {
  3. Map<String,Object> result =new HashMap<String,Object>();
  4. try {
  5. WebSocketServer.sendInfo("有新客户呼入,sltAccountId:"+CommonUtils.getValue(param, "sltAccountId"));
  6. result.put("operationResult", true);
  7. }catch (IOException e) {
  8. result.put("operationResult", true);
  9. }
  10. return result;
  11. }

重要的地方我都加粗了,主要是这段,使用这个方法,可以实现服务器主动推送。

[java] view plain copy

  1. public void sendMessage(String message) throws IOException {
  2. this.session.getBasicRemote().sendText(message);
  3. }

4.js(html就不写了,随便找个能触发这个js的就可以)

[javascript] view plain copy

  1. //socket = new WebSocket("ws://localhost:9094/starManager/websocket/张三");
  2. var socket;
  3. if(typeof(WebSocket) == "undefined") {
  4. console.log("您的浏览器不支持WebSocket");
  5. }else{
  6. console.log("您的浏览器支持WebSocket");
  7. //实现化WebSocket对象,指定要连接的服务器地址与端口 建立连接
  8. //socket = new WebSocket("ws://localhost:9094/starManager/websocket/张三")

[javascript] view plain copy

  1. socket = new WebSocket("ws://localhost:9094/starManager/websocket");
  2. //打开事件
  3. socket.onopen = function() {
  4. console.log("Socket 已打开");
  5. //socket.send("这是来自客户端的消息" + location.href + new Date());
  6. };
  7. //获得消息事件
  8. socket.onmessage = function(msg) {
  9. console.log(msg.data);
  10. //发现消息进入 调后台获取
  11. getCallingList();
  12. };
  13. //关闭事件
  14. socket.onclose = function() {
  15. console.log("Socket已关闭");
  16. };
  17. //发生了错误事件
  18. socket.onerror = function() {
  19. alert("Socket发生了错误");
  20. }
  21. $(window).unload(function(){
  22. socket.close();
  23. });
  24. // $("#btnSend").click(function() {
  25. // socket.send("这是来自客户端的消息" + location.href + new Date());
  26. // });
  27. //
  28. // $("#btnClose").click(function() {
  29. // socket.close();
  30. // });
  31. }

简单说说:

通过前端代码

[javascript] view plain copy

  1. socket = new WebSocket("ws://localhost:9094/starManager/websocket");

其中,starManager是工程名,/webscoket是访问路径名

建立连接,前端调用scoket.open() 会使后台在静态成员变量webSocketSet里面增加一个元素,相当于一个缓存。后台服务调用sendMessage

(指定某个用户,定向)或sendInfo(遍历webSocketSet逐个发送,类似群发)方法,即可向已登录的客户端推送消息。

代码就这么多。我的用这些代码就跑的起来。做的时候出现过页面报404等错误,如果也是spring boot+h5,仔细核对下和我代码有无区别,加配置 路径是有ok,问题应该不大。

使用spring boot +WebSocket实现(后台主动)消息推送

相关推荐