From f974ff6023c32070d38012c6177f59a771c421c0 Mon Sep 17 00:00:00 2001
From: mitao <2763622819@qq.com>
Date: 星期一, 29 七月 2024 16:11:43 +0800
Subject: [PATCH] 修改bug
---
ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/websocket/WebSocketServer.java | 17 +++++++++++------
1 files changed, 11 insertions(+), 6 deletions(-)
diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/websocket/WebSocketServer.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/websocket/WebSocketServer.java
index 33ae939..bd6bdb4 100644
--- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/websocket/WebSocketServer.java
+++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/websocket/WebSocketServer.java
@@ -1,6 +1,5 @@
package com.ruoyi.system.websocket;
-import com.ruoyi.system.api.util.WebSocketUsers;
import java.util.concurrent.Semaphore;
import javax.websocket.OnClose;
import javax.websocket.OnError;
@@ -38,9 +37,15 @@
session.close();
} else {
WebSocketUsers.put(session.getId(), session, clientType);
- LOGGER.info("\n 建立连接 - {}", session);
+
+ if (clientType == 1) {
+ LOGGER.info("\n 用户端建立连接 - {}", session);
+ WebSocketUsers.sendMessageToUserByText(session, "用户端连接成功");
+ } else if (clientType == 2) {
+ LOGGER.info("\n 拍卖师端建立连接 - {}", session);
+ WebSocketUsers.sendMessageToUserByText(session, "拍卖师端连接成功");
+ }
LOGGER.info("\n 当前人数 - {}", WebSocketUsers.getUsers().size());
- WebSocketUsers.sendMessageToUserByText(session, "连接成功");
}
}
@@ -65,8 +70,8 @@
@OnMessage
public void onMessage(String message, Session session) {
- String msg = message.replace("你", "我").replace("吗", "").replace("PING", "PONG")
- .replace("ping", "pong");
- WebSocketUsers.sendMessageToUserByText(session, msg);
+ // String msg = message.replace("你", "我").replace("吗", "").replace("PING", "PONG")
+ // .replace("ping", "pong");
+ // WebSocketUsers.sendMessageToUserByText(session, msg);
}
}
--
Gitblit v1.7.1