chenkaiyang
/
chat-demo
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

聊天室信息发送

This commit is contained in:
chanbook 2022-08-08 16:51:31 +08:00
parent d6b62f282b
commit 082aedafdf
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/zhangshu/chat/demo/websocket/ChatRoom.java
View File

@ -39,10 +39,10 @@ public class ChatRoom {
*/ */
@OnOpen @OnOpen
public void onOpen(Session session, @PathParam("roomId") String roomId) { public void onOpen(Session session, @PathParam("roomId") String roomId) {
// if (getRoomCache().createSuccess(roomId)) { if (getRoomCache().createSuccess(roomId)) {
// this.sendMessage("无此房间，拒绝连接", session); this.sendMessage("无此房间，拒绝连接", session);
// return; return;
// } }
Principal userPrincipal = session.getUserPrincipal(); Principal userPrincipal = session.getUserPrincipal();
if (Objects.isNull(userPrincipal)) { if (Objects.isNull(userPrincipal)) {
this.sendMessage("用户验证失败，拒绝连接", session); this.sendMessage("用户验证失败，拒绝连接", session);