From 7d84edc660c0e54f9e448c47707cb8574c05a3a8 Mon Sep 17 00:00:00 2001 From: wangyuan Date: Thu, 19 Sep 2019 20:21:06 +0800 Subject: [PATCH] fix reconnect --- .../jieling/network/server/ProtocolsManager.java | 6 +----- .../thread/task/RetrySendIndicationThread.java | 13 ------------- 2 files changed, 1 insertion(+), 18 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/network/server/ProtocolsManager.java b/serverlogic/src/main/java/com/ljsd/jieling/network/server/ProtocolsManager.java index 22711f196..04427a6d0 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/network/server/ProtocolsManager.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/network/server/ProtocolsManager.java @@ -232,12 +232,8 @@ public class ProtocolsManager implements ProtocolsAbstract { if(indicationInRedis!=null){ Map map= gson.fromJson(indicationInRedis.toString(),type); for(Map.Entry info : map.entrySet()){ - Integer msgIndex = info.getKey(); session.writeAndFlush(info.getValue().getMsg()); - session.putBackIndicationToMap(msgIndex,info.getValue().getMsg()); - if(maxMsgId indexToIndication = session.getIndexToIndication(); - boolean send = false; for(ISession.IndicationMsg indicationMsg : indexToIndication.values()){ long create = indicationMsg.getCreate(); int retryTimes = indicationMsg.getRetryTimes()+1; if(now-create>retryTimes*300){ - if(session.getUid() == 20000739){ - Calendar calendar = Calendar.getInstance(); - int i = calendar.get(Calendar.MINUTE); - if(i%2==0 && !send){ - for(Integer id : indexToIndication.keySet()){ - LOGGER.info("indication id={}",id); - } - send = true; - } - - - } MessageUtil.retrySendIndication(session,indicationMsg.getMsg()); indicationMsg.setRetryTimes(retryTimes); }