1 代码
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;
/**
* NIO服务端
*/
public class NIOServer {
// 通道管理器，相当于超级服务生，把门口迎接客人，服务个人的活都做了
private Selector selector;
/**
* 获得一个ServerSocket通道，并对该通道做一些初始化的工作
*
* @param port 绑定的端口号
*/
public void initServer(int port) throws IOException {
// 获得一个ServerSocket通道
ServerSocketChannel serverChannel = ServerSocketChannel.open();
// 设置通道为非阻塞
serverChannel.configureBlocking(false);
// 将该通道对应的ServerSocket绑定到port端口
serverChannel.socket().bind(new InetSocketAddress(port));
// 获得一个通道管理器
this.selector = Selector.open();
// 将通道管理器和该通道绑定，并为该通道注册SelectionKey.OP_ACCEPT事件。
// 注册该事件后，当该事件到达时selector.select()会返回。若该事件没到达selector.select()会一直阻塞。
serverChannel.register(selector, SelectionKey.OP_ACCEPT);
}
/**
* 采用轮询的方式监听selector上是否有需要处理的事件，如果有，则进行处理
*/
public void listen() throws IOException {
System.out.println("服务端启动成功！");
// 轮询访问selector
while (true) {
// 当注册的事件到达时，方法返回。否则,该方法会一直阻塞
// C语言实现
selector.select();
// 获得selector中选中的项的迭代器，选中的项为注册的事件
Iterator<?> ite = this.selector.selectedKeys().iterator();
while (ite.hasNext()) {
SelectionKey key = (SelectionKey) ite.next();
// 删除已选的key,以防重复处理
ite.remove();
handler(key);
}
}
}
/**
* 处理请求
*/
public void handler(SelectionKey key) throws IOException {
if (key.isAcceptable()) {
// 客户端请求连接事件
handlerAccept(key);
} else if (key.isReadable()) {
// 获得了可读的事件
handelerRead(key);
}
}
/**
* 处理连接请求
*/
public void handlerAccept(SelectionKey key) throws IOException {
ServerSocketChannel server = (ServerSocketChannel) key.channel();
// 获得和客户端连接的通道
SocketChannel channel = server.accept();
// 设置成非阻塞
channel.configureBlocking(false);
// 在这里可以给客户端发送信息哦
System.out.println("新的客户端连接");
// 在和客户端连接成功之后，为了可以接收到客户端的信息，需要给通道注册读的事件
channel.register(this.selector, SelectionKey.OP_READ);
}
/**
* 处理读的事件
*/
public void handelerRead(SelectionKey key) throws IOException {
// 服务器可读取消息:得到事件发生的Socket通道
SocketChannel channel = (SocketChannel) key.channel();
// 创建读取的缓冲区
ByteBuffer buffer = ByteBuffer.allocate(1024);
int read = channel.read(buffer);
if (read > 0) {
byte[] data = buffer.array();
String msg = new String(data).trim();
System.out.println("服务端收到信息：" + msg);
// 回写数据， 将消息回送给客户端
ByteBuffer outBuffer = ByteBuffer.wrap("好的".getBytes());
channel.write(outBuffer);
} else {
System.out.println("客户端关闭");
key.cancel();
}
}
/**
* 启动服务端测试
*/
public static void main(String[] args) throws IOException {
NIOServer server = new NIOServer();
server.initServer(8000);
server.listen();
}
}
2 对应关系
ServerSocketChannel-ServerSocket SocketChannel-Socket Selector和SelectionKey无对应
3 代码分析
通道管理器Selector，相当于超级服务生，把门口迎接客人，服务客户的活一个人全都做了。理论上一个selector可以对应N个客户端。即监听注册事件，又处理业务。
4 一些疑问
A、selector.select()也是阻塞的，为什么说NIO是非阻塞的selector.select() 阻塞selector.select(1000) 设置阻塞时间selector.wakeup() 唤醒selector。某个线程调用select()方法后阻塞了，即使没有通道已经就绪，也有办法让其从select()方法返回。只要让其它线程在第一个线程调用select()方法的那个对象上调用selector.wakeup()方法即可。阻塞在select()方法上的线程会立马返回。若有其它线程调用了wakeup()方法，但当前没有线程阻塞在select()方法上，下个调用select()方法的线程会立即醒来（wake up）。
B、SelectionKey.OP_WRITE表示什么意思
表示底层缓冲区是否有空间，是则响应返回true。
