目錄附錄聊天室：@ServicepublicclassWebSocketServiceImplimplementsWebSocketService{@AutowiredprivateChatServicechatService;@AutowiredprivateChatMapperchatMapper;@AutowiredprivateSysUserServicesysUserService;@OverridepublicvoidaddUser(StringaccountName,StringnovelId,StringchapterId,Sessionsession){//1、獲取當(dāng)前用戶信息SysUsersysUser=sysUserService.getOne(newQueryWrapper<SysUser>().eq(SqlConstant.ACCOUNT_NAME,accountName));//1、保存當(dāng)前用戶信息WebSocketUserInfowebSocketUserInfo=newWebSocketUserInfo();webSocketUserInfo.setUserId(sysUser.getId());webSocketUserInfo.setUsername(sysUser.getUserName());webSocketUserInfo.setAccountName(accountName);webSocketUserInfo.setNovelId(novelId);webSocketUserInfo.setChapterId(chapterId);webSocketUserInfo.setSession(session);WebSocketUtils.addSession(accountName,webSocketUserInfo);//2、給當(dāng)前的用戶從數(shù)據(jù)庫(kù)撈出最新的10條聊天數(shù)據(jù)List<Chat>chats=this.chatMapper.selectList(newQueryWrapper<Chat>().eq(SqlConstant.NOVEL_ID,novelId).eq(SqlConstant.CHAPTER_ID,chapterId).in(SqlConstant.MSG_TYPE,MessageType.NOTICT_MSG,MessageType.CHAT_MSG.getCode(),MessageType.USER_MSG.getCode()).orderByDesc(SqlConstant.SEND_TIME).last("limit10"));//取出的數(shù)據(jù)再按照正序排if(!chats.isEmpty()){chats=chats.stream().sorted(Cparing(Chat::getSendTime)).collect(Collectors.toList());}for(Chatchat:chats){if(chat.getMsgType().equals(MessageType.NOTICT_MSG.getCode())){this.sendMessageForNovelIdAndChapterId(chat.getNovelId(),chat.getChapterId(),chat.getMessage(),chat.getMsgType());}elseif(chat.getSendUserId().equals(sysUser.getId())){this.sendMessageForNovelIdAndChapterId(chat.getNovelId(),chat.getChapterId(),chat.getMessage(),MessageType.USER_MSG.getCode());}else{this.sendMessageForNovelIdAndChapterId(chat.getNovelId(),chat.getChapterId(),chat.getMessage(),MessageType.CHAT_MSG.getCode());}}//3、通知當(dāng)前章節(jié)的用戶當(dāng)前用戶已經(jīng)上線StringuserUpMsg=accountName+"用戶已上線";this.sendMessageForNovelIdAndChapterId(novelId,chapterId,userUpMsg,MessageType.NOTICT_MSG.getCode());//保存上線提示信息Chatchat=newChat(StringUtils.getUuid(),userUpMsg,sysUser.getId(),newDate(),novelId,chapterId,MessageType.NOTICT_MSG.getCode());this.chatService.save(chat);//4、當(dāng)前在線人數(shù)+1this.sendMessageOnlineNum(novelId,chapterId);}@OverridepublicvoidexitChat(StringaccountName,StringnovelId,StringchapterId,Sessionsession){WebSocketUserInfouserInfo=WebSocketUtils.getUserInfo(accountName);//1、移除當(dāng)前人的信息WebSocketUtils.removeSession(accountName);//2、通知當(dāng)前章節(jié)用戶已下線StringexitMsg=accountName+"用戶已下線";this.sendMessageForNovelIdAndChapterId(novelId,chapterId,exitMsg,MessageType.NOTICT_MSG.getCode());//保存下線提示信息Chatchat=newChat(StringUtils.getUuid(),exitMsg,userInfo.getUserId(),newDate(),novelId,chapterId,MessageType.NOTICT_MSG.getCode());this.chatService.save(chat);//3、當(dāng)前在線人數(shù)減一this.sendMessageOnlineNum(novelId,chapterId);}@OverridepublicvoidsendMessage(StringaccountName,StringnovelId,StringchapterId,Sessionsession,Stringmessage){//1、群發(fā)Map<String,WebSocketUserInfo>onlineSession=WebSocketUtils.getOnlineSession();WebSocketUserInfosendUserInfo=WebSocketUtils.getUserInfo(accountName);for(Map.Entry<String,WebSocketUserInfo>entry:onlineSession.entrySet()){WebSocketUserInfouserInfo=entry.getValue();//發(fā)送消息WebSocketPojowebSocketPojo=newWebSocketPojo();webSocketPojo.setAccountName(accountName);webSocketPojo.setUsername(userInfo.getUsername());webSocketPojo.setMessageTime(newDate());webSocketPojo.setMessage(message);if(accountName.equals(userInfo.getAccountName())){webSocketPojo.setMsgType(MessageType.USER_MSG.getCode());}elseif(userInfo.getNovelId().equals(novelId)&&userInfo.getChapterId().equals(chapterId)){//發(fā)送消息webSocketPojo.setMsgType(MessageType.CHAT_MSG.getCode());}WebSocketUtils.sendMessage(userInfo.ge