| | |
| | | //Channel channel; |
| | | @Async("taskExecutor") |
| | | public void run(int port) { |
| | | // Thread thread = new Thread(new Runnable() { |
| | | // @Override |
| | | // public void run() { |
| | | //启动服务 |
| | | EventLoopGroup workerGroup = new NioEventLoopGroup(); |
| | | //优化使用的线程 |
| | |
| | | // 绑定端口,开始接收进来的连接 |
| | | ChannelFuture f = b.bind(port).sync(); |
| | | //获取channel通道 |
| | | //channel=f.channel(); |
| | | System.out.println("UDP Server 启动,端口:" + port); |
| | | // 等待服务器 socket 关闭 。 |
| | | // 这不会发生,可以优雅地关闭服务器。 |
| | |
| | | group.shutdownGracefully(); |
| | | workerGroup.shutdownGracefully(); |
| | | } |
| | | // } |
| | | // }); |
| | | // thread.start(); |
| | | } |
| | | |
| | | } |