From 82673bcee70e5c0bd7d29f21e7476a0e6364de06 Mon Sep 17 00:00:00 2001 From: zhangshanxue Date: Fri, 16 Oct 2020 14:46:13 +0800 Subject: [PATCH] user lru --- .../ljsd/jieling/logic/dao/UserManager.java | 26 +++++++++---------- 1 file changed, 13 insertions(+), 13 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/UserManager.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/UserManager.java index 88936cc2d..972c6ce9d 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/UserManager.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/UserManager.java @@ -53,20 +53,20 @@ public class UserManager { //离线清除逻辑 public static void checkOffline(){ try { -// Set collect = userMap.entrySet().stream().filter(integerUserEntry -> !OnlineUserManager.checkUidOnline(integerUserEntry.getKey())).map(Map.Entry::getValue).collect(Collectors.toSet()); -// long l = System.currentTimeMillis(); -// collect.forEach(integerUserEntry -> { -// long offLineTime = integerUserEntry.getPlayerInfoManager().getOffLineTime(); -// if(offLineTime12*60*60*1000&& userMapPutTime.getOrDefault(integerUserEntry.getId(),0L)>12*60*60*1000){ -// userMap.remove(integerUserEntry.getId()); -// userMapPutTime.remove(integerUserEntry.getId()); -// } -// }); + Set collect = userMap.entrySet().stream().filter(integerUserEntry -> !OnlineUserManager.checkUidOnline(integerUserEntry.getKey())).map(Map.Entry::getValue).collect(Collectors.toSet()); + long l = System.currentTimeMillis(); + collect.forEach(integerUserEntry -> { + long offLineTime = integerUserEntry.getPlayerInfoManager().getOffLineTime(); + if(offLineTime12*60*60*1000&& userMapPutTime.getOrDefault(integerUserEntry.getId(),0L)>12*60*60*1000){ + userMap.remove(integerUserEntry.getId()); + userMapPutTime.remove(integerUserEntry.getId()); + } + }); }catch (Exception e){ - LOGGER.error(e.toString()); + LOGGER.error("Exception离线清除逻辑err={}",e.toString()); } }