皮皮网

1.inEventLoop()方法有什么
2.Java编程方法论-Reactor-Netty与Spring WebFlux解读 之 第4章 Reactor Netty针对EventLoopGroup的封装
3.Netty源码探究1：事件驱动原理
4.netty系列之:小白福利！手把手教你做一个简单的代理服务器
5.Netty原理-从NIO开始
6.netty nioeventloopgroup是做什么用的

inEventLoop()方法有什么

       线程模型啊

       NioEventLoop相对NioEventLoopGroup来说就复杂很多了，需要一定的耐心来看这篇文章。

       首先从NioEventLoop的启动讲起，对于线程池来说，启动一般都是加载exede源码从第一个任务的添加开始的。经过跟踪，找到execute()方法在SingleThreadEventExecutor类中：

       [java] view plain copy

       public void execute(Runnable task) {

       if (task == null) {

       throw new NullPointerException("task");

       }

       // inEventLoop表示启动线程与当前线程相同，相同表示已经启动，不同则有两种可能：未启动或者线程不同

       boolean inEventLoop = inEventLoop();

       if (inEventLoop) {

       // 运行中则直接添加任务到队列中

       addTask(task);

       } else {

       // 尝试启动任务

       startExecution();

       // 将任务加到任务队列taskQueue中

       addTask(task);

       // 发现已经关闭则移除任务并拒绝

       if (isShutdown() && removeTask(task)) {

       reject();

       }

       }

       if (!addTaskWakesUp && wakesUpForTask(task)) {

       // 唤醒执行线程

       wakeup(inEventLoop);

       }

       }

       private void startExecution() {

       // 未启动的状态下才进行启动

       if (STATE_UPDATER.get(this) == ST_NOT_STARTED) {

       if (STATE_UPDATER.compareAndSet(this, ST_NOT_STARTED, ST_STARTED)) {

       // 增加一个定时任务，该任务将定时任务队列中的已取消任务从队列中移除，该任务每间隔1秒执行1次

       schedule(new ScheduledFutureTask<Void>(

       this, Executors.<Void>callable(new PurgeTask(), null),

       ScheduledFutureTask.deadlineNanos(SCHEDULE_PURGE_INTERVAL), -SCHEDULE_PURGE_INTERVAL));

       // 开始执行

       scheduleExecution();

       }

       }

       }

       // 如果已经关闭了，则不能再加任务，否则加入到任务队列中

       protected void addTask(Runnable task) {

       if (task == null) {

       throw new NullPointerException("task");

       }

       if (isShutdown()) {

       reject();

       }

       taskQueue.add(task);

       }

Java编程方法论-Reactor-Netty与Spring WebFlux解读 之 第4章 Reactor Netty针对EventLoopGroup的封装

       Java编程方法论-Reactor-Netty与Spring WebFlux解读整体简介第4章 Reactor Netty针对EventLoopGroup的封装

       在功能使用层面，为对应如HttpServer、TcpServer等类中的Create方法，Reactor Netty设计了EventLoopGroup的Create方法，以适应响应式环境，实现功能增强。此章节将深入解析这一过程。

       针对EventLoopGroup的接口设计采用装饰器模式，引入reactor.netty.resources.LoopResources接口，它继承自Disposable接口，EventLoopGroup作为其实现类的小牛计划源码一部分。默认的Create方法返回此接口的默认实现。

       在顶层接口内，设置了默认方法，用于获取客户端或服务端的EventLoopGroup。对Netty中的workerGroup和bossGroup进行设定。确认EventLoopGroup是否可关闭，并提供了相应的daemon方法。

       EventLoopGroup继承EventExecutorGroup，关闭操作通过调用EventExecutorGroup的shutdownGracefully方法实现，包装为Mono.defer，订阅执行关闭逻辑。顶层接口中定义了disposeLater方法，用于封装这一逻辑，实现类中重写。

       获取EventLoopGroup与对应的ServerChannel，提供onServerChannel方法进行确认。通过preferNative方法判断本地是否支持Epoll与KQueue，实现层面判断功能支持，使用Class.forName进行判断，异常表示不支持。

       针对操作系统支持的EventLoopGroup，DefaultLoop接口提供获取实例、确认支持的idea netty 源码Channel类型和名称获取方法。实现中通过静态代码块进行逻辑判断，选择对应类型，实现懒汉模式。

       LoopResources接口的create方法返回默认的EventLoopGroup实例，考虑多核处理和缓存策略，使用AtomicReference管理实例。针对selectCount的策略设定，实现bossGroup与workerGroup共享或独立。

       获取EventLoopGroup实例的逻辑分为本地支持情况下的默认实现和不支持时的通用NioEventLoopGroup获取。cacheNativeServerLoops和cacheNioServerLoops分别处理本地支持和不支持情况。

       通过拓展ThreadFactory设定线程名称，结合原子计数获取EventLoopGroup线程数，实现更清晰的线程属性描述。Reactor Netty的Dispose逻辑通过Mono.defer封装，确保所有资源释放完毕后结束订阅。

       本章学习到Reactor Netty针对EventLoopGroup的封装设计，通过上层接口提供核心功能，隐藏实现细节，融合Reactor与Netty，了解原子类、ThreadFactory等技术的用法，以及封装、缓存策略等实践。股价扫描源码

Netty源码探究1：事件驱动原理

       Netty源码探究1：事件驱动原理

       Netty借鉴了Reactor设计模式，这是一种事件处理模式，用于管理并发服务请求。在模式中，服务处理器对请求进行I/O多路复用，并同步分发给相应的请求处理器。Netty的核心内容是Reactor，因此深入分析其在Netty中的应用至关重要。Netty吸收了前人优秀经验，构建出这款优秀的技术框架。

       在Reactor设计模式中，Demultiplexer和Dispatcher是关键概念。Netty中的Demultiplexer是如何实现的？答案在于其Server端的架构设计。Netty通过Bootstrap（ServerBootstrap也适用）来构建Server，其中bind方法是启动Reactor运行的关键。在bind方法中，Netty创建并注册Channel到EventLoopGroup，从而实现Demultiplexer的功能。

       Netty中的Channel与JDK中的Channel有何不同？Netty通过NioServerSocketChannel构建Server，其内部封装了Java NIO的Channel，但Netty的Channel与JDK中的Channel在注册到Selector时有所不同。Netty中的Channel注册到NioEventLoop中的Selector上，只关注OP_ACCEPT事件。内部oa源码当客户端连接时，事件被触发，Server响应客户端连接。这涉及NioServerSocketChannel的构造过程和Selector的创建。

       Dispatcher在Java NIO中负责事件分发，Netty中如何实现这一功能？在NioEventLoop中，Selector.select()方法配合run()函数，共同实现事件监听循环。run函数中包含事件状态机和事件分派逻辑。当有事件到来时，状态机触发processSelectedKeys()方法，根据事件类型调用相应处理器进行处理。

       Netty中的事件驱动原理最终如何与自定义handler关联？在NioEventLoop的processSelectedKey()方法中，事件处理逻辑与Channel.Unsafe接口相关联。Channel.Unsafe接口用于封装Socket的最终操作，Netty通过此接口与业务层Handler建立关联。通过调用handler的read方法，Netty将事件与业务处理逻辑关联起来。

       总之，Netty通过Reactor设计模式实现了事件驱动原理，借助Demultiplexer和Dispatcher的机制，实现了对并发请求的高效处理。理解Netty的源码结构和事件驱动原理，对于深入掌握Netty技术框架至关重要。

netty系列之:小白福利！手把手教你做一个简单的代理服务器

       简介

       爱因斯坦说过:所有的伟大，都产生于简单的细节中。Netty为我们提供了如此强大的eventloop、channel通过对这些简单东西的有效利用，可以得到非常强大的应用程序，比如今天要讲的代理。

代理和反向代理

       相信只要是程序员应该都听过nginx服务器了，这个超级优秀nginx一个很重要的功能就是做反向代理。那么有小伙伴要问了，有反向代理肯定就有正向代理，那么他们两个有什么区别呢？

       先讲一下正向代理，举个例子，最近流量明星备受打击，虽然被打压，但是明星就是明星，一般人是见不到的，如果有人需要跟明星对话的话，需要首先经过明星的经纪人，有经纪人将话转达给明星。这个经纪人就是正向代理。我们通过正向代理来访问要访问的对象。

       那么什么是反向代理呢？比如现在出现了很多人工智能，假如我们跟智能机器人A对话，然后A把我们之间的对话转给了后面的藏着的人，这个人用他的智慧，回答了我们的对话，交由智能机器人A输出，最终实现了人工智能。这个过程就叫做反向代理。

netty实现代理的原理

       那么在netty中怎么实现这个代理服务器呢？

       首选我们首先代理服务器是一个服务器，所以我们需要在netty中使用ServerBootstrap创建一个服务器：

EventLoopGroupbossGroup=newNioEventLoopGroup(1);EventLoopGroupworkerGroup=newNioEventLoopGroup();try{ ServerBootstrapb=newServerBootstrap();b.group(bossGroup,workerGroup).channel(NioServerSocketChannel.class).handler(newLoggingHandler(LogLevel.INFO)).childHandler(newSimpleDumpProxyInitializer(REMOTE_HOST,REMOTE_PORT)).childOption(ChannelOption.AUTO_READ,false).bind(LOCAL_PORT).sync().channel().closeFuture().sync();

       在这个local服务器中，我们传入ProxyInitializer。在这个handler初始化器中，我们传入自定义的handler：

publicvoidinitChannel(SocketChannelch){ ch.pipeline().addLast(newLoggingHandler(LogLevel.INFO),newSimpleDumpProxyInboundHandler(remoteHost,remotePort));}

       在自定义的handler中，我们使用Bootstrap创建一个client，用来连接远程要代理的服务器，我们将这个client端的创建放在channelActive方法中：

//开启outbound连接Bootstrapb=newBootstrap();b.group(inboundChannel.eventLoop()).channel(ctx.channel().getClass()).handler(newSimpleDumpProxyOutboundHandler(inboundChannel)).option(ChannelOption.AUTO_READ,false);ChannelFuturef=b.connect(remoteHost,remotePort);

       然后在client建立好连接之后，就可以从inboundChannel中读取数据了：

outboundChannel=f.channel();f.addListener(future->{ if(future.isSuccess()){ //连接建立完毕，读取inbound数据inboundChannel.read();}else{ //关闭inboundchannelinboundChannel.close();}});

       因为是代理服务，所以需要将inboundChannel读取的数据，转发给outboundChannel，所以在channelRead中我们需要这样写：

publicvoidchannelRead(finalChannelHandlerContextctx,Objectmsg){ //将inboundChannel中的消息读取，并写入到outboundChannelif(outboundChannel.isActive()){ outboundChannel.writeAndFlush(msg).addListener((ChannelFutureListener)future->{ if(future.isSuccess()){ //flush成功，读取下一个消息ctx.channel().read();}else{ future.channel().close();}});}}

       当outboundChannel写成功之后，再继续inboundChannel的读取工作。

       同样对于client的outboundChannel来说，也有一个handler，在这个handler中，我们需要将outboundChannel读取到的数据反写会inboundChannel中：

publicvoidchannelRead(finalChannelHandlerContextctx,Objectmsg){ //将outboundChannel中的消息读取，并写入到inboundChannel中inboundChannel.writeAndFlush(msg).addListener((ChannelFutureListener)future->{ if(future.isSuccess()){ ctx.channel().read();}else{ future.channel().close();}});}

       当inboundChannel写成功之后，再继续outboundChannel的读取工作。

       如此一个简单的代理服务器就完成了。

实战

       如果我们将本地的端口，代理到www..com的端口，会发生什么情况呢？运行我们的程序，访问, 所以服务器端不认识我们的请求，从而报错。

总结

       本文的代理服务器之间简单的转发请求，并不能够处理上述的场景，那么该怎么解决上面的问题呢？ 敬请期待我的后续文章！

       本文的例子可以参考：learn-netty4

       最通俗的解读，最深刻的干货，最简洁的教程，众多你不知道的小技巧等你来发现！

       欢迎关注我的公众号:「程序那些事」,懂技术，更懂你！

Netty原理-从NIO开始

       Netty是基于NIO的异步通信框架（曾经引入过AIO，后来放弃），故要说Netty原理我们要先从NIO开始。

        NIO 是JAVA在JDK4中引入的同步非阻塞通信模型，在NIO出现之前（JDK4之前）市场上只有一个BIO模型顾名思义BLOCKING IO （同步阻塞通信模型）

        BIO（BLOCKING I/O）：

        BIO 为一个连接 一个线程的模式，当有连接时服务器会开启一个线程来处理请求

        若此请求啥都不想干此时线程会怎么样？

        此线程会进入阻塞模式（BLOCKING）！---啥也不干，干等着zzZZ~

        这种一连接，一线程的模式会造成服务器资源不必要的开销并且在大量连接访问时 服务器会发生什么？车道（线程）不足，车太多--我堵车了

        由此就出现了NIO

        ↓

        NIO（new/NONBLOCKING I/O）:

        NIO为同步非阻塞通信模型，Select（多路复用器）为此模型的核心，实现了多个连接一个线程

        当有客户端连接请求时 此连接请求会被注册至select上，当select检测到此连接有I/O请求时才会打开一个线程去对此I/O请求进行处理-----单线程模型

        这个时候有人问了：这么多操作都在一个线程里，线程忙不过来怎么办？

        此时 由于网络请求、I/O读写、业务操作都在一个线程下，会导致在高并发的情况下存在性能瓶颈 于是乎有人就提出来 将业务操作丢到另一个线程怎么样？

        于是出现了第三种reactor模型-使用线程池进行操作网络请求、IO在一个线程，业务操作在另个一个线程 的业务分离----线程池模型

        从此图中可以看出此时 模型中使用一个线程池来进行网络请求、IO读取

        当读取完成后将业务操作绑定在线程池中另外的线程上-------网络IO与业务操作可以同步进行了！一切都完美了起来！

        但是！事情还没完！！这个时候又有人提出问题：在高并发的时候咋办？会不会有性能瓶颈

        因为网络IO是非常消耗CPU的，当网络请求与网络IO在同个线程中时，造CK的情况下单个线程并不足以支撑起所有的IO操作！因此也形成了在高并发状态下的性能瓶颈

        于是大佬们就想着，如果把IO拆出来让单个线程池去接收网络请求，用另一个线程池来进行IO与业务操作会不会更好

        于是第四种Reactor模型应运而生--主从Reactor多线程模型

        此模型中 mainReactor只用于接收网络请求，而subReactor中为一个线程池，线程池中每个线程上绑定一个select

        当mainReactor接收到请求时（一个描述符） 系统会生成一个新的描述符代表此连接生效，此时mainReactor会将新的描述符通过一个算法在线程池中选定一个线程 将此描述符绑定至此线程池上的select上，由此线程来对请求进行I/O 与业务操作

        从此百万连接高并发不是问题

        写到这 我们是不是想起了Netty的启动过程

        1、声明两个EventLoopGroup一个为boss（mainReactor）一个为worker（subReactor）

        EventLoopGroup（线程池）初始化的时候会生成（懒加载）指定数量的EventLoop（线程）若无指定 则会生成CPU数X2的线程

        2、声明一个启动辅助类Bootstrap并将EventLoopGroup注册到启动辅助类BootStrap上(bootStrap.group)

        接着再给bootstrap指定channel模型等属性，再添加上业务流水线（channelpipeline）并且在pipeline中添加上业务操作handler，（通过channelpipeline可以对传入数据为所欲为）

        3、绑定端口

        Netty启动完成

        这时候可能有人会问了：这和你上面说的reactor？NIO有啥关系？

        这个时候我们要这么看

        ↓

        若我们将boss与worker线程池设置为相同的一个线程池，那么会发生什么事？

        此时关注一下第三个Reactor模型时就会发现 当BOSS=WORKER时候 netty实现的就是第三种Reactor模型 使用线程池模型

        而当boss不等于worker的时候使用的就是第四种 主从多线程模型

        Netty就是基于Reactor模型来对NIO进行了易用化封装，从Netty源码中就可以看出来其实底层还都是NIO的接口

        此次处为自己读源码之后的理解 如有误请指正

        感恩

        反手拿下第一个赞

netty nioeventloopgroup是做什么用的

       相比Netty3,Netty4有很多显著的变化：NioEventLoopGroup是一个处理I/O操作的多线程事件环。即为Netty4里的线程池，在3x里，一个Channel是由ChannelFactory创建的，同时新创建的Channel会自动注册到一个隐藏的I/O线程。netty nioeventloopgroup是做什么用的

Netty面试题及答案（年Netty面试题大全带答案）

       年的Netty面试题集锦，包含了大量经典和高级面试问题，旨在帮助求职者，无论是应届生、实习生还是有经验的开发者，全面了解Netty的各个方面。以下是部分面试题和解析：

:Netty是什么？它是一个基于NIO的高性能网络应用框架，用于开发可维护的服务器和客户端，提供了异步事件驱动的编程模型。

:NioEventLoopGroup的源码解析：它管理多线程事件执行，每个NioEventLoop对应一个线程和Selector，负责事件轮询，解决NIO中的空轮询bug。

:BIO与Netty的区别：BIO是阻塞+同步，易导致性能瓶颈；Netty则是异步+非阻塞，提升了并发处理能力，减少通信等待时间。

:TCP粘包/拆包及其解决办法：由于分包和重组机制，可能产生数据混乱。Netty通过优化数据包边界和序列化协议来避免。

:Netty的使用场景：常用于高性能的实时通信服务，如WebSocket、游戏服务器、消息队列等。

       这个面试题大全详细涵盖了Netty的基础概念、核心组件、线程模型、内存管理以及与BIO的对比，全面解答了Netty面试中的常见问题。点击下载PDF版的面试手册，获取完整答案和深度解析。

       下载链接：[高清份，累计 页大厂面试题 PDF](download_link)