back_recharge
lvxinran 2019-09-18 11:35:23 +08:00
commit 67dc20bd41
3 changed files with 2 additions and 4 deletions

View File

@ -299,7 +299,6 @@ public class ProtocolsManager implements ProtocolsAbstract {
iSession.setOfflineType(ErrorCode.reloginCode);
backUpMsgToRedis(iSession);
OnlineUserManager.userOffline(uid);
LOGGER.info("the channel={}",iSession.getCtx().channel());
return 1;
}
return 0;
@ -401,7 +400,6 @@ public class ProtocolsManager implements ProtocolsAbstract {
}
String key = RedisUtil.getInstence().getKey(RedisKey.RESPONSE_OFFLINE, Integer.toString(session.getUid()));
LOGGER.info("the uid={},the offlineIndex={},",session.getUid(),session.getIndexToMessage().keySet().iterator().next());
RedisUtil.getInstence().set(key,gson.toJson(session.getIndexToMessage()));
}

View File

@ -76,7 +76,7 @@ public class MinuteTask extends Thread {
int minute = calendar.get(Calendar.MINUTE);
if(minute%5 == 0){
KTAppOnline ktAppOnline = new KTAppOnline();
int onlineNum = OnlineUserManager.onlineUserMap.size();
int onlineNum = OnlineUserManager.sessionMap.size();
ParamEventBean paramEventBean = new ParamEventBean(ParamEventBean.OnlineEvent);
int time =(int)(calendar.getTimeInMillis()/1000);
paramEventBean.add(String.valueOf(time));

View File

@ -28,7 +28,7 @@ public class MessageUtil {
backMessage = new byte[0];
} else {
backMessage = generatedMessage.toByteArray();
LOGGER.info(JsonFormat.printToString(generatedMessage));
//LOGGER.info(JsonFormat.printToString(generatedMessage));
}
int length = PackageConstant.UID_FIELD_LEN + PackageConstant.TOKEN_LEN