修改消息组件

device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/NettyStartedService.java

@@ -29,7 +29,7 @@ public class NettyStartedService implements IApplicationStartedService {
     public void start() {
         logger.info("开始netty服务....");
          thread = new Thread(() -> {
-            controlServer.run(7788);
+            controlServer.run(61112);
         });
         thread.setDaemon(true);
         thread.start();

device-manager/src/test/java/com/mortals/httpclient/UDPClientHandler.java

@@ -28,12 +28,11 @@ public class UDPClientHandler extends SimpleChannelInboundHandler<DatagramPacket
     @Override
     public void channelActive(ChannelHandlerContext ctx) throws Exception {
         log.info("remoteAddress:{}", ctx.channel().remoteAddress());
-
-
         ctx.executor().parent().execute(new Runnable() {
             @Override
             public void run() {
                 for (int i = 0; i < 10; i++) {
+                    log.info("send msg:{}",i);
                     ctx.writeAndFlush(new DatagramPacket(Unpooled.copiedBuffer("我在广播" + i, Charset.forName("utf-8")),
                             new InetSocketAddress("255.255.255.255", 7788)));
                     try {