|
|
@@ -105,15 +105,13 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter { |
|
|
|
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { |
|
|
|
//接收msg消息与上一章节相比,此处已经不需要自己进行解码} |
|
|
|
SocketChannel channel = (SocketChannel) ctx.channel(); |
|
|
|
String ipAddress = channel.remoteAddress().getHostString().toString(); |
|
|
|
//String message = " 接收到消息:{0}, 客户端IP:{1}"; |
|
|
|
String ipAddress = channel.remoteAddress().getHostString(); |
|
|
|
log.info("接收到消息:" + msg + ",客户端IP:" + ipAddress); |
|
|
|
// if (nettyServerHandler.positionConfig != null) { |
|
|
|
// log.info("config info is : " + nettyServerHandler.positionConfig.getCenterProvinceFilePath() + nettyServerHandler.positionConfig.getCenterProvince() + nettyServerHandler.positionConfig.getIpPositionRequestPath() + |
|
|
|
// nettyServerHandler.positionConfig.getIpPositionRequestKey()); |
|
|
|
// } else { |
|
|
|
// log.info("positionConfig info is null!!!!!!!!!!!!!! "); |
|
|
|
// } |
|
|
|
if(ipAddress.contains(":")) { |
|
|
|
String[] ipAddressArr = ipAddress.split(":"); |
|
|
|
ipAddress = ipAddressArr[0].replace("/",""); |
|
|
|
} |
|
|
|
log.info("新客户端IP:" + ipAddress); |
|
|
|
|
|
|
|
String channelAns = ""; |
|
|
|
// 返回时间指令 |
|
|
|