layim即使通讯框架只能两个浏览器之间单向通讯问题

Posted 2022-03-28 Fire king

项目场景：

毕业设计作品：

项目场景：两个浏览器之间通信

---

问题描述

只能一个浏览器发到另一个浏览器：

两个浏览器分别登陆用户，打开框架自带的通信窗口，但是只能单向通信：

---

原因分析：

原理分析：一定要一字一句读懂

通信窗口所在页面每次刷新都会建立一个websocket连接，而后端代码就会不断保存新的连接，由于保存websocketsession使用HashMap以用户id为key保存的，所以后端session不断在map里面刷新，session.send的时候保存的websocketsession与浏览器的session不一致，所以就发不过去，但都有一个共同点，两个浏览器都能发送数据给服务器，就只是其中一个session.isOpen()判断为false，发不了数据，说是关闭状态。其实所谓的关闭状态就是后端已经保存了这个对应userId的websocketsession，但是你浏览器可能由于种种原因（session保存的设计原因，我就是）导致服务端与客户端的session不一致，所以就找不到这个session，也就认为是关闭状态了。

---

解决方案：

具体解决方案：服务端demo设计根据业务需求

解决的核心：维持连个浏览器的session和服务器HashMap保存的分别一样。这里就有人会想出一种很暴力的方法：不管登录与否，我就在某一次保存websocketsession，而且针对每个userId我只保存一次，同时保证浏览器只能创建一次websocket连接，不管用什么方式去实现这个操作。但是，我踩坑了，因为我也的确这么做。不能这样做的原因是，websocket设计之初的理念就是每个连接默认都是只能发一次消息，直到有新连接创建并且连接上去，否则就会阻塞。这就是阻塞模式。还有一个原因就是我的服务端是单线程。如果这么做的话两个浏览器就只能各自发送一次数据而已。同时，也与websocket设计理念相违背。因此，我们不能去违背框架设计理念开发，而是顺从天意，既然页面刷新就不断创建新连接，那么我们就在服务端设计存websocketSession的规则保持每次页面刷新后就在服务端同步这个session即可。还有一个办法就是单线程不行就多线程，具体如何下期分享。

前端代码：

socket = new WebSocket('ws://localhost:8080/myHandler?myid='+currentUserId);

后端代码：

//部分片段1
//消息处理类
@Component
public class MyHandler extends TextWebSocketHandler 
    @Autowired
    private RedisTemplate redisTemplate;
    // 在线用户列表
    public volatile static  Map<String, WebSocketSession> userSocketSessionMap = new HashMap<String, WebSocketSession>();
    public volatile static  Map<String, String>  loginedUser= new HashMap<String, String>();

    // 用户连接成功 就被调用
    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception 
        //获取传来的登录用户的id
        String currentUserId = session.getUri().toString().split("=")[1];
        if (!currentUserId.equals("undefined") && !StringUtils.isEmpty(currentUserId)) 
            userSocketSessionMap.put(currentUserId, session);
        
        String webSocketSessionUserId = (String)redisTemplate.opsForValue().get("webSocketSessionUserId");
        int size = userSocketSessionMap.size();
       /* if (!StringUtils.isEmpty(webSocketSessionUserId)
                && (size < 2 )
                && (!userSocketSessionMap.containsKey(webSocketSessionUserId))
        ) 
            //保存对应的WebSocketSession
            userSocketSessionMap.put(webSocketSessionUserId, session);
            loginedUser.put(webSocketSessionUserId , "");
        */
        System.err.println("用户连接成功");
    

//部分片段2
 if(session.isOpen())
                        System.out.println("回复消息");
                        System.out.println(message.getPayload());
                        session.sendMessage(message);