皮皮网

1.Netty源码-Reactor线程模型之NioEventLoopGroup研究
2.Pistache源码分析 —— Transport类
3.Reactive Spring实战 -- 理解Reactor的线线程设计与实现
4.C/C++实现高效事件处理模式（reactor模式、proactor模式）
5.单服务器高性能详解：Reactor 和 Proactor
6.Reactor-Netty基本抽象类介绍

Netty源码-Reactor线程模型之NioEventLoopGroup研究

       在Netty网络编程中，程源池NioEventLoopGroup作为线程池的线线程核心组件，其作用至关重要。程源池从初始化的线线程逻辑分析来看，NioEventLoopGroup扮演多重角色，程源池追趣游戏源码不仅提供了线程池相关功能，线线程同时也继承了线程模型的程源池ScheduledExecutorService，ExecutorService和Executor接口，线线程体现其多功能性。程源池

       其层次结构显示，线线程NioEventLoopGroup从底层向上层层封装，程源池实现了线程池模型的线线程关键功能。进一步深入分析，程源池NioEventLoopGroup通过继承自MultithreadEventLoopGroup，线线程并在构造函数中执行关键初始化操作，展现了其独特的设计。首先，NioEventLoopGroup在初始化时创建线程工厂，构建线程执行器Executor，如果未提供自定义Executor，将使用DefaultThreadFactory创建FastThreadLocalThread线程执行任务。其次，根据指定数量nThreads创建子线程组，若nThreads未定义或设为0，则默认设置为2倍的CPU线程数。最后，在初始化子线程组时，NioEventLoopGroup通过newChild()方法执行初始化，这一步操作具体实现由NioEventLoop类完成，其初始化参数包括线程选择器chooser，以及其他多个关键参数，确保线程高效运行。

       NioEventLoopGroup与Java线程池之间的区别主要体现在其面向特定应用场景的设计上，尤其在事件驱动和非阻塞IO模型的支持方面。Netty通过NioEventLoopGroup实现了更灵活、发票查重源码高效的并发处理机制，使得在处理高并发、高网络流量场景时，性能得到显著提升。

       在研究NioEventLoopGroup的过程中，我们深入学习到了设计模式的应用，如单例模式确保了线程选择器的唯一性，工厂模式则负责创建不同类型的线程组。此外，模板设计模式的使用，使得NioEventLoopGroup能够提供高度抽象的初始化逻辑，同时保持了代码的复用性和可扩展性。通过这种设计，Netty不仅优化了资源管理，还提升了系统的整体性能和稳定性。

Pistache源码分析 —— Transport类

       Transport类是Reactor架构中的关键组件，它为worker线程提供了一系列接口，负责处理核心功能，如等待HTTP请求并调用用户自定义的Handler。简单来说，如果Handler对应HTTP协议，那么Transport相当于TCP协议，这是其名称的由来。

       Transport类继承自Aio::Handler类，该基类定义了两个虚函数。Transport类内部还包含了一系列成员变量和成员函数，共同构成其功能。

       成员变量包括：PollableQueue、处理新连接、处理HTTP请求、异步写机制、线程资源统计、定时机制和断开连接等。

       Aio::Handler类主要定义了两个虚函数，具体功能与Transport类的看java源码神器成员函数相对应，如处理新连接、处理HTTP请求、异步写机制等。

       处理新连接：这部分功能在初始化和请求处理阶段实现，具体操作可参考源码分析文章。

       处理HTTP请求：处理请求是核心功能，文章中详细描述了这一过程，包括请求处理的具体实现。

       异步写机制：这部分功能通过rusage和timerfd机制实现，可参考相关Linux手册了解具体实现。

       线程资源统计：这部分功能用于统计线程资源，确保程序高效运行。

       定时机制：通过timerfd_create(2)和getrusage(2)实现定时任务，这部分功能需要深入理解Linux相关手册。

       断开连接：提供了断开连接的功能，确保连接资源的合理管理。

       重载父类：实现父类的重载，扩展或修改基类的功能。

       其他：Transport类还包含了其他功能，这些功能可能涉及数据处理、状态管理等，具体细节需查阅源代码。

Reactive Spring实战 -- 理解Reactor的设计与实现

       Reactor是Spring提供的非阻塞式响应式编程框架，实现了Reactive Streams规范。它提供了可组合的异步序列API，包括用于多个元素的Flux和用于零到一个元素的Mono。

       Reactor Netty项目还支持非阻塞式网络通信，非常适合微服务架构，为HTTP（包括Websockets），TCP和UDP提供了响应式编程基础。本文将通过实例展示和源码阅读，深入分析Reactor的核心设计与实现机制。

       Reactor源码基于版本3.3。

       响应式编程是一个专注于数据流和变化传递的异步编程范式，允许使用编程语言表示静态或动态数据流。智能音箱源码分析

       Reactor中，发布者（Publisher）负责生产数据，订阅者（Subscriber）负责处理和消费数据。创建发布者和订阅者后，通过建立订阅关系，发布者开始生产数据并传递给订阅者。

       Flux和Mono是两种发布者类型，分别用于生产多个数据元素和单个数据元素。例如，Flux.range和fromArray等静态方法会返回Flux子类。

       Reactor中关键方法包括Publisher#subscribe和Flux#subscribe。订阅者在onSubscribe方法中接收订阅关系，然后通过Subscription#request方法向发布者请求数据。

       RangeSubscription#request、Subscriber#onNext和CoreSubscriber的内部逻辑展示了数据流转的过程。Flux子类的subscribe方法创建Subscription，将操作符逻辑转移到Subscriber端。

       操作符方法，如skip、distinct、sort和filter，是Reactor的核心，用于处理和组合数据流。例如，myHandler作为订阅者，可以处理生成的Flux子类序列。

       Reactor支持push和pull模式。pull模式通过Flux#generate和Sink缓存数据，而push模式则通过Flux#create，允许多线程同时推送数据。

       Reactor提供线程与调度器支持，例如parallel、single、boundedElastic和parallel。这些调度器允许在不同线程环境下执行操作。中兴内核源码下载

       Reactor中的publishOn和subscribeOn操作符方法用于切换操作上下文，分别影响后续操作和整个链路的线程执行环境。

       流量控制是响应式编程中的重要概念，FluxSink.OverflowStrategy定义了在数据生产速度超过消费速度时的策略，如忽略、错误或缓存数据。

       Reactor通过实例和源码展示了响应式编程的概念和实现机制，以及如何在实际应用中使用。通过WebFlux和AsyncRestTemplate的比较，将揭示响应式编程带来的优势。

C/C++实现高效事件处理模式（reactor模式、proactor模式）

       Reactor模式是一种事件驱动机制，其核心在于回调函数。应用程序提供接口并注册到Reactor上，当特定事件发生时，Reactor主动调用相应的回调函数。这种模式在并发I/O处理中较为常见，用于同步I/O，强调将所有I/O事件注册到中心I/O多路复用器，多线程Reactor模式中，主线程负责注册与等待事件，通过epoll内核事件表进行I/O操作，多个工作线程处理事件的具体逻辑。单线程Reactor模式与之类似，但工作在同一线程中。

       Proactor模式与Reactor模式不同，它将I/O操作交给主线程和内核处理，工作线程负责业务逻辑。Proactor模式通过调用aio_read/aio_write函数向内核注册读写事件，内核通过信号通知应用程序事件状态。主线程仅处理连接请求事件，而读写事件由信号触发。

       使用同步I/O模拟Proactor模式时，主线程执行数据读写操作，读写完成通知工作线程，工作线程获得结果并进行逻辑处理。流程包括注册读就绪事件、等待数据读取、将数据封装为请求对象、工作线程处理请求、注册写就绪事件、写入结果等。

       几种开源库应用了上述技术，包括事件循环、优先级处理和线程安全。event_base和loop实例通常不支持线程安全，一个实例只能在一个线程内访问，并按照优先级顺序执行事件回调。

单服务器高性能详解：Reactor 和 Proactor

       Reactor 和 Proactor 是网络通信处理中的高性能模型，是架构思想和设计思维的体现。学习它们能帮助我们更好地理解并处理高并发网络IO请求。

       Reactor 模型，以"反应器"命名，是被动过程，接收客户端事件后根据事件类型调用相应代码进行处理。它以I/O多路复用和线程池为基础，用于服务器端处理高并发网络IO请求。

       Reactor 线程模型包括三种：单 Reactor 单线程模型、单 Reactor 多线程模型和多 Reactor 多线程模型。

       单 Reactor 单线程模型中，所有操作都在一个线程中完成，优点是简单、无线程竞争，但缺点是无法充分利用多核CPU性能，且当业务耗时长时容易造成阻塞。

       单 Reactor 多线程模型采用线程池处理业务逻辑，能充分利用多CPU性能，但存在交互复杂性问题。

       多 Reactor 多线程模型通过增加多个 Reactor提升性能，实现清晰的职责分工，减少了交互复杂性，但需要更复杂的逻辑处理。

       Proactor 模型，以"主动器"命名，主动处理连接、读写等IO事件，由操作系统内核在处理完事件后通知程序代码。与Reactor模型相似，Proactor模型同样有模型抽象图、工作原理、优缺点和案例。

       Reactor 和 Proactor 模型是网络IO处理中的经典高性能模型，掌握了它们的精髓能帮助快速适应技术更迭。

Reactor-Netty基本抽象类介绍

       概述

       之前已经把reactor3看的差不多了,在学会webflux之前还需要了解Reactor-Netty的相关知识,然后才能看懂webflux,然后才能看懂Gateway.

LoopResource

       首先先学习几个基本的类才能看懂Reactor-Netty在干什么.我们先来看LoopResource类.官方说这个类是一个EventLoopGroup 的 selector并且关联了 Channel的工厂

* An { @link EventLoopGroup} selector with associated* { @link io.netty.channel.Channel} factories.

       我们来看一下LoopResource提供的一些方法

static LoopResources create(String prefix) { if (Objects.requireNonNull(prefix, "prefix").isEmpty()) { throw new IllegalArgumentException("Cannot use empty prefix"); } return new DefaultLoopResources(prefix, DEFAULT_IO_SELECT_COUNT, DEFAULT_IO_WORKER_COUNT, true);}

        我们来看看DefaultLoopResource内部实现

        其实内部就是缓存了一堆的EventLoopGroup

ChannelPipelineConfigurer

        这个类的作用就是Channel创建好之后,在读取数据之前的初始化工作,我们看几个实现类 HttpServerChannelInitializer

ChannelGroup

       官方解释: 一个线程安全的集合,里面装的是打开的Channel,并且提供了很多操作Channel的方法,关闭的Channel会自动被group剔除.一个Channel可以属于多个Group

       先来看看唯一一个实现类DefaultChannelGroup的源码

        可以看到内部就是两个Map维护服务端和客户端的Channel,然后还有一个监听器.接下来看看添加Channel的方法再来看看是如何自动把过期Channel移除的,channel关闭之后会出发listener,listener会调用remove方法

        其实就是很简单的从map中移除数据的逻辑

ConnectionObserver

       从字面上看就是连接的观察者.是一个Connection的生命周期观察器.核心方法是 onStateChange.子类很多,等看源码的时候看到具体的再看源码.我们先来看ConnectionObserver定义的几个状态

TransportConfig

       一个配置的抽象类,里面保存了一些属性

        我们上面介绍的那些类都被保存在了这个Config里面.来看看其中一些比较重要的子类

ServerTransportConfig

        可以看到这个子类里面提供了两个ConnectionObserver我们分别来看一看

ServerTransportDoOnconnectionServerTransportDoOn原文：/post/

Reactor模式以及Netty中的应用

       本文主要讨论Reactor模式以及它在Netty中的应用。Reactor模式是一种设计模式，用于处理并发请求，它由一个线程接收所有请求，然后将这些请求分发到相关的工作线程中处理。

       Reactor模式在Java中尤为突出，尤其在多线程环境下。传统socket编程中，请求处理是阻塞的，这在面对高并发请求时效率低下。为了解决这个问题，引入了Reactor模式。Reactor模式有三种形式：单Reactor单线程、单Reactor多线程和多Reactor多线程。

       单Reactor单线程工作流程中，一个select循环接收请求，并将其分发给处理器处理。然而，这种模式的问题在于如果一个处理器阻塞，所有请求都将阻塞。单Reactor多线程则将注册和监听事件的责任留给Reactor，而计算和编解码则由线程池处理。这种模式能充分利用资源，提高应用性能，但也存在Reactor在主线程中运行的问题。多Reactor多线程中，mainReactor处理连接建立，subReactor处理连接事件，这种模型使得模块更加专一，支持更高并发量。

       Netty框架采用了多Reactor多线程模型，包含BossGroup和WorkGroup两个线程池，每个线程池中有多个NioEventGroup，负责监听事件。Pipeline里包含多个ChannelHandler，按顺序执行。这种架构使得Netty能够高效处理并发请求。

       Reactor模式和Netty框架的应用展示了它们在处理并发请求时的强大能力。学习这些模式不仅有助于理解设计思想，也有助于构建高性能的网络应用。Doug Lea的名言强调了知识分享的重要性，鼓励大家共同学习和进步。

Reactor 线程模型，我总结了这3点

       Reactor模型是网络服务器端处理高并发网络IO请求的编程方式。它包含连接事件、写事件、读事件三大处理事件，由reactor、acceptor、handler三个关键角色共同协作完成。

       在单Reactor单线程模型中，所有功能由一个线程执行，reactor负责监听与事件分发，acceptor处理连接事件，handler处理读写事件，同时完成业务处理。

       单Reactor多线程模型中，reactor、acceptor、handler功能继续由一个线程执行，但业务处理工作由线程池中的worker线程完成。

       主-从Reactor多线程模型则由一个主线程、多个子线程与worker线程构成线程池。主线程监听事件并分发给子线程处理，子线程监听事件，handler在同一个线程中读取请求与返回结果，业务处理由worker线程处理。

       Redis采用单Reactor单线程模型，通过aeMain、aeProcessEvents、aeCreateFileEvent等关键函数实现。

       Nginx采用多进程模型，master进程不处理网络IO，每个worker进程为独立的单Reactor单线程模型。

       Netty支持多种线程模型，包括单Reactor单线程、单Reactor多线程及多Reactor多线程。

       Kafka采用主从Reactor多线程模型，Reactor负责网络IO，处理任务交由worker线程池完成，主要与磁盘IO交互。

       深入理解Reactor模型，参考Doug Lea关于Reactor的论文、Nginx Reactor模型与一文剖析Reactor模型的资料。

netty的reactor线程组中的每个reactor线程处理网络i/o为什

       在Netty的Reactor线程组中，每个Reactor线程处理网络I/O的机制，旨在提高效率与降低资源消耗。Netty采用非阻塞I/O模型，即NIO，因此在处理IO操作时，无需因等待而发生阻塞。这使得无需启动超出实际处理能力的线程数，有效减少了不必要的线程切换，提高了系统性能。

       Reactor线程组中的"串行"处理并非传统意义上的等待一个请求完成后再处理下一个，而是指线程在执行特定阶段的I/O操作时，依次顺序执行。这种串行处理方式确保了每个线程专注于当前任务，直至完成，避免了多任务切换带来的开销。同时，这种设计降低了线程间的同步复杂度，使得系统在高并发场景下更加稳定高效。

       Reactor线程组中的每个Reactor线程负责接收与发送数据包、处理事件循环等关键操作，通过非阻塞方式处理网络请求，有效避免了线程间的阻塞问题。这种机制确保了系统能充分利用CPU资源，提高网络I/O性能，显著提升了应用程序的整体响应速度和吞吐量。

       综上所述，Netty的Reactor线程组通过合理利用NIO特性，实现高效、低开销的网络I/O处理。每个Reactor线程专注并顺序执行任务，避免了不必要的线程切换与阻塞，从而在保证系统稳定性的前提下，最大化资源利用率，显著提升应用性能。