diff --git a/src/main/java/com/sqx/modules/chat/controller/app/AppChatSocket.java b/src/main/java/com/sqx/modules/chat/controller/app/AppChatSocket.java index de88980..b00ea06 100644 --- a/src/main/java/com/sqx/modules/chat/controller/app/AppChatSocket.java +++ b/src/main/java/com/sqx/modules/chat/controller/app/AppChatSocket.java @@ -140,7 +140,8 @@ public class AppChatSocket {//用户聊天 // } List toUsers = chatContentService.selectUserByConversationId(Long.parseLong(chatConversationId)); for(ChatContent toUser :toUsers){ - AppChatSocket chatSocket = clients.get(toUser.getUserId()); + String toUserId = String.valueOf(toUser.getUserId()); + AppChatSocket chatSocket = clients.get(toUserId); if (chatSocket!=null) { chatSocket.session.getAsyncRemote().sendText(message); System.err.println(this.userId+"发送成功:"+userId);