修改bug

mitao

2024-07-29 f974ff6023c32070d38012c6177f59a771c421c0

 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);
    }
}