从jdk的nio到epoll源码与实现内幕全面解析

近来笔者在研究java的nio部分代码时，看到在java的nio中关于事件类型的设计有四个分别是：

• OP_ACCEPT
  
• OP_READ
  
• OP_WRITE
  
• OP_CONNECT
  

然而nio的底层在Linux的实现是epoll，在epoll的模型中事件类型相对比较多分别是:

• POLLIN
  
• POLLOUT
  
• POLLERR
  
• POLLHUP
  
• POLLNVAL
  
• POLLREMOVE
  

当时笔者就有一个疑惑，为什么在epoll中没有关于OP_ACCEPT相关的事件，那么OP_ACCEPT在epoll中又意味着什么
怀着这样的疑问，笔者开始对源码进行解析，想一探究竟，本篇博客，我们就一起学习下关于java的nio到epoll详细实现的源码。
我们先从java服务端nio代码，一样平常在java中利用nio编程时都会利用这样的代码：
//当我们在java中利用nio编程时,一样平常会利用这几行代码在服务端开启一个selector和channel对特定端口进行监听//笔者省略了一些关于selectionKey的循环处置惩罚逻辑Selector selector = Selector.open();ServerSocketChannel serverChannel = ServerSocketChannel.open();serverChannel.bind(new InetSocketAddress(bindIp, port), 1024);serverChannel.register(selector, SelectionKey.OP_ACCEPT);selector.select(1000L)Set keys = selector.selectedKeys()复制1.selector.open()：

我们来一行一行分析，先看selector.open()，这一行会创建一个selector，我们一起看下selector的本质是什么：
//这个方法是开启一个Selectorpublic static Selector open() throws IOException {        return SelectorProvider.provider().openSelector();}public static SelectorProvider provider() {        synchronized (lock) {                if (provider != null)                        return provider;                return AccessController.doPrivileged(                        new PrivilegedAction() {                                public SelectorProvider run() {                                                if (loadProviderFromProperty())                                                        return provider;                                                if (loadProviderAsService())                                                        return provider;                        //默认情况下利用DefaultSelectorProvider                                                provider = sun.nio.ch.DefaultSelectorProvider.create();                                                return provider;                                        }                                });        }}//linux情况下DefaultSelectorProvider的create方法public static SelectorProvider create() {      String osname = AccessController                .doPrivileged(new GetPropertyAction("os.name"));      if (osname.equals("SunOS"))                return createProvider("sun.nio.ch.DevPollSelectorProvider");      //可以看出在linux情况下利用的是EPollSelectorProvider      if (osname.equals("Linux"))                return createProvider("sun.nio.ch.EPollSelectorProvider");      return new sun.nio.ch.PollSelectorProvider();}//EPollSelectorProvider的openSelector()方法public AbstractSelector openSelector() throws IOException {        return new EPollSelectorImpl(this);}复制EPollSelectorImpl从名字可以看出，nio的在Linux系统上的实现果然是epoll，我们看下EPollSelectorImpl类的构造方法：
EPollSelectorImpl(SelectorProvider sp) throws IOException {        super(sp);    //创建一个pipe通道,返回fd文件句柄,用于实现超机遇制        long pipeFds = IOUtil.makePipe(false);    //分别保存输入和输出的句柄        fd0 = (int) (pipeFds >>> 32);        fd1 = (int) pipeFds;    //创建epoll包装类        pollWrapper = new EPollArrayWrapper();    //这里是初始化中断,后面用于实现超机遇制        pollWrapper.initInterrupt(fd0, fd1);        fdToKey = new HashMap();}复制这里我们看到在selector中实际是创建了一个epoll的包装类，我们先着看这个包装类构造方法做了什么：
//EPollArrayWrapper构造方法的EPollArrayWrapper() throws IOException {        //创建epoll文件描述符 epollCreate()是native方法        epfd = epollCreate();        //申请一个数组,用于保存epoll_event的数组        int allocationSize = NUM_EPOLLEVENTS * SIZE_EPOLLEVENT;        pollArray = new AllocatedNativeObject(allocationSize, true);    //这里保存了这个数组的地点用于将其传给epoll,epoll会将准备好的事件复制到数组中        pollArrayAddress = pollArray.address();        //用于保存高位channel绑定的socket文件句柄和感兴趣事件的映射    //EPollArrayWrapper中另有用于保存映射关系的低位数组,两者作用是一样的        if (OPEN_MAX > MAX_UPDATE_ARRAY_SIZE)                eventsHigh = new HashMap();}//epollCreate的native方法private native int epollCreate();复制我们看下创建epoll的的native方法，这个方法的实现在EPollArrayWrapper.c中，是由c语言写的：
JNIEXPORT jint JNICALLJava_sun_nio_ch_EPollArrayWrapper_epollCreate(JNIEnv *env, jobject this){    //可以看到简朴干脆,调用了epoll_create方法,并直接返回epoll的文件句柄    int epfd = epoll_create(256);    if (epfd < 0) {       JNU_ThrowIOExceptionWithLastError(env, "epoll_create failed");    }    return epfd;}复制到这里我们可以看出java中的selector在linux上其实其本质就是一个epoll，当然以笔者看源码的习惯是不会满足于这里，我们还要继续往下看。
而epoll_create()方法的实现就需要从linux源码中探求了，它在eventpoll.c中：
//来源于linux 5.14.7SYSCALL_DEFINE1(epoll_create, int, size){        if (size event.events & EPOLLEXCLUSIVE)) {                                epds->events |= EPOLLERR | EPOLLHUP;                                error = ep_modify(ep, epi, epds);                        }                } else                        error = -ENOENT;                break;        }    .....}复制注:这里关于ep_insert()这个方法笔者就不继续展开，这个方法将对应的fd添加到epoll的红黑树中，并在添加一个回调(叫做ep_poll_callback)绑定在epoll事件发生后，这个回调会在epoll事件发生后将对应的事件放到epoll的准备就绪链表上，并唤醒epoll中的全部等待队列。
代码执行到这里，我们需要监听的全部socoket的fd已经被添加到epoll的红黑树中了，并且当产生对应感兴趣的事件后，会调用我们添加的回调方法，将对应事件复制到epoll的就绪链表中，以是接下来epoll要做的就是监听这个就绪链表，这也就是epollWait()方法的内容，我们一起来看下：
//实现一样是在linux源码中,最后会调用这个方法static int do_epoll_wait(int epfd, struct epoll_event __user *events,                         int maxevents, struct timespec64 *to){    ......    //这个方法会先将一个临时空节点加入就绪队列rdllist中    //之后将就绪队列从eventpoll中卸载，只从临时空节点开始遍历获取全部的就绪事件，    //并将其从内核态copy到用户态,copy到之前传入的事件数组pollArray中(之前传入了pollArray的地点)    //我们就不继续展开        error = ep_poll(ep, events, maxevents, to);    ......}复制到这里pollArray中就有已经就绪的地点了，之后会调用updateSelectedKeys()这个方法(之前提到过的方法)将其复制到key的集合中，以便于我们获取:
protected int doSelect(long timeout) throws IOException {        if (closed)                throw new ClosedSelectorException();        processDeregisterQueue();        try {                begin();                pollWrapper.poll(timeout);        } finally {                end();        }        processDeregisterQueue();        //这个方法会将pollArray数组中的已经完成的事件取出,找到对应的Key将其    //更新前面提到的SelectionKey的Set集合,即selector.selectedKeys()方法返回的集合        int numKeysUpdated = updateSelectedKeys();        if (pollWrapper.interrupted()) {                pollWrapper.putEventOps(pollWrapper.interruptedIndex(), 0);                synchronized (interruptLock) {                        pollWrapper.clearInterrupted();                        IOUtil.drain(fd0);                        interruptTriggered = false;                }        }        return numKeysUpdated;}private int updateSelectedKeys() {    //获取已经就绪的事件数        int entries = pollWrapper.updated;        int numKeysUpdated = 0;        for (int i=0; i

转发了