JeecgBoot关于websocket的改进方案

zhangdaiscott

1.环境描述

JeecgBoot3.0

2.websocket权限认证

• 在shiroConfig.java代码中注释掉
  

1. filterChainDefinitionMap.put("/websocket/**", "anon");//系统通知和公告

复制代码

• 配置拦截器
  

1. package org.jeecg.config.websocket;
   
2. 
   
3. import org.apache.commons.lang.StringUtils;
   
4. import org.springframework.http.server.ServerHttpRequest;
   
5. import org.springframework.http.server.ServerHttpResponse;
   
6. import org.springframework.http.server.ServletServerHttpRequest;
   
7. import org.springframework.http.server.ServletServerHttpResponse;
   
8. import org.springframework.stereotype.Component;
   
9. import org.springframework.web.socket.WebSocketHandler;
   
10. import org.springframework.web.socket.server.support.HttpSessionHandshakeInterceptor;
    
11. import javax.servlet.http.HttpServletRequest;
    
12. import javax.servlet.http.HttpServletResponse;
    
13. import java.util.Map;
    
14. 
    
15. @Component
    
16. public class HandshakeInterceptor extends HttpSessionHandshakeInterceptor {
    
17. 
    
18.     @Override
    
19.     public boolean beforeHandshake(ServerHttpRequest request,
    
20.                                    ServerHttpResponse response, WebSocketHandler wsHandler,
    
21.                                    Map<String, Object> attributes) throws Exception {
    
22.         return super.beforeHandshake(request, response, wsHandler, attributes);
    
23.     }
    
24. 
    
25.     @Override
    
26.     public void afterHandshake(ServerHttpRequest request,
    
27.                                ServerHttpResponse response, WebSocketHandler wsHandler,
    
28.                                Exception ex) {
    
29. 
    
30.         HttpServletRequest httpServletRequest = ((ServletServerHttpRequest)request).getServletRequest();
    
31.         HttpServletResponse httpServletResponse = ((ServletServerHttpResponse)response).getServletResponse();
    
32.         if(StringUtils.isNotEmpty(httpServletRequest.getHeader("sec-websocket-protocol")))
    
33.             httpServletResponse.addHeader("sec-websocket-protocol", httpServletRequest.getHeader("sec-websocket-protocol"));
    
34.         super.afterHandshake(request, response, wsHandler, ex);
    
35.     }
    
36. }

复制代码

• 修改前端的请求，在HeaderNotice.vue中
  

1. let token = Vue.ls.get(ACCESS_TOKEN)
   
2. var url = window._CONFIG['domianURL'].replace("https://","wss://").replace("http://","ws://")+"/websocket/"+userId +"?token="+token

复制代码

3. HashMap不是线程安全的，可以改为线程安全的map，如下

1. private static Map<String, Session> sessionPool = new ConcurrentHashMap<>();

复制代码

4.重复发送问题

• 原有的代码为:
  

1. /**
   
2.      * 服务器端推送消息
   
3.      */
   
4.     public void pushMessage(String message) {
   
5.         try {
   
6.             webSockets.forEach(ws -> ws.session.getAsyncRemote().sendText(message));
   
7.         } catch (Exception e) {
   
8.             e.printStackTrace();
   
9.         }
   
10.     }
    
11. 
    
12. 
    
13.     @OnMessage
    
14.     public void onMessage(String message) {
    
15.         //todo 现在有个定时任务刷，应该去掉
    
16.         log.debug("【websocket消息】收到客户端消息:" + message);
    
17.         JSONObject obj = new JSONObject();
    
18.         //业务类型
    
19.         obj.put(WebsocketConst.MSG_CMD, WebsocketConst.CMD_CHECK);
    
20.         //消息内容
    
21.         obj.put(WebsocketConst.MSG_TXT, "心跳响应");
    
22.         for (WebSocket webSocket : webSockets) {
    
23.             webSocket.pushMessage(message);
    
24.         }
    
25.     }

复制代码

• 可将OnMessage函数改为：
  

   

1. @OnMessage
   
2.     public void onMessage(String message) {
   
3.         //todo 现在有个定时任务刷，应该去掉
   
4.         log.debug("【websocket消息】收到客户端消息:" + message);
   
5.         JSONObject obj = new JSONObject();
   
6.         //业务类型
   
7.         obj.put(WebsocketConst.MSG_CMD, WebsocketConst.CMD_CHECK);
   
8.         //消息内容
   
9.         obj.put(WebsocketConst.MSG_TXT, "心跳响应");
   
10.         for (WebSocket webSocket : webSockets) {
    
11.    //webSocket.pushMessage(message);
    
12.             webSocket.session.getAsyncRemote().sendText(message);
    
13.         }
    
14.     }

复制代码

水果奶娘99

这时相机的稳定性问题就会变得幸运飞艇直播，福彩双色球结果，幸运时时彩走势图非常突出，一丁点儿的晃动都会致使成像模糊不清，导致拍摄失败