From ac2b4ef91a2dc4ad452f8fadf2e9fc0bcb23ac7d Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Thu, 23 Mar 2023 11:53:10 +0800
Subject: [PATCH] 修复问题
---
src/main/java/org/springblade/common/handler/SocketIOService.java | 3 ++-
1 files changed, 2 insertions(+), 1 deletions(-)
diff --git a/src/main/java/org/springblade/common/handler/SocketIOService.java b/src/main/java/org/springblade/common/handler/SocketIOService.java
index 70b88ba..d7f8d81 100644
--- a/src/main/java/org/springblade/common/handler/SocketIOService.java
+++ b/src/main/java/org/springblade/common/handler/SocketIOService.java
@@ -81,7 +81,7 @@
if (clientMap.containsKey(socketEntity.getCurrent())){
client.sendEvent("connectError",R.fail("连接已存在"));
- log.info("设备{}连接失败",socketEntity.getCurrent());
+ log.info("设备{}连接已存在",socketEntity.getCurrent());
}else {
clientMap.put(socketEntity.getCurrent(),client);
client.sendEvent("connectOk",R.success("连接成功"));
@@ -137,6 +137,7 @@
public void OnEvent(SocketIOClient client) {
String connectInfo = client.getHandshakeData().getSingleUrlParam("connectInfo");
SocketEntity socketEntity = parseMsg(connectInfo);
+ //保证断连只会断连自己，不会断连其他客户端
clientMap.forEach((key,value)->{
if (value.getSessionId().equals(client.getSessionId())){
clientMap.remove(key);
--
Gitblit v1.9.3