|
|
@@ -36,10 +36,13 @@ public class ServerHandler extends ChannelInboundHandlerAdapter {
|
|
|
/**
|
|
|
* 往客户端发送消息
|
|
|
*/
|
|
|
- String helo = "QN=20160801085857223;ST=32;CN=2031;PW=123456;MN=010000A8900016F000169DC0;Flag=5;CP=&&BeginTime=20160801000000;EndTime=20160801000000&&";
|
|
|
+ String helo = "QN=20250530085857223;ST=32;CN=2031;PW=123456;MN=0152316A279055;Flag=5;CP=&&BeginTime=20250529000000;EndTime=20250530000000&&";
|
|
|
ByteBuf byteBuf = Unpooled.wrappedBuffer(helo.getBytes());
|
|
|
ctx.channel().writeAndFlush(byteBuf);
|
|
|
System.out.println("首次连接完成!"+byteBuf);
|
|
|
+ String helo2 = "QN=20250530085857223;ST=32;CN=2031;PW=123456;MN=1234567901234;Flag=5;CP=&&BeginTime=20250529000000;EndTime=20250530000000&&";
|
|
|
+ ByteBuf byteBuf3 = Unpooled.wrappedBuffer(helo2.getBytes());
|
|
|
+ ctx.channel().writeAndFlush(byteBuf3);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
@@ -83,7 +86,7 @@ public class ServerHandler extends ChannelInboundHandlerAdapter {
|
|
|
log.info("==========数据已接收,接收时间:==========" + LocalDateTime.now());
|
|
|
String pushMonitorDataStr = serverHandler.monitorDatasynch.pushMonitorData(channelHandlerContext,msg);
|
|
|
} catch (Exception e) {
|
|
|
- log.info("==========数据入库失败==========");
|
|
|
+ log.info("==========数据错误==========");
|
|
|
e.printStackTrace();
|
|
|
} finally {
|
|
|
channelHandlerContext.flush();
|