admin/wisdomisite-java
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

bug修复

Browse Source
This commit is contained in:
guo 2024-01-11 18:42:31 +08:00
parent bfbf1b721a
commit 3d4f839c04
1 changed files with 22 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
src/main/java/com/zhgd/netty/udp/UDPServerApp.java
View File

@ -25,27 +25,27 @@ public class UDPServerApp {
@PostConstruct @PostConstruct
public void startUdpApp() { public void startUdpApp() {
if (port == null) { if (port == null) {
return; return;
} }
log.info("启动udp中……"); log.info("启动udp中……");
Bootstrap bootstrap = new Bootstrap(); Bootstrap bootstrap = new Bootstrap();
EventLoopGroup workGroup = new NioEventLoopGroup(); EventLoopGroup workGroup = new NioEventLoopGroup();
bootstrap.group(workGroup).channel(NioDatagramChannel.class) bootstrap.group(workGroup).channel(NioDatagramChannel.class)
.option(ChannelOption.SO_BROADCAST, true) .option(ChannelOption.SO_BROADCAST, true)
.handler(new ChannelInitializer<NioDatagramChannel>() { .handler(new ChannelInitializer<NioDatagramChannel>() {
@Override @Override
protected void initChannel(NioDatagramChannel ch) throws Exception { protected void initChannel(NioDatagramChannel ch) throws Exception {
ch.pipeline().addLast(udpServerHandler); ch.pipeline().addLast(udpServerHandler);
} }
}); });
try { try {
Channel channel = bootstrap.bind("127.0.0.1", port).sync().channel(); Channel channel = bootstrap.bind(port).sync().channel();
//channel.closeFuture().sync().await(); //channel.closeFuture().sync().await();
log.info("启动udp成功……"); log.info("启动udp成功，端口：{}", port);
} catch (Exception e) { } catch (Exception e) {
log.error("udp启动err:", e); log.error("udp启动err:", e);
} }
} }
} }