| | |
| | | |
| | | @Override |
| | | public void channelRead0(ChannelHandlerContext ctx, BaseCommand command) { |
| | | //InetSocketAddress ipSocket = (InetSocketAddress) ctx.channel().remoteAddress(); |
| | | //String host = ipSocket.getHostString(); |
| | | //int port = ipSocket.getPort(); |
| | | //tyService.processMessage(host + "/" + port, msg); |
| | | InetSocketAddress ipSocket = (InetSocketAddress) ctx.channel().remoteAddress(); |
| | | String host = ipSocket.getHostString(); |
| | | int port = ipSocket.getPort(); |
| | | tyService.processMessage(host + ":" + port, command); |
| | | } |
| | | |
| | | @Override |