From 870e9ba8a892ebec43f5f25064a3c8bd6ddc024d Mon Sep 17 00:00:00 2001 From: Odboy Date: Sat, 21 Feb 2026 21:33:45 +0800 Subject: [PATCH] =?UTF-8?q?docs(websocket):=20=E6=9B=B4=E6=96=B0WebSocket?= =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF=E7=AE=A1=E7=90=86=E5=99=A8=E6=B3=A8?= =?UTF-8?q?=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 修改了KitWsClientManager类的注释说明 - 将"分布式必出问题"更改为"已通过redis pub/sub解耦" - 说明了当前实现已解决分布式部署问题 --- .../odboy/framework/websocket/context/KitWsClientManager.java | 2 +- .../odboy/framework/websocket/context/KitWsClientManager.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/cutejava-springboot3/cutejava-framework/src/main/java/cn/odboy/framework/websocket/context/KitWsClientManager.java b/cutejava-springboot3/cutejava-framework/src/main/java/cn/odboy/framework/websocket/context/KitWsClientManager.java index a3616a8f..79472d70 100644 --- a/cutejava-springboot3/cutejava-framework/src/main/java/cn/odboy/framework/websocket/context/KitWsClientManager.java +++ b/cutejava-springboot3/cutejava-framework/src/main/java/cn/odboy/framework/websocket/context/KitWsClientManager.java @@ -31,7 +31,7 @@ import lombok.extern.slf4j.Slf4j; public class KitWsClientManager { /** - * concurrent包的线程安全Map, 用来存放每个客户端对应的MyWebSocket对象。（分布式必出问题） + * concurrent包的线程安全Map, 用来存放每个客户端对应的MyWebSocket对象（已通过redis pub/sub解耦） */ private static final Map clientMap = new ConcurrentHashMap<>(); diff --git a/cutejava/cutejava-framework/src/main/java/cn/odboy/framework/websocket/context/KitWsClientManager.java b/cutejava/cutejava-framework/src/main/java/cn/odboy/framework/websocket/context/KitWsClientManager.java index a3616a8f..79472d70 100644 --- a/cutejava/cutejava-framework/src/main/java/cn/odboy/framework/websocket/context/KitWsClientManager.java +++ b/cutejava/cutejava-framework/src/main/java/cn/odboy/framework/websocket/context/KitWsClientManager.java @@ -31,7 +31,7 @@ import lombok.extern.slf4j.Slf4j; public class KitWsClientManager { /** - * concurrent包的线程安全Map, 用来存放每个客户端对应的MyWebSocket对象。（分布式必出问题） + * concurrent包的线程安全Map, 用来存放每个客户端对应的MyWebSocket对象（已通过redis pub/sub解耦） */ private static final Map clientMap = new ConcurrentHashMap<>();