master_zzxx
grimm 2024-05-31 17:05:01 +08:00
parent 559a40e9f1
commit b2daffb239
2 changed files with 15 additions and 13 deletions

View File

@ -1,6 +1,7 @@
{ {
"version":"6", "version":"7",
"classes": [ "classes": [
{"name":"BuyGoodsNewLogic.class","fullName":"com.ljsd.jieling.logic.store.BuyGoodsNewLogic"} {"name":"BuyGoodsNewLogic.class","fullName":"com.ljsd.jieling.logic.store.BuyGoodsNewLogic"},
{"name":"RetrySendIndicationThread.class","fullName":"com.ljsd.jieling.thread.task.RetrySendIndicationThread"}
] ]
} }

View File

@ -51,18 +51,19 @@ public class RetrySendIndicationThread extends Thread{
} }
ConcurrentHashMap<Integer, ISession.IndicationMsg> indexToIndication = session.getIndexToIndication(); ConcurrentHashMap<Integer, ISession.IndicationMsg> indexToIndication = session.getIndexToIndication();
for(ISession.IndicationMsg indicationMsg : indexToIndication.values()){ for(ISession.IndicationMsg indicationMsg : indexToIndication.values()){
// long create = indicationMsg.getCreate(); long create = indicationMsg.getCreate();
// int retryTimes = indicationMsg.getRetryTimes()+1; int retryTimes = indicationMsg.getRetryTimes()+1;
// if(retryTimes>3){ if(retryTimes>3){
// continue; continue;
// }
// if(now-create > retryTimes*3000L){
// MessageUtil.retrySendIndication(session,indicationMsg.getMsg());
// indicationMsg.setRetryTimes(retryTimes);
// }
MessageUtil.retrySendIndication(session,indicationMsg.getMsg());
} }
session.cleanIndication(); if(now-create > retryTimes*3000L){
MessageUtil.retrySendIndication(session,indicationMsg.getMsg());
indicationMsg.setRetryTimes(retryTimes);
}
// LOGGER.info("indication :{}",indicationMsg.getMsg());
// MessageUtil.retrySendIndication(session,indicationMsg.getMsg());
}
// session.cleanIndication();
}else{ }else{
removeIds.add(session.getUid()); removeIds.add(session.getUid());
} }