上饶警务-警车数据读取服务(udp)
zhongrj
2025-01-16 3a1d32e5e512f68ab5a613ae19997bbbcbbe0f98
src/main/java/org/springblade/modules/netty/server/UdpServer.java
@@ -31,6 +31,9 @@
    //Channel channel;
    @Async("taskExecutor")
    public void run(int port) {
//      Thread thread = new Thread(new Runnable() {
//         @Override
//         public void run() {
        //启动服务
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        //优化使用的线程
@@ -70,6 +73,7 @@
            // 绑定端口,开始接收进来的连接
            ChannelFuture f = b.bind(port).sync();
            //获取channel通道
            //channel=f.channel();
            System.out.println("UDP Server 启动,端口:" + port);
            // 等待服务器 socket 关闭 。
            // 这不会发生,可以优雅地关闭服务器。
@@ -81,6 +85,9 @@
            group.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
//         }
//         });
//      thread.start();
    }
}