修改消息组件

device-manager/src/main/java/com/mortals/xhx/daemon/netty/server/controlserver/handler/NettyUDPServerHandler.java

@@ -50,7 +50,13 @@ public class NettyUDPServerHandler extends SimpleChannelInboundHandler<DatagramP
         resp.setCode(YesNoEnum.YES.getValue());
         resp.setMsg("获取服务端地址成功！");
         resp.setData(URL);
-        ctx.writeAndFlush(new DatagramPacket(Unpooled.copiedBuffer(JSON.toJSONString(resp), CharsetUtil.UTF_8), msg.sender()));
+
+
+        InetSocketAddress remoteAddress = new InetSocketAddress("255.255.255.255", 7789);
+        DatagramPacket sendpacket =new DatagramPacket(Unpooled.copiedBuffer(JSON.toJSONString(resp), CharsetUtil.UTF_8),remoteAddress);
+
+        //ctx.writeAndFlush(new DatagramPacket(Unpooled.copiedBuffer(JSON.toJSONString(resp), CharsetUtil.UTF_8), msg.sender()));
+        ctx.writeAndFlush(sendpacket);
 
     }
 

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

@@ -34,7 +34,7 @@ public class UDPClientHandler extends SimpleChannelInboundHandler<DatagramPacket
                 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)));
+                            new InetSocketAddress("255.255.255.255", 61112)));
                     try {
                         TimeUnit.SECONDS.sleep(2);
                     } catch (InterruptedException e) {