| | |
|---|
| | | import java.util.concurrent.Executors; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * Created by wangshikai on 2016/7/18. |
|---|
| | | * updServer udp服务端 |
|---|
| | | */ |
|---|
| | | public class UdpServer { |
|---|
| | | private static Logger LOG = LoggerFactory.getLogger(UdpServer.class); |
|---|
| | |
|---|
| | | //使用ChannelPipeline实现自定义IO |
|---|
| | | //Channel channel; |
|---|
| | | public void run() { |
|---|
| | | Thread thread = new Thread(new Runnable() { |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | | //InetSocketAddress socketAddress = new InetSocketAddress("s16s652780.51mypc.cn", 21403); |
|---|
| | | //启动服务 |
|---|
| | | EventLoopGroup workerGroup = new NioEventLoopGroup(); |
|---|
| | |
|---|
| | | ChannelFuture f = b.bind(port).sync(); |
|---|
| | | //获取channel通道 |
|---|
| | | //channel=f.channel(); |
|---|
| | | System.out.println("UDP Server 启动！"); |
|---|
| | | System.out.println("UDP Server 启动,端口:"+port); |
|---|
| | | // 等待服务器 socket 关闭 。 |
|---|
| | | // 这不会发生，可以优雅地关闭服务器。 |
|---|
| | | f.channel().closeFuture().sync(); |
|---|
| | |
|---|
| | | workerGroup.shutdownGracefully(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | thread.start(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
