有的时候博客内容会有变动，首发博客是最新的，其他博客地址可能会未同步,认准https://blog.zysicyj.top

全网最细面试题手册，支持艾宾浩斯记忆法。这是一份最全面、最详细、最高质量的 java面试题，不建议你死记硬背，只要每天复习一遍，有个大概印象就行了。 https://store.amazingmemo.com/chapterDetail/1685324709017001`

Netty 和 Reactor 模式

Netty 是一个高性能的网络编程框架，它使用了 Reactor 模式来处理并发网络事件。Reactor 模式是一种事件处理模式，用于处理服务端接收到的并发请求，其核心思想是异步非阻塞。

Reactor 模式的基本组成

Reactor 模式主要由以下几个部分组成：

Reactor: 负责监控和分发事件，它会处理IO事件并将相应的事件分发给对应的 Handler。
Handlers: 事件处理器，负责处理非阻塞的行为。
Synchronous Event Demultiplexer: 同步事件多路复用器，它是一个系统调用，用于等待事件的发生（比如，select、poll、epoll）。
Resources: 资源，代表一个打开的文件或网络连接等。

Netty 中的 Reactor 模式

Netty 实现了 Reactor 模式的扩展，即主从 Reactor 多线程模型。在这个模型中，有两组 Reactor：

主 Reactor: 负责处理连接事件，每当有新的客户端连接接入时，主 Reactor 就会接收并将连接分配给从 Reactor。
从 Reactor: 负责处理读写事件，一旦连接建立，从 Reactor 就会负责后续的 IO 事件处理。

Netty 的主要组件

在 Netty 中，Reactor 模式的实现涉及以下几个主要组件：

EventLoopGroup: 事件循环组，它是一组 EventLoop 的集合，EventLoop 是 Netty 的核心抽象，用于处理连接的生命周期中的所有事件。
ServerBootstrap: 服务端启动类，用于配置服务器。
Channel: 网络通信的组件，可以理解为每个连接。
ChannelHandler: 处理网络事件的处理器接口，用户可以自定义处理逻辑。
ChannelPipeline: 一个 ChannelHandler 的链表，用于处理或拦截通道的入站事件和出站操作。

Netty 使用 Reactor 模式的简单示例

以下是一个简单的 Netty 服务器端使用 Reactor 模式的示例：

public class EchoServer {

    public static void main(String[] args) throws Exception {
        // 创建两个 EventLoopGroup，一个用于接收客户端连接，一个用于处理客户端数据
        EventLoopGroup bossGroup = new NioEventLoopGroup(1); // 主 Reactor
        EventLoopGroup workerGroup = new NioEventLoopGroup(); // 从 Reactor

        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class) // 使用 NIO 传输 Channel
             .childHandler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 public void initChannel(SocketChannel ch) throws Exception {
                     // 添加自定义的 ChannelHandler
                     ch.pipeline().addLast(new EchoServerHandler());
                 }
             });

            // 绑定端口，同步等待成功
            ChannelFuture f = b.bind(8080).sync();

            // 等待服务端监听端口关闭
            f.channel().closeFuture().sync();
        } finally {
            // 优雅关闭 EventLoopGroup
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
}

class EchoServerHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        // 处理读事件
        ctx.write(msg); // 写回数据
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) {
        // 读完毕事件
        ctx.flush(); // 刷新后才将数据发出到 SocketChannel
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        // 异常事件
        cause.printStackTrace();
        ctx.close(); // 关闭这个 Channel
    }
}

在这个示例中，bossGroup 是主 Reactor，负责处理连接事件，而 workerGroup 是从 Reactor，负责处理客户端的数据读写。EchoServerHandler 是自定义的处理器，用于处理读事件和异常事件。

Netty 的设计充分利用了 Reactor 模式的优势，使得它能够高效地处理大量并发连接，同时提供了灵活的 API 以满足不同网络应用的需求。

Netty如何使用Reactor模式

Netty 和 Reactor 模式

Reactor 模式的基本组成

Netty 中的 Reactor 模式

Netty 的主要组件

Netty 使用 Reactor 模式的简单示例

喜欢这篇文章的人也看了

如何使用mybatis plus

mybatis pus中的常用注解