四川省网关接口相关2

jiazx0107@163.com

2023-10-24 f2cacfb5c8760d2b9b539821cc9e13054dbc1320

 src/main/java/com/fzzy/gateway/sc2023/websocket/WebSocketMqtt.java

@@ -1,13 +1,15 @@
package com.fzzy.gateway.sc2023.websocket;

import lombok.extern.slf4j.Slf4j;

import org.springframework.stereotype.Component;

import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 *
@@ -17,13 +19,13 @@
@ServerEndpoint(value = "/mqtt")
public class WebSocketMqtt {

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

    // 与某个客户端的连接会话，需要通过它来给客户端发送数据
    private Session session;

    private String key;

    
    
    @OnOpen
    public void onOpen(Session session,
                       @PathParam("keepalive") String keepalive,