完善偏移最新的获取消息位置,提升性能。
This commit is contained in:
@@ -4,6 +4,7 @@ import java.util.List;
|
|||||||
|
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
import org.springframework.util.CollectionUtils;
|
||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
|
import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
|
||||||
import com.gzzn.omms.msgexchangeapi.msghandler.MsgHandlerDispatcher;
|
import com.gzzn.omms.msgexchangeapi.msghandler.MsgHandlerDispatcher;
|
||||||
@@ -58,7 +59,11 @@ public class MsgExchangeRunner implements Runnable{
|
|||||||
msgHandlerDispatcher.dispatch(cminmsg);
|
msgHandlerDispatcher.dispatch(cminmsg);
|
||||||
}//end for
|
}//end for
|
||||||
|
|
||||||
|
if(!CollectionUtils.isEmpty(lsCminmsgs))
|
||||||
|
{
|
||||||
|
beginId = lsCminmsgs.get(lsCminmsgs.size()-1).getCminmsgsId();//偏移到最新位置,等待最新的消息
|
||||||
|
redisService.set(RedisKeyConstant.KEY_LASTBEGINID,beginId);
|
||||||
|
}
|
||||||
logger.info("本次定时获取新消息完成...");
|
logger.info("本次定时获取新消息完成...");
|
||||||
}//end run
|
}//end run
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user