root
/
miduo_server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

user lru

back_recharge
zhangshanxue 2020-10-16 14:46:13 +08:00
parent f7c5cfb7c4
commit 82673bcee7
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
serverlogic/src/main/java/com/ljsd/jieling/logic/dao/UserManager.java
View File

@ -53,20 +53,20 @@ public class UserManager {
//离线清除逻辑
public static void checkOffline(){
try {
// Set<User> 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(offLineTime<integerUserEntry.getPlayerInfoManager().getOnlineTime()){
// return;
// }
// if(l-offLineTime>12*60*60*1000&& userMapPutTime.getOrDefault(integerUserEntry.getId(),0L)>12*60*60*1000){
// userMap.remove(integerUserEntry.getId());
// userMapPutTime.remove(integerUserEntry.getId());
// }
// });
Set<User> 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(offLineTime<integerUserEntry.getPlayerInfoManager().getOnlineTime()){
return;
}
if(l-offLineTime>12*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());
}
}