fix:User_Logout_NPE

cim-client-sdk/src/test/java/com/crossoverjie/cim/client/sdk/ClientTest.java

@@ -395,4 +395,26 @@ public void testClose() throws Exception {
         super.stopSingle();
     }
 
+    @Test
+    public void testIncorrectUser() throws Exception {
+        super.starSingleServer();
+        super.startRoute();
+        String routeUrl = "http://localhost:8083";
+        String cj = "xx";
+        long id = 100L;
+        var auth1 = ClientConfigurationData.Auth.builder()
+                .userId(id)
+                .userName(cj)
+                .build();
+
+        Client client1 = Client.builder()
+                .auth(auth1)
+                .routeUrl(routeUrl)
+                .build();
+        TimeUnit.SECONDS.sleep(3);
+
+        Assertions.assertDoesNotThrow(client1::close);
+
+        super.stopSingle();
+    }
 }

cim-forward-route/src/main/java/com/crossoverjie/cim/route/controller/RouteController.java

@@ -23,6 +23,7 @@
 import jakarta.annotation.Resource;
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 import java.util.Set;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -75,7 +76,7 @@ public BaseResponse<NULLBody> groupRoute(@RequestBody ChatReqVO groupReqVO) thro
             CIMServerResVO cimServerResVO = cimServerResVOEntry.getValue();
             if (userId.equals(groupReqVO.getUserId())) {
                 //过滤掉自己
-                CIMUserInfo cimUserInfo = userInfoCacheService.loadUserInfoByUserId(groupReqVO.getUserId());
+                Optional<CIMUserInfo> cimUserInfo = userInfoCacheService.loadUserInfoByUserId(groupReqVO.getUserId());
                 log.warn("过滤掉了发送者 userId={}", cimUserInfo.toString());
                 continue;
             }
@@ -131,10 +132,12 @@ public BaseResponse<NULLBody> p2pRoute(@RequestBody P2PReqVO p2pRequest) throws
     public BaseResponse<NULLBody> offLine(@RequestBody ChatReqVO groupReqVO) {
         BaseResponse<NULLBody> res = new BaseResponse();
 
-        CIMUserInfo cimUserInfo = userInfoCacheService.loadUserInfoByUserId(groupReqVO.getUserId());
+        Optional<CIMUserInfo> cimUserInfo = userInfoCacheService.loadUserInfoByUserId(groupReqVO.getUserId());
 
-        log.info("user [{}] offline!", cimUserInfo.toString());
-        accountService.offLine(groupReqVO.getUserId());
+        if(cimUserInfo.isPresent()){
+            log.info("user [{}] offline!", cimUserInfo.toString());
+            accountService.offLine(groupReqVO.getUserId());
+        }
 
         res.setCode(StatusEnum.SUCCESS.getCode());
         res.setMessage(StatusEnum.SUCCESS.getMessage());

cim-forward-route/src/main/java/com/crossoverjie/cim/route/service/UserInfoCacheService.java

@@ -2,6 +2,7 @@
 
 import com.crossoverjie.cim.common.pojo.CIMUserInfo;
 
+import java.util.Optional;
 import java.util.Set;
 
 /**
@@ -19,7 +20,7 @@ public interface UserInfoCacheService {
      * @return
      * @throws Exception
      */
-    CIMUserInfo loadUserInfoByUserId(Long userId) ;
+    Optional<CIMUserInfo> loadUserInfoByUserId(Long userId) ;
 
     /**
      * 保存和检查用户登录情况

cim-forward-route/src/main/java/com/crossoverjie/cim/route/service/impl/AccountServiceRedisImpl.java

@@ -32,6 +32,7 @@
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.Map;
+import java.util.Optional;
 
 import static com.crossoverjie.cim.common.enums.StatusEnum.OFF_LINE;
 import static com.crossoverjie.cim.route.constant.Constant.*;
@@ -154,11 +155,12 @@ private void parseServerInfo(Map<Long, CIMServerResVO> routes, String key) {
 
     @Override
     public void pushMsg(CIMServerResVO cimServerResVO, long sendUserId, ChatReqVO groupReqVO) throws Exception {
-        CIMUserInfo cimUserInfo = userInfoCacheService.loadUserInfoByUserId(sendUserId);
+        Optional<CIMUserInfo> cimUserInfo = userInfoCacheService.loadUserInfoByUserId(sendUserId);
 
         String url = "http://" + cimServerResVO.getIp() + ":" + cimServerResVO.getHttpPort();
+        ServerApi serverApi = RpcProxyManager.create(ServerApi.class, okHttpClient);
+        SendMsgReqVO vo = new SendMsgReqVO(cimUserInfo.get().getUserName() + ":" + groupReqVO.getMsg(), groupReqVO.getUserId());
 
-        SendMsgReqVO vo = new SendMsgReqVO(cimUserInfo.getUserName() + ":" + groupReqVO.getMsg(), groupReqVO.getUserId());
         serverApi.sendMsg(vo, url);
     }
 

cim-forward-route/src/main/java/com/crossoverjie/cim/route/service/impl/UserInfoCacheServiceImpl.java

@@ -8,6 +8,7 @@
 
 import java.util.HashSet;
 import java.util.Map;
+import java.util.Optional;
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 
@@ -34,12 +35,12 @@ public class UserInfoCacheServiceImpl implements UserInfoCacheService {
     private RedisTemplate<String,String> redisTemplate ;
 
     @Override
-    public CIMUserInfo loadUserInfoByUserId(Long userId) {
+    public Optional<CIMUserInfo> loadUserInfoByUserId(Long userId) {
 
         //优先从本地缓存获取
         CIMUserInfo cimUserInfo = USER_INFO_MAP.get(userId);
         if (cimUserInfo != null){
-            return cimUserInfo ;
+            return Optional.ofNullable(cimUserInfo);
         }
 
         //load redis
@@ -49,7 +50,7 @@ public CIMUserInfo loadUserInfoByUserId(Long userId) {
             USER_INFO_MAP.put(userId,cimUserInfo) ;
         }
 
-        return cimUserInfo;
+        return Optional.ofNullable(cimUserInfo);
     }
 
     @Override
@@ -71,8 +72,9 @@ public Set<CIMUserInfo> onlineUser() {
             if (set == null){
                 set = new HashSet<>(64) ;
             }
-            CIMUserInfo cimUserInfo = loadUserInfoByUserId(Long.valueOf(member)) ;
-            set.add(cimUserInfo) ;
+            Optional<CIMUserInfo> cimUserInfo = loadUserInfoByUserId(Long.valueOf(member)) ;
+
+            cimUserInfo.ifPresentOrElse(set::add, () -> {});
         }
 
         return set;