|
@@ -61,6 +61,8 @@ public class CIMServerHandle extends SimpleChannelInboundHandler<CIMRequestProto |
|
@@ -61,6 +61,8 @@ public class CIMServerHandle extends SimpleChannelInboundHandler<CIMRequestProto |
|
61
|
IdleStateEvent idleStateEvent = (IdleStateEvent) evt;
|
61
|
IdleStateEvent idleStateEvent = (IdleStateEvent) evt;
|
|
62
|
if (idleStateEvent.state() == IdleState.READER_IDLE) {
|
62
|
if (idleStateEvent.state() == IdleState.READER_IDLE) {
|
|
63
|
|
63
|
|
|
|
|
64
|
+ LOGGER.info("定时检测服务端是否存活");
|
|
|
|
65
|
+
|
|
64
|
HeartBeatHandler heartBeatHandler = SpringBeanFactory.getBean(ServerHeartBeatHandlerImpl.class) ;
|
66
|
HeartBeatHandler heartBeatHandler = SpringBeanFactory.getBean(ServerHeartBeatHandlerImpl.class) ;
|
|
65
|
heartBeatHandler.process(ctx) ;
|
67
|
heartBeatHandler.process(ctx) ;
|
|
66
|
}
|
68
|
}
|