[update] netty返回消息端口

Jenkinsfile

@@ -90,7 +90,7 @@ pipeline {
                 sh 'docker run -p 32000:32000 -p 15115:15115 -itd --name signal-utc-service 10.102.1.182:5000/xinkong/signal-utc-service:0.2.1'
                 sh 'docker run -p 32001:32001 -p 15116:15116 -itd --name signal-control-service 10.102.1.182:5000/xinkong/signal-control-service:0.2.1'
                 sh 'docker run -p 39001:39001 -p 15117:15117 -itd --name signal-optimize-service 10.102.1.182:5000/xinkong/signal-optimize-service:0.2.1'
-                sh 'docker run -p 39002:39002 -p 15118:15118 -p 5050:5050 -itd --name signal-utc-dt-service 10.102.1.182:5000/xinkong/signal-utc-dt-service:0.2.1'
+                sh 'docker run -p 39002:39002 -p 15118:15118 -p 5050:5050 -p 5051:5051 -itd --name signal-utc-dt-service 10.102.1.182:5000/xinkong/signal-utc-dt-service:0.2.1'
             }
         }
     }

signal-utc-dt-service/src/main/java/net/wanji/com/netty/handler/NettyServerHandler.java

@@ -5,7 +5,6 @@ import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 import io.netty.channel.socket.DatagramPacket;
-import lombok.NoArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import net.wanji.com.cache.CrossInfoCache;
 import net.wanji.com.cache.netty.NettyMessageCache;
@@ -24,12 +23,10 @@ import java.net.InetSocketAddress;
 import java.util.Objects;
 
 @Slf4j
-@NoArgsConstructor
 public class NettyServerHandler extends SimpleChannelInboundHandler<DatagramPacket> {
 
     @Resource
     private CrossInfoCache crossInfoCache;
-
     private ThreadPoolTaskExecutor threadPoolExecutor;
 
     public NettyServerHandler(ThreadPoolTaskExecutor threadPoolExecutor) {
@@ -45,6 +42,7 @@ public class NettyServerHandler extends SimpleChannelInboundHandler<DatagramPack
      */
     @Override
     public void channelRead0(ChannelHandlerContext ctx, DatagramPacket packet) throws Exception {
+        log.info("收到服务端包数据： {}", packet);
         ByteBuf content = packet.content();
         InetSocketAddress sender = packet.sender();
         log.info("收到消息地址： {}, 端口： {}", sender.getAddress(), sender.getPort());
@@ -83,19 +81,6 @@ public class NettyServerHandler extends SimpleChannelInboundHandler<DatagramPack
         }
     }
 
-    /**
-     * 关闭
-     *
-     * @param ctx
-     * @throws Exception
-     */
-    @Override
-    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
-        String s = ctx.channel().remoteAddress().toString();
-        log.error("{} connection break", s);
-        ctx.fireChannelInactive();
-    }
-
     private CommandPojo getCommandPojo(String key, String data) {
         CrossInfoPO crossInfo = crossInfoCache.getCrossInfo(key);
         CommandPojo commandPojo = new CommandPojo();