javaNIO实战8----＞ java NIO的非阻塞式IO网络编程UDP协议实战

1、前面说的SocketChannel、ServerSocketChannel都是针对TCP协议而来的实现，那么今天我们就实战一下UDP协议的NIO非阻塞式网络编程，在NIO中UDP的通道实现类是DatagramChannel。

2、实战案例

      1、客户端的实现：

    @Testpublic void nioNonBlockingClientUDP() throws IOException {//1、开启一个DatagramChannel 的客户端通道DatagramChannel datagramChannel = DatagramChannel.open();//2、配置客户端通道为非阻塞的datagramChannel.configureBlocking(false);//3、分配缓冲区，然后存储需要发送到服务端的数据。ByteBuffer buffer = ByteBuffer.allocate(1024);buffer.put("你好 我是客户端！".getBytes());buffer.flip();//4、使用客户端通道发送数据到服务端。datagramChannel.send(buffer, new InetSocketAddress("127.0.0.1",9898));buffer.clear();}

      2、服务端的实现：

    @Testpublic void nioNonBlockingServerUDP() throws IOException {//1、开启一个UDP的 DatagramChannel 服务端通道DatagramChannel datagramChannel = DatagramChannel.open();//2、配置服务端通道为非阻塞的datagramChannel.configureBlocking(false);//3、绑定服务端通道 端口为9898datagramChannel.bind(new InetSocketAddress(9898));//4、打开一个选择器Selector selector = Selector.open();//5、将服务端的 通道 注册到 选择器 上，注册的事件类型是READ类型。datagramChannel.register(selector, SelectionKey.OP_READ);//6、轮询选择器的选择数量，只要大于1 就表示有事件需要处理。while (selector.select() >= 1) {//7、获取到选择器上所有被选择的 选择键列表，循环处理每一个选择键。Set<SelectionKey> selectionKeys = selector.selectedKeys();Iterator<SelectionKey> iterator = selectionKeys.iterator();while (iterator.hasNext()) {SelectionKey selectionKey = iterator.next();if (selectionKey.isReadable()) {ByteBuffer buffer = ByteBuffer.allocate(1024);DatagramChannel currentDatagramChannel = (DatagramChannel) selectionKey.channel();currentDatagramChannel.receive(buffer);buffer.flip();System.out.println(new String(buffer.array(),0, buffer.limit()));buffer.clear();}//8、选择键处理完成后一定要当前循环的选择键。iterator.remove();}}}