消息修改
parent
597d1c38ba
commit
8785a037de
|
|
@ -3,8 +3,6 @@ package com.ljsd.jieling.handler;
|
|||
import com.ljsd.jieling.db.redis.RedisKey;
|
||||
import com.ljsd.jieling.db.redis.RedisUtil;
|
||||
import com.ljsd.jieling.handler.map.MapLogic;
|
||||
import com.ljsd.jieling.ktbeans.KTDataUtil;
|
||||
import com.ljsd.jieling.ktbeans.KTEnvironmentUtil;
|
||||
import com.ljsd.jieling.ktbeans.KTRequestBeans.LoginParamType;
|
||||
import com.ljsd.jieling.ktbeans.KtEventUtils;
|
||||
import com.ljsd.jieling.ktbeans.ReportUtil;
|
||||
|
|
@ -77,11 +75,11 @@ public class LoginRequestHandler extends BaseHandler<PlayerInfoProto.LoginReques
|
|||
}
|
||||
ParamDataBean paramDataBean = new ParamDataBean();
|
||||
paramDataBean.setChannel_s(loginRequest.getChannelS());
|
||||
KTDataUtil.addUserDataInfo(userId,paramDataBean);
|
||||
|
||||
// KTDataUtil.addUserDataInfo(userId,paramDataBean);
|
||||
// KTEnvironmentUtil.addUserEnviromentInfo(userId,paramEnvironmentBean);
|
||||
// KTEnvironmentUtil.addUserSimpleEnviromentInfo(userId,paramEnvironmentSimpleBean);
|
||||
// KTEnvironmentUtil.addUserEnviromentInfo(userId,paramEnvironmentBean);
|
||||
KTEnvironmentUtil.addUserSimpleEnviromentInfo(userId,paramEnvironmentSimpleBean);
|
||||
KTEnvironmentUtil.addUserEnviromentInfo(userId,paramEnvironmentBean);
|
||||
|
||||
int pid = 0;
|
||||
int gid = 0;
|
||||
|
|
|
|||
|
|
@ -2,11 +2,9 @@ package com.ljsd.jieling.network.session;
|
|||
|
||||
import com.ljsd.jieling.netty.NettyGameSession;
|
||||
import com.ljsd.jieling.netty.server.IChannel;
|
||||
import com.ljsd.jieling.netty.server.NettyChannel;
|
||||
import com.ljsd.jieling.protocol.INetWorkHandler;
|
||||
import util.TimeUtils;
|
||||
|
||||
import java.util.UUID;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
|
|
@ -123,6 +121,10 @@ public class ISession extends NettyGameSession {
|
|||
this.indexToIndication.remove(ackId);
|
||||
}
|
||||
|
||||
public void cleanIndication() {
|
||||
this.indexToIndication.clear();
|
||||
}
|
||||
|
||||
public byte[] getCacheMessage(int index) {
|
||||
return this.indexToMessage.get(index);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -51,16 +51,18 @@ public class RetrySendIndicationThread extends Thread{
|
|||
}
|
||||
ConcurrentHashMap<Integer, ISession.IndicationMsg> indexToIndication = session.getIndexToIndication();
|
||||
for(ISession.IndicationMsg indicationMsg : indexToIndication.values()){
|
||||
long create = indicationMsg.getCreate();
|
||||
int retryTimes = indicationMsg.getRetryTimes()+1;
|
||||
if(retryTimes>3){
|
||||
continue;
|
||||
}
|
||||
if(now-create > retryTimes*3000L){
|
||||
MessageUtil.retrySendIndication(session,indicationMsg.getMsg());
|
||||
indicationMsg.setRetryTimes(retryTimes);
|
||||
}
|
||||
// long create = indicationMsg.getCreate();
|
||||
// int retryTimes = indicationMsg.getRetryTimes()+1;
|
||||
// if(retryTimes>3){
|
||||
// continue;
|
||||
// }
|
||||
// if(now-create > retryTimes*3000L){
|
||||
// MessageUtil.retrySendIndication(session,indicationMsg.getMsg());
|
||||
// indicationMsg.setRetryTimes(retryTimes);
|
||||
// }
|
||||
MessageUtil.retrySendIndication(session,indicationMsg.getMsg());
|
||||
}
|
||||
session.cleanIndication();
|
||||
}else{
|
||||
removeIds.add(session.getUid());
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue