有的时候博客内容会有变动，首发博客是最新的，其他博客地址可能会未同步,认准
https://blog.zysicyj.top
全网最细面试题手册，支持艾宾浩斯记忆法。这是一份最全面、最详细、最高质量的 java面试题，不建议你死记硬背，只要每天复习一遍，有个大概印象就行了。 https://store.amazingmemo.com/chapterDetail/1685324709017001`
Netty ChannelPipeline & ChannelHandler 概念
Netty 是一个高性能的网络编程框架，它提供了一个异步事件驱动的网络应用程序框架和工具，用于快速开发高性能、高可靠性的网络服务器和客户端程序。在 Netty 中，ChannelPipeline 和 ChannelHandler 是核心概念，它们共同工作以处理网络事件。
ChannelPipeline
ChannelPipeline 是一个 Netty 中特有的概念，它本质上是一个处理网络事件的拦截器链。每个 Channel 都有自己的 ChannelPipeline，它负责管理和执行 ChannelHandler 链。
特点
- 事件传播：
ChannelPipeline负责传播四种类型的事件：入站事件（Inbound）、出站事件（Outbound）、异常事件（Exception）和用户自定义事件（User Event）。 - 链式结构：
ChannelPipeline内部维护了一个ChannelHandler的链表，事件会按照这个链表的顺序进行传播。 - 动态修改：可以在运行时动态地添加、删除或替换
ChannelHandler。
工作流程
当一个事件在 ChannelPipeline 中传播时，它会按照顺序经过多个 ChannelHandler。入站事件会从链的头部开始传播，直到某个 ChannelHandler 消费该事件或传播到链的末端。出站事件则从链的尾部开始传播，直到某个 ChannelHandler 处理该事件或传播到链的头部。
ChannelHandler
ChannelHandler 是一个接口，它定义了一组事件处理方法。用户可以通过实现 ChannelHandler 接口来定义自己的事件处理逻辑。
类型
- ChannelInboundHandler：用于处理入站事件，如数据读取、连接激活等。
- ChannelOutboundHandler：用于处理出站事件，如数据写入、连接关闭等。
生命周期
ChannelHandler 有自己的生命周期方法，例如 handlerAdded()、handlerRemoved() 和 exceptionCaught()。这些方法可以被重写以执行特定的动作，例如资源释放或异常处理。
实现
实现 ChannelHandler 通常涉及继承 ChannelInboundHandlerAdapter 或 ChannelOutboundHandlerAdapter 类，并重写感兴趣的事件处理方法。
示例
以下是一个简单的 ChannelHandler 实现示例，它只是在接收到数据时打印消息：
public class SimpleChannelHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
// 处理入站事件：数据读取
System.out.println("Received message: " + msg);
// 传递事件给下一个 ChannelHandler
ctx.fireChannelRead(msg);
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
// 处理异常事件
cause.printStackTrace();
ctx.close();
}
}
在这个例子中，SimpleChannelHandler 继承自 ChannelInboundHandlerAdapter 并重写了 channelRead() 和 exceptionCaught() 方法。当读取到数据时，它会打印消息，并通过 ctx.fireChannelRead(msg) 将事件传递给下一个 ChannelHandler。如果发生异常，它会打印异常堆栈并关闭 Channel。
Netty 的 ChannelPipeline 和 ChannelHandler 提供了一个强大的机制来处理复杂的网络事件处理逻辑，使得开发高性能网络应用程序变得更加简单和灵活。
