延长redis数据缓存时间

jim-server/src/main/java/org/jim/server/command/handler/LoginReqHandler.java

@@ -29,6 +29,7 @@ import org.tio.core.Aio;
 import org.tio.core.ChannelContext;
 import org.tio.utils.lock.SetWithLock;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Set;
 import java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock;
@@ -99,8 +100,16 @@ public class LoginReqHandler extends AbstractCmdHandler {
 		imSessionContext.getClient().setUser(user);
 		//绑定用户
 		ImAio.bindUser(channelContext,userId,imConfig.getMessageHelper().getBindListener());
+
+		List<Group> groups = user.getGroups();
+		//把客服绑定到 由客服主动发起聊天的群组
+		if(CollectionUtils.isNotEmpty(user.getIntoChatGroups())){
+			groups.addAll(user.getIntoChatGroups());
+			user.setGroups(groups);
+		}
+
 		//初始化绑定,并且解绑与当前用户绑定群组不一致的群组;
-		bindUnbindGroup(channelContext, user, user.getGroups());
+		bindUnbindGroup(channelContext, user, groups);
 		//判断当前用户 是否具有 查看所有客服权限 如果有 绑定群组
 		hasViewAllServiceAccountAuthority(channelContext,user);
 		//初始化 由客服主动发起聊天的群组
@@ -127,8 +136,6 @@ public class LoginReqHandler extends AbstractCmdHandler {
 		if(VisitTypeEnum.SERVICEACCOUNT.getKey().equals(user.getVisitType())){
 			if( user.getExtras().getBoolean("intoChat") ){
 				List<Group> intoChatGroups = user.getIntoChatGroups();
-				//把客服绑定到群组中
-				this.bindUnbindGroup(channelContext, user, intoChatGroups);
 				String consumerId;
 				if( VisitTypeEnum.CUSTOMER.getKey().equals(user.getExtras().get("type")) ){
 					consumerId = user.getExtras().getString("customerDepartmentId");

server-chat/src/main/java/com/cn/processor/IMChatAsyncChatMessageProcessor.java

@@ -1,13 +1,15 @@
 package com.cn.processor;
 
 import com.alibaba.fastjson.JSONObject;
+import org.apache.commons.collections4.CollectionUtils;
+import org.jim.common.ImSessionContext;
+import org.jim.common.cache.redis.RedisCache;
+import org.jim.common.cache.redis.RedisCacheManager;
+import org.jim.common.packets.*;
 import org.jim.server.model.ChatGroup;
 import org.jim.server.model.Conversation;
 import org.jim.server.model.ConversationRecord;
 import org.jim.common.ImAio;
-import org.jim.common.packets.ChatBody;
-import org.jim.common.packets.ChatType;
-import org.jim.common.packets.User;
 import org.jim.server.command.handler.processor.chat.DefaultAsyncChatMessageProcessor;
 import org.jim.server.enums.VisitTypeEnum;
 import org.jim.server.model.GroupConversationMiddle;
@@ -20,6 +22,7 @@ import java.sql.Timestamp;
 import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -33,6 +36,24 @@ public class IMChatAsyncChatMessageProcessor extends DefaultAsyncChatMessageProc
 
     private static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 
+    //设置key的过期时间 30分钟
+    private static final int TIME_OUT = 30 * 60;
+
+    private final String SUBFIX = ":";
+
+    private static RedisCache groupCache;
+
+    private static RedisCache userCache;
+
+    static{
+        RedisCacheManager.register(USER, Integer.MAX_VALUE, Integer.MAX_VALUE);
+        RedisCacheManager.register(GROUP, Integer.MAX_VALUE, Integer.MAX_VALUE);
+        RedisCacheManager.register(STORE, Integer.MAX_VALUE, Integer.MAX_VALUE);
+        RedisCacheManager.register(PUSH, Integer.MAX_VALUE, Integer.MAX_VALUE);
+        groupCache = RedisCacheManager.getCache(GROUP);
+        userCache = RedisCacheManager.getCache(USER);
+    }
+
     @Override
     public void doHandler(ChatBody chatBody, ChannelContext channelContext) {
         log.info("聊天记录持久化... 开始:" + sdf.format(new Date()));
@@ -56,11 +77,39 @@ public class IMChatAsyncChatMessageProcessor extends DefaultAsyncChatMessageProc
                     }
                 }
             }
+            //延长redis数据过期时间
+            this.extendRedisData(chatBody,channelContext);
         }
         log.info("聊天记录持久化... 结束:" + sdf.format(new Date()));
     }
 
     /**
+     * 延长redis数据过期时间
+     * @param chatBody
+     * @param channelContext
+     * @return {@link }
+     * @author Darren
+     * @date 2020/2/18 21:02
+     */
+    private void extendRedisData(ChatBody chatBody, ChannelContext channelContext){
+        String userId = chatBody.getFrom();
+        String groupId = chatBody.getGroup_id();
+        ImSessionContext imSessionContext = (ImSessionContext)channelContext.getAttribute();
+        Client client = imSessionContext.getClient();
+        if(client != null) {
+            User onlineUser = client.getUser();
+            if(onlineUser != null){
+                userCache.expire(userId + SUBFIX + TERMINAL + SUBFIX + onlineUser.getTerminal(),TIME_OUT);
+            }
+        }
+        userCache.expire( userId + SUBFIX + GROUP,TIME_OUT);
+        userCache.expire(userId + SUBFIX + INFO,TIME_OUT);
+        userCache.expire(userId + SUBFIX + FRIENDS,TIME_OUT);
+        groupCache.expire(groupId + SUBFIX + USER,TIME_OUT);
+        groupCache.expire(groupId + SUBFIX + INFO,TIME_OUT);
+    }
+
+    /**
      * 组装ConversationRecord数据
      * @param chatBody
      * @param conversation