|
@@ -48,20 +48,19 @@ public class CenterClientHandler extends SimpleChannelInboundHandler<NettyMessag
|
|
|
@Override
|
|
|
public void channelActive(ChannelHandlerContext ctx) throws Exception {
|
|
|
log.info("Connected to: {}", ctx.channel().remoteAddress());
|
|
|
-
|
|
|
-
|
|
|
+
|
|
|
nettyClient.sendMessage(new NettyMessage(200));
|
|
|
-
|
|
|
-
|
|
|
+
|
|
|
+
|
|
|
+ iniAlarmResult(ctx);
|
|
|
+
|
|
|
+
|
|
|
NettyMessage nettyMessage = new NettyMessage(4);
|
|
|
JSONObject content = new JSONObject();
|
|
|
content.put("groupCode", CommonConst.groupCode);
|
|
|
content.put("projectId", CommonConst.projectId);
|
|
|
nettyMessage.setContent(Arrays.asList(content));
|
|
|
nettyClient.sendMessage(nettyMessage);
|
|
|
-
|
|
|
-
|
|
|
- iniAlarmResult(ctx);
|
|
|
}
|
|
|
|
|
|
private void iniAlarmResult(ChannelHandlerContext ctx) {
|
|
@@ -84,14 +83,14 @@ public class CenterClientHandler extends SimpleChannelInboundHandler<NettyMessag
|
|
|
try {
|
|
|
TimeInterval timer = DateUtil.timer();
|
|
|
handlerMsg(ctx, msg);
|
|
|
- log.info("处理消息时间[{}]", timer.interval());
|
|
|
+ log.info("处理消息时间[{} ms]", timer.interval());
|
|
|
} catch (Exception e) {
|
|
|
log.error("channelRead", e);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
private void handlerMsg(ChannelHandlerContext channelHandlerContext, NettyMessage msg) throws Exception {
|
|
|
- if (msg.getOpCode() == 7) {
|
|
|
+ if (msg.getOpCode() == 7) {
|
|
|
log.info("--报警定义新增或更新--{}",msg);
|
|
|
NettyMessage<AlarmDefine> AlarmDefineMessage = JSONObject.parseObject(msg.toString(), new TypeReference<NettyMessage<AlarmDefine>>() {
|
|
|
});
|