epoll，java

<link rel="stylesheet" href="https://js.how234.com/third-party/SyntaxHighlighter/shCoreDefault.css" type="text/css" /><script type="text/javascript" src="https://js.how234.com/third-party/SyntaxHighlighter/shCore.js"></script><script type="text/javascript"> SyntaxHighlighter.all(); </script>

java epoll是什麼，讓我們一起了解一下？

epoll是Linux內核為處理大批量文件描述符而作了改進的poll，是Linux下多路複用IO接口select或poll的增強版本，能顯著提高程序在大量併發連接中只有少量活躍的情況下的系統CPU利用率。

如何實現epoll的接口？

1、創建epoll句柄。

2、將被監聽的描述符添加到epoll句柄或從epool句柄中刪除或者對監聽事件進行修改。

3、等待事件觸發，當超過timeout還沒有事件觸發時，就超時。

在Java中epoll的優點有哪些？

1、支持一個進程打開大數目的socket描述符。

2、IO效率不隨FD數目增加而線性下降。

3、沒有使用mmap加速內核與用户空間的消息傳遞。

如何使用多路複用的服務端程序，來演示JavaAPI中提供的方法與底層epoll函數實現的具體關係？

首先程序運行後服務端啟動並綁定9090端口，等待客户端連接，讀取到客户端消息後再直接把消息後回覆給客户端。

示例代碼如下：

import java.io.IOException;import java.net.InetSocketAddress;import java.nio.ByteBuffer;import java.nio.channels.*;import java.util.Iterator;import java.util.Set;public class SocketMultiplexIO {    private static Selector selector;    public static void main(String[] args) throws Exception {        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();        serverSocketChannel.bind(new InetSocketAddress(9090));        serverSocketChannel.configureBlocking(false);        selector = Selector.open();        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);        System.out.println("服務端啟動了。。。");        while (true) {            Set<SelectionKey> keys = selector.keys();            System.out.println("當前epoll註冊的事件：" + keys.size());            while (selector.select() > 0) {                Set<SelectionKey> selectionKeys = selector.selectedKeys();                Iterator<SelectionKey> iterator = selectionKeys.iterator();                while (iterator.hasNext()) {                    SelectionKey selectionKey = iterator.next();                    iterator.remove();                    if (selectionKey.isAcceptable()) {                        System.out.println("有一個客户端連接了。。。");                        acceptHandler(selectionKey);                    } else if (selectionKey.isReadable()) {                        selectionKey.cancel();                        System.out.println("cancel函數，取消了accept事件");                        readHandler(selectionKey);                    }                }            }        }    }    private static void readHandler(SelectionKey key) {        SocketChannel client = (SocketChannel) key.channel();        ByteBuffer buffer = (ByteBuffer) key.attachment();        buffer.clear();        int read;        try {            while (true) {                read = client.read(buffer);                if (read > 0) {                    buffer.flip();                    while (buffer.hasRemaining()) {                        client.write(buffer);                    }                    buffer.clear();                } else if (read == 0) {                    break;                } else {                    client.close();                    break;                }            }        } catch (IOException e) {            e.printStackTrace();        }    }    private static void acceptHandler(SelectionKey selectionKey) throws IOException {        ServerSocketChannel serverSocketChannel = (ServerSocketChannel) selectionKey.channel();        SocketChannel accept = serverSocketChannel.accept();        accept.configureBlocking(false);        ByteBuffer byteBuffer = ByteBuffer.allocateDirect(1024);        accept.register(selector, SelectionKey.OP_READ, byteBuffer);    }}