上一篇【第33篇】Netty连接管理与心跳检测——工业级断连处理方案下一篇【第35篇】Netty时间轮HashedWheelTimer源码解析——百万定时任务的秘密一、优化一替换JDK SelectedKeySetJDK Selector的selectedKeys()返回HashSet遍历时需要Iterator有大量装箱/拆箱开销。Netty的做法用SelectedSelectionKeySet基于数组替换HashSet。// 反射替换底层SetfinalclassSelectedSelectionKeySetextendsAbstractSetSelectionKey{SelectionKey[]keysnewSelectionKey[1024];intsize;publicbooleanadd(SelectionKeykey){if(sizekeys.length)returnfalse;keys[size]key;// O(1)追加不需要hash计算returntrue;}publicvoidreset(){size0;// O(1)清空不需要逐个removeArrays.fill(keys,null);// 帮助GC}}// 遍历时直接for循环访问数组比Iterator快很多for(inti0;iselectedKeys.size;i){SelectionKeykselectedKeys.keys[i];// 处理...}性能对比10万连接Netty遍历selectedKeys比JDK快3-5倍。二、优化二解决epoll空轮询BugJDK在Linux下存在epoll空轮询BugSelector.select()没有事件却返回导致CPU 100%。Netty的检测与修复// NioEventLoop中检测空轮询if(SELECTOR_AUTO_REBUILD_THRESHOLD0){longselectTimeSystem.nanoTime()-time;if(selectTime1000000000/10){// 小于100ms就算空轮询emptyPollingCount;if(emptyPollingCount512){// 连续512次空轮询rebuildSelector();// 重建SelectoremptyPollingCount0;}}else{emptyPollingCount0;}}// rebuildSelector创建新Selector将旧Channel重新注册publicvoidrebuildSelector(){SelectornewSelectorSelectorProvider.provider().openSelector();for(SelectionKeykey:oldSelector.keys()){Channelch(Channel)key.attachment();ch.register(newSelector,key.interestOps(),ch);}oldSelector.close();this.selectornewSelector;}三、优化三批量处理任务// runAllTasks可以一次处理多个任务减少线程切换protectedbooleanrunAllTasks(longtimeoutNanos){fetchFromScheduledTaskQueue();RunnabletaskpollTask();if(tasknull)returnfalse;longdeadlineSystem.nanoTime()timeoutNanos;longrunTasks0;for(;;){safeExecute(task);runTasks;taskpollTask();if(tasknull||System.nanoTime()deadline)break;}returntrue;}四、其他优化优化说明效果直接内存优先I/O使用DirectBuffer减少GC内存池PooledByteBufAllocator减少分配开销TCP_NODELAY禁用Nagle算法降低延迟SO_REUSEADDR端口快速复用避免TIME_WAIT五、总结优化技术SelectedKeySet替换数组替代HashSetepoll空轮询修复rebuildSelector批量任务处理一次循环执行多个任务关键原则减少GC、减少锁、减少系统调用上一篇【第33篇】Netty连接管理与心跳检测——工业级断连处理方案下一篇【第35篇】Netty时间轮HashedWheelTimer源码解析——百万定时任务的秘密