From f2cacfb5c8760d2b9b539821cc9e13054dbc1320 Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期二, 24 十月 2023 19:37:10 +0800
Subject: [PATCH] 四川省网关接口相关2
---
src/main/java/com/fzzy/gateway/sc2023/websocket/WebSocketMqtt.java | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/fzzy/gateway/sc2023/websocket/WebSocketMqtt.java b/src/main/java/com/fzzy/gateway/sc2023/websocket/WebSocketMqtt.java
index ddd20dd..7969203 100644
--- a/src/main/java/com/fzzy/gateway/sc2023/websocket/WebSocketMqtt.java
+++ b/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,
--
Gitblit v1.9.3