完善websocket发消息日志
This commit is contained in:
parent
116e08474b
commit
d635db503a
|
|
@ -112,9 +112,25 @@ public class SdWebsocket {
|
|||
* @param message
|
||||
*/
|
||||
public void sendMessage(String userId, String message) {
|
||||
log.info("【系统 SdWebsocket】广播,userId:"+userId+",消息:"+message);
|
||||
log.info("【系统 SdWebsocket】向用户 {} 发送消息: {}", userId, message);
|
||||
|
||||
// 打印所有在线用户
|
||||
StringBuilder userList = new StringBuilder();
|
||||
for (String user : sessionPool.keySet()) {
|
||||
if (userList.length() > 0) {
|
||||
userList.append(", ");
|
||||
}
|
||||
userList.append(user);
|
||||
}
|
||||
log.info("【系统 SdWebsocket】当前在线用户: [{}] 共 {} 人", userList.toString(), sessionPool.size());
|
||||
|
||||
Session session = sessionPool.get(userId);
|
||||
session.getAsyncRemote().sendText(message);
|
||||
if (session != null && session.isOpen()) {
|
||||
session.getAsyncRemote().sendText(message);
|
||||
log.debug("【系统 SdWebsocket】消息发送成功");
|
||||
} else {
|
||||
log.warn("【系统 SdWebsocket】用户 {} 不在线或连接已关闭,无法发送消息", userId);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
|||
Loading…
Reference in New Issue