JavaSE：NIO编程实例

客户端

public static void main(String[] args) throws IOException {



　　// 创建客户端

　　SocketChannel sc = SocketChannel.open();



　　// 指定要连接的服务器ip和端口

　　sc.connect(new InetSocketAddress("127.0.0.1", 9000) );



　　// 创建缓冲输出

　   ByteBuffer buffer = ByteBuffer.allocate(1024);



　　// 给数组添加数据

　　buffer.put ("Hi你好啊".getBytes());



　　// 切换

　　buffer.flip();



　　// 输出数据

　　sc.write(buffer);



　　// 关闭资源

　　sc.close();

}

Demo服务端

import java.io.IOException;

import java.net.InetSocketAddress;

import java.nio.channels.SelectionKey;

import java.nio.channels.Selector;

import java.nio.channels.ServerSocketChannel;

import java.util.Set;



public class Demo服务端 {

　　main() throws IOException {

　　　　// 创建服务端对象

　　　　ServerSocketChannel ssc1 = ServerSocketChannel.open();

　　　　ssc1.bind(new InetSocketAddress(8000));



　　　　// 设置非阻塞
　　　　ssc1.configureBlocking(false);
　　　　
　　　　// 创建服务器端对象
　　　　ServerSocketChannel ssc2 = ServerSocketChannel.open();
　　　　ssc2.bind(new InetSocketAddress(9000));
　　　　ssc2.configureBlocking(false);



　　　　// 创建服务器端对象 
　　　　ServerSocketChannel ssc3 = ServerSocketChannel.open();
　　　　ssc3.bind(new InetSocketAddress(10001));
　　　　ssc3.configureBlocking(false);



　　　　// 创建选择器对象

　　　　Selector s = Selector.open();



　　　　// 两个服务器，都要交给选择器来管理

　　　　ssc1.register(s, SelectionKey.OP_ACCEPT);

　　　　ssc2.register(s, SelectionKey.OP_ACCEPT);

　　　　ssc3.register(s, SelectionKey.OP_ACCEPT);



　　　　// 获取集合
　　　　// selectedKeys()： 返回集合，集合作用存放的是被连接的服务对象的key
　　　　Set<SelectionKey> set = s.selectedKeys();
　　　　print("集合中元素的个数：" + set.size() );　　// 0 (没有服务器被访问的时候，显示0)
　　　　
　　　　// select()： 这是选择器连接客户端的方法
　　　　s.select();


　　　　print("集合中元素的个数：" + set.size() );　　// 1 (有一个服务端被访问的时候，显示1)
 
　　}

}

Selector服务端

import java.io.IOException;

import java.net.InetSocketAddress;

import java.nio.ByteBuffer;

import java.nio.channels.SelectionKey;

import java.nio.channels.Selector;

import java.nio.channels.ServerSocketChannel;

import java.nio.channels.SocketChannel;

import java.util.Iterator;



public class Selector服务端 {

　　main() throws IOException {

　　　　//　　1. 获取Selector选择器

　　　　Selector selector = Selector.open();



　　　　//　　2. 获取通道

　　　　ServerSocketChannel ssc1 = ServerSocketChannel.open();

　　　　ServerSocketChannel ssc2 = ServerSocketChannel.open();

　　　　ServerSocketChannel ssc3 = ServerSocketChannel.open();



　　　　//　　3. 设置为非阻塞

　　　　ssc1.configureBlocking(false);

　　　　ssc2.configureBlocking(false);

　　　　ssc3.configureBlocking(false);



　　　　//　　4.绑定连接

　　　　ssc1.bind (new InetSocketAddress(8000));

　　　　ssc2.bind (new InetSocketAddress(9000));

　　　　ssc3.bind (new InetSocketAddress(10000));



　　　　//　　5.将通道注册到选择器上，并注册的操作为："接收"操作
　　　　ssc1.register(selector, SelectionKey.OP_ACCEPT);
　　　　ssc2.register(selector, SelectionKey.OP_ACCEPT);
　　　　ssc3.register(selector, SelectionKey.OP_ACCEPT);


　　　　//　　6.采用轮询的方式，查询获取"准备就绪"的注册过的操作
　　　　while (selector.select() > 0 ) {

　　　　　　//　　7. 获取当前选择器中，所有的选择键 （“已经准备就绪的操作”）
　　　　　　Iterator<SelectionKey> selectedKeys = selector.selectedKeys().iterator();
　　　　　　while (selectedKeys.hasNext() ){



　　　　　　　　//　　8.　　获取"准备就绪"的事件
　　　　　　　　SelectionKey selectedKey = selectedKeys.next();


　　　　　　　　//　　9.　　获取ServerSocketChannel
　　　　　　　　ServerSocketChannel serverSocketChannel = (ServerSocketChannel) selectedKey.channel();


　　　　　　　　//　　10.　　接收客户端发来的数据
　　　　　　　　SocketChannel socketChannel = serverSocketChannel.accept();


　　　　　　　　//　　11.　　读取数据
　　　　　　　　ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
　　　　　　　　int length = 0;
　　　　　　　　while ( (length = socketChannel.read(byteBuffer)) != -1 ){

　　　　　　　　　　byteBuffer.flip();
　　　　　　　　　　print (new String(byteBuffer.array(),0,length) );
　　　　　　　　　　byteBuffer.clear();
　　　　　　　　}
　　　　　　　　socketChannel.close();

　　　　　　}
　　　　　　//　　12.　　移除选择键
　　　　　　selectedKeys.remove();
　　　　}
　　　　//　　13.　　关闭连接
　　　　ssc1.close();
　　　　ssc2.close();
　　　　ssc3.close();
　　}

}

图解注释

<1>

<2>

 

 <3>