docs(websocket): 更新WebSocket客户端管理器注释
- 修改了KitWsClientManager类的注释说明 - 将"分布式必出问题"更改为"已通过redis pub/sub解耦" - 说明了当前实现已解决分布式部署问题
This commit is contained in:
+1
-1
@@ -31,7 +31,7 @@ import lombok.extern.slf4j.Slf4j;
|
|||||||
public class KitWsClientManager {
|
public class KitWsClientManager {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* concurrent包的线程安全Map, 用来存放每个客户端对应的MyWebSocket对象。(分布式必出问题)
|
* concurrent包的线程安全Map, 用来存放每个客户端对应的MyWebSocket对象(已通过redis pub/sub解耦)
|
||||||
*/
|
*/
|
||||||
private static final Map<String, KitWsServer> clientMap = new ConcurrentHashMap<>();
|
private static final Map<String, KitWsServer> clientMap = new ConcurrentHashMap<>();
|
||||||
|
|
||||||
|
|||||||
+1
-1
@@ -31,7 +31,7 @@ import lombok.extern.slf4j.Slf4j;
|
|||||||
public class KitWsClientManager {
|
public class KitWsClientManager {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* concurrent包的线程安全Map, 用来存放每个客户端对应的MyWebSocket对象。(分布式必出问题)
|
* concurrent包的线程安全Map, 用来存放每个客户端对应的MyWebSocket对象(已通过redis pub/sub解耦)
|
||||||
*/
|
*/
|
||||||
private static final Map<String, KitWsServer> clientMap = new ConcurrentHashMap<>();
|
private static final Map<String, KitWsServer> clientMap = new ConcurrentHashMap<>();
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user