diff --git a/src/main/java/com/zhgd/netty/udp/UDPServerApp.java b/src/main/java/com/zhgd/netty/udp/UDPServerApp.java index 3df6d0d77..fa88a9c7b 100644 --- a/src/main/java/com/zhgd/netty/udp/UDPServerApp.java +++ b/src/main/java/com/zhgd/netty/udp/UDPServerApp.java @@ -25,27 +25,27 @@ public class UDPServerApp { @PostConstruct public void startUdpApp() { - if (port == null) { - return; - } - log.info("启动udp中……"); - Bootstrap bootstrap = new Bootstrap(); - EventLoopGroup workGroup = new NioEventLoopGroup(); - bootstrap.group(workGroup).channel(NioDatagramChannel.class) - .option(ChannelOption.SO_BROADCAST, true) - .handler(new ChannelInitializer() { + if (port == null) { + return; + } + log.info("启动udp中……"); + Bootstrap bootstrap = new Bootstrap(); + EventLoopGroup workGroup = new NioEventLoopGroup(); + bootstrap.group(workGroup).channel(NioDatagramChannel.class) + .option(ChannelOption.SO_BROADCAST, true) + .handler(new ChannelInitializer() { - @Override - protected void initChannel(NioDatagramChannel ch) throws Exception { - ch.pipeline().addLast(udpServerHandler); - } - }); - try { - Channel channel = bootstrap.bind("127.0.0.1", port).sync().channel(); - //channel.closeFuture().sync().await(); - log.info("启动udp成功……"); - } catch (Exception e) { - log.error("udp启动err:", e); - } - } + @Override + protected void initChannel(NioDatagramChannel ch) throws Exception { + ch.pipeline().addLast(udpServerHandler); + } + }); + try { + Channel channel = bootstrap.bind(port).sync().channel(); + //channel.closeFuture().sync().await(); + log.info("启动udp成功,端口:{}", port); + } catch (Exception e) { + log.error("udp启动err:", e); + } + } }