|
|
@@ -92,11 +92,11 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter { |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { |
|
|
|
//接收msg消息{与上一章节相比,此处已经不需要自己进行解码} |
|
|
|
//接收msg消息与上一章节相比,此处已经不需要自己进行解码} |
|
|
|
SocketChannel channel = (SocketChannel) ctx.channel(); |
|
|
|
String ipAddress = channel.remoteAddress().toString(); |
|
|
|
String message = " 接收到消息:{0}, 客户端IP:{1}"; |
|
|
|
log.info(message ,msg, ipAddress); |
|
|
|
//String message = " 接收到消息:{0}, 客户端IP:{1}"; |
|
|
|
log.info("接收到消息:" + msg + "客户端IP:" + ipAddress); |
|
|
|
|
|
|
|
String channelAns = ""; |
|
|
|
// 返回时间指令 |
|
|
@@ -134,7 +134,7 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter { |
|
|
|
buf = Unpooled.buffer(astEPHBytes.getBytes().length); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
log.info(buf.toString()); |
|
|
|
// 最后把SDBP-AST-TIME、SDBP-AST-POS、SDBP-AST-EPH并包一起发给设备。 |
|
|
|
// 设备采用16进制获取数据,则代理服务器也是采用16进制返回数据。 |
|
|
|
// 通知客户端链消息发送成功 |
|
|
|