JeecgBoot关于websocket的改进方案

1.环境描述

JeecgBoot3.0

2.websocket权限认证

在shiroConfig.java代码中注释掉

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

配置拦截器

package org.jeecg.config.websocket;import org.apache.commons.lang.StringUtils;
import org.springframework.http.server.ServerHttpRequest;
import org.springframework.http.server.ServerHttpResponse;
import org.springframework.http.server.ServletServerHttpRequest;
import org.springframework.http.server.ServletServerHttpResponse;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.server.support.HttpSessionHandshakeInterceptor;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.Map;@Component
public class HandshakeInterceptor extends HttpSessionHandshakeInterceptor {@Overridepublic boolean beforeHandshake(ServerHttpRequest request,ServerHttpResponse response, WebSocketHandler wsHandler,Map<String, Object> attributes) throws Exception {return super.beforeHandshake(request, response, wsHandler, attributes);}@Overridepublic void afterHandshake(ServerHttpRequest request,ServerHttpResponse response, WebSocketHandler wsHandler,Exception ex) {HttpServletRequest httpServletRequest = ((ServletServerHttpRequest)request).getServletRequest();HttpServletResponse httpServletResponse = ((ServletServerHttpResponse)response).getServletResponse();if(StringUtils.isNotEmpty(httpServletRequest.getHeader("sec-websocket-protocol")))httpServletResponse.addHeader("sec-websocket-protocol", httpServletRequest.getHeader("sec-websocket-protocol"));super.afterHandshake(request, response, wsHandler, ex);}
}

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

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

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

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

4.重复发送问题

原有的代码为:

     /*** 服务器端推送消息*/public void pushMessage(String message) {try {webSockets.forEach(ws -> ws.session.getAsyncRemote().sendText(message));} catch (Exception e) {e.printStackTrace();}}@OnMessagepublic void onMessage(String message) {//todo 现在有个定时任务刷，应该去掉log.debug("【websocket消息】收到客户端消息:" + message);JSONObject obj = new JSONObject();//业务类型obj.put(WebsocketConst.MSG_CMD, WebsocketConst.CMD_CHECK);//消息内容obj.put(WebsocketConst.MSG_TXT, "心跳响应");for (WebSocket webSocket : webSockets) {webSocket.pushMessage(message);}}

可将OnMessage函数改为：

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

JeecgBoot关于websocket的改进方案相关推荐

关于consistent hash的思考及改进方案
这里默认读者已经知道了一致性hash算法的原理. 1. 为什么在某台机器宕机之后consistent hash算法能够避免所有或者大部分key重新hash? 首先需要弄清的是,如果某一台机器宕机之后, ...
[分享]技术改进方案模板
来自: http://www.cnblogs.com/raol/archive/2013/04/25/program_template.html 关于XX改进方案现状描述: 不满意的地方: 1. 2 ...
图像检索：图像拷贝检索PHash改进方案
感知哈希是用来做图像拷贝检索(Copy Detection)最容易操作的一种方法,实际上除了感知哈希.均值哈希,还有很多的从图像本身出发计算出来的图像哈希值,在OpenCV 3.3及其以后的版本中,包 ...
十大经典排序算法（附代码、动画及改进方案）
前言说明十大排序算法可以说是每个程序员最早接触的也是最重要的算法,这一块必须要非常熟练的掌握,应该要理解每种排序的思想,对各个排序的性能的了解也是基础且重要的.为了方便自己和大家学习,决定整合成一篇 ...
欢迎广大编程爱好者为MyPage网站提供改进方案
MyPage网站现投资一大笔资金用于网站的改进,欢迎广大编程爱好者为其提供改进的方案.每个改进的方案一经采纳后将根据方案的优秀程度得到100-500元不等的经费资助.如果方案特别优秀,MyPage网站 ...
某项目608版本投产前验收问题报告与后续研发流程改进方案
一.问题描述及问题分析 1.问题描述 608版本计划于6.30日上线,该版本在投产前的验证环节发现项目详情中合同执行表有内容,而项目信息下载的合同执行表却为空. 2.原因分析合同执行表下载逻辑中,对 ...
DTcms-【改进】-我自己的改进方案
我自己的改进方案 1. 建议应该将"附加信息"和附件的图片进行分开的存放单台服务器的图片分文件夹存放主从服务器图片的分文件夹存放在删除某一信息[文章信息下载信息 ...
对于XL改进方案的初步分析
根据前一篇博客中统计的单个事务耗时分布,我们发现每个请求在datanode执行的时间与PG执行时间几乎一样. 之前测试的是短事务,一个事务一个insert语句写入一条数据,这种场景对于xl来说没有什么 ...
【思考进步】2022年1月读书思考和改进方案
一.进度总结先给出结论,按之前预想的进度来说,是失败的. 再次基础上,我经过反思得出一些结论和后续建设性的改进方案,希望给自己和想读书的各位一些启发. 二.理想进度和实际进度的差别首先是进度上的严 ...

JeecgBoot关于websocket的改进方案

1.环境描述

2.websocket权限认证

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

4.重复发送问题

JeecgBoot关于websocket的改进方案相关推荐

最新文章

热门文章