|
@@ -45,8 +45,10 @@ public class ChatProcessor extends WebSoketSupport implements ProcessorInterface
|
|
|
//获取消息
|
|
|
String sessionId = request.getSessionid();
|
|
|
//敏感词过滤
|
|
|
- String message = SensitivewordFilter.replaceSensitiveWord(request.getMsg(), 1, "**");
|
|
|
- request.setMsg(message);
|
|
|
+ if (request.getType() == 1){
|
|
|
+ request.setMsg(SensitivewordFilter.replaceSensitiveWord(request.getMsg(), 1, "**"));
|
|
|
+ }
|
|
|
+
|
|
|
|
|
|
//redis只存当天的消息,RedisTask中synRedisChatToDB定时任务会在每天凌晨把消息同步到数据库
|
|
|
//每次发消息,把消息累加到redis中,推送全量数据给客户端
|