diff --git a/device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/NettyStartedService.java b/device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/NettyStartedService.java index d19cb65296d3dce0ab7c66d5fe2821a621b47d17..9b885970bdcf91752f9b2ddd341969bf8da8426c 100644 --- a/device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/NettyStartedService.java +++ b/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("寮€濮媙etty鏈嶅姟...."); thread = new Thread(() -> { - controlServer.run(7788); + controlServer.run(61112); }); thread.setDaemon(true); thread.start(); diff --git a/device-manager/src/test/java/com/mortals/httpclient/UDPClientHandler.java b/device-manager/src/test/java/com/mortals/httpclient/UDPClientHandler.java index 8b5bf24edf597ebc6516a2505919c4eb98d68cf9..e1208d4d12923feb611e697ec51c9be70e3aea57 100644 --- a/device-manager/src/test/java/com/mortals/httpclient/UDPClientHandler.java +++ b/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 {