linux网络配置命令 linux网络配置的详细过程( 三 ) _云知道

2.3.1 I/O 多路复用- ｓｅｌｅｃｔ

简介：有连接请求抵达了再检查处理。
缺点：

句柄上限- 默认打开的FD有限制,1024个。
重复初始化-每次调用ｓｅｌｅｃｔ()，需要把 fd 集合从用户态拷贝到内核态，内核进行遍历。
逐个排查所有FD状态效率不高。

服务端的ｓｅｌｅｃｔ就像一块布满插口的插排，client端的连接连上其中一个插口，建立了一个通道，然后再在通道依次注册读写事件。一个就绪、读或写事件处理时一定记得删除，要不下次还能处理。

public static void main(String[] args) throws IOException {ServerSocketChannel ssc = ServerSocketChannel.open();//管道型ServerSocketssc.socket().bind(new InetSocketAddress(Constant.HOST, Constant.PORT));ssc.configureBlocking(false);//设置非阻塞System.out.println(" NIO single server started, listening on :" + ssc.getLocalAddress());Selector selector = Selector.open();ssc.register(selector, SelectionKey.OP_ACCEPT);//在建立好的管道上，注册关心的事件 就绪while(true) {selector.ｓｅｌｅｃｔ();Set<SelectionKey> keys = selector.selectedKeys();Iterator<SelectionKey> it = keys.iterator();while(it.hasNext()) {SelectionKey key = it.next();it.remove();//处理的事件，必须删除handle(key);}}}private static void handle(SelectionKey key) throws IOException {if(key.isAcceptable()) {ServerSocketChannel ssc = (ServerSocketChannel) key.channel();SocketChannel sc = ssc.accept();sc.configureBlocking(false);//设置非阻塞sc.register(key.selector(), SelectionKey.OP_READ );//在建立好的管道上，注册关心的事件 可读} else if (key.isReadable()) { //flipSocketChannel sc = null;sc = (SocketChannel)key.channel();ByteBuffer buffer = ByteBuffer.allocate(512);buffer.clear();int len = sc.read(buffer);if(len != -1) {System.out.println("[" +Thread.currentThread().getName()+"] recv :"+ new String(buffer.array(), 0, len));}ByteBuffer bufferToWrite = ByteBuffer.wrap("HelloClient".getBytes());sc.write(bufferToWrite);}}

2.3.2 I/O 多路复用 – poll

简介：设计新的数据结构(链表)提供使用效率。
poll和ｓｅｌｅｃｔ相比在本质上变化不大，只是poll没有了ｓｅｌｅｃｔ方式的最大文件描述符数量的限制。
缺点：逐个排查所有FD状态效率不高。
2.3.3 I/O 多路复用- epoll简介：没有fd个数限制，用户态拷贝到内核态只需要一次，使用事件通知机制来触发。通过epoll_ctl注册fd，一旦fd就绪就会通过callback回调机制来激活对应fd，进行相关的I/O操作。
缺点：

跨平台，Linux 支持最好。
底层实现复杂。
同步。

 public static void main(String[] args) throws Exception {final AsynchronousServerSocketChannel serverChannel = AsynchronousServerSocketChannel.open().bind(new InetSocketAddress(Constant.HOST, Constant.PORT));serverChannel.accept(null, new CompletionHandler<AsynchronousSocketChannel, Object>() {@Overridepublic void completed(final AsynchronousSocketChannel client, Object attachment) {serverChannel.accept(null, this);ByteBuffer buffer = ByteBuffer.allocate(1024);client.read(buffer, buffer, new CompletionHandler<Integer, ByteBuffer>() {@Overridepublic void completed(Integer result, ByteBuffer attachment) {attachment.flip();client.write(ByteBuffer.wrap("HelloClient".getBytes()));//业务逻辑}@Overridepublic void failed(Throwable exc, ByteBuffer attachment) {System.out.println(exc.getMessage());//失败处理}});}@Overridepublic void failed(Throwable exc, Object attachment) {exc.printStackTrace();//失败处理}});while (true) {//不while true main方法一瞬间结束}}

当然上面的缺点相比较它优点都可以忽略。JDK提供了异步方式实现，但在实际的Linux环境中底层还是epoll，只不过多了一层循环，不算真正的异步非阻塞。而且就像上图中代码调用，处理网络连接的代码和业务代码解耦得不够好。Netty提供了简洁、解耦、结构清晰的API 。