Netty 常见组件介绍

上篇文章Netty入门程序echo 基本包含了Netty常见的组件，本文分别介绍各个组件

Bootstrap or ServerBootstrap
EventLoop
EventLoopGroup
ChannelPipeline
Channel
Future or ChannelFuture
ChannelInitializer
ChannelHandler

Bootstrap vs ServerBootstrap

Bootstrap

Bootstrap 主要用于客户端的配置，它主要用于创建一个连接到远程服务器的客户端应用程序

它允许你设置以下内容

EventLoopGroup
Channel
ChannelInitializer 用来配置新创建的通道的 ChannelPipeline。

 Bootstrap b = new Bootstrap();b.group(group).channel(NioSocketChannel.class).handler(new ChannelInitializer<SocketChannel>() {@Overridepublic void initChannel(SocketChannel ch) throws Exception {ch.pipeline().addLast("decoder", new StringDecoder());ch.pipeline().addLast("encoder", new StringEncoder());ch.pipeline().addLast(new ClientHandler());}});// 连接到服务器ChannelFuture f = b.connect(host, port).sync();

ServerBootstrap

ServerBootstrap 是专门用于配置和启动服务端通道的工具类。
它用于创建一个能够监听指定端口，接收客户端连接并处理客户端请求的服务器应用程序

ServerBootstrap还需要配置
childHandler 服务端会为每个客户端连接创建一个新的通道，childHandler方法用于添加处理这些客户端通道事件的ChannelHandler。

ServerBootstrap 需要两个 EventLoopGroup，一个用于接受连接
另一个用于处理 IO读写操作，而Bootstrap只需要指定一个EventLoopGroup用于处理IO读写操作

 EventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup workerGroup = new NioEventLoopGroup();try {ServerBootstrap b = new ServerBootstrap();b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>() {@Overridepublic void initChannel(SocketChannel ch) throws Exception {ch.pipeline().addLast("decoder", new StringDecoder());ch.pipeline().addLast("encoder", new StringEncoder());ch.pipeline().addLast(new ServerHandler());}});ChannelFuture f = b.bind(port).sync();

Channel

Channel 在 Netty 中是对网络 I/O 操作的抽象。它代表了一个网络连接或者通信管道，可以是服务器端用于监听客户端连接的通道，也可以是客户端用于连接服务器的通道。

NioSocketChannel

基于 Java NIO 的 Socket 通道，主要用于客户端建立 TCP 连接。前面Bootstrap客户端代码片段使用的就是NioSocketChannel

NioServerSocketChannel

同样基于 Java NIO，用于服务器端监听 TCP 端口，等待客户端的连接请求。前面ServerBootstrap代码片段使用的就是NioSocketChannel

EpollSocketChannel 和 EpollServerSocketChannel（适用于 Linux）

这两种通道是基于 Linux 的 epoll 机制实现的。
EpollSocketChannel用于客户端连接，EpollServerSocketChannel用于服务器监听

OioSocketChannel 和 OioServerSocketChannel（基于旧的阻塞 I/O）

这是基于传统的阻塞式 I/O 实现的通道，使用的比较少，通常我们使用NIO，都使用Netty，还用阻塞IO，小编实在编不出有什么合适的理由。

ChannelPipeline

ChannelPipeline 是 Netty 中的一个核心组件，它是一个ChannelHandler 的责任链，负责处理所有的入站事件(读)和出站事件（写）。无论服务端还是客户端都可能要处理读写事件，因为本质建立在TCP链接基础上，是全双工的。

ChannelPipeline无论在服务端还是客户端，它的设置都非常重要。

ChannelPipeline 包含着一系列的 ChannelHandler，服务端/客户端按照ChannelHandler顺序来处理 IO 事件，它的顺序非常重要。

事件处理顺序

责任链中隐含两个Handler，一个Header,一个是Tail,这两个非常重要，本文先点到为止。

加上Header和Tail用户向ChannelPipeline中添加的ChannelHandler1，ChannelHandler2，…，ChannelHandlerN ; 按顺序处理出站/入站事件。

入站事件顺序

入站事件从 ChannelPipeline 的头部开始，向尾部传播

Header -> ChannelHandler1 -> ChannelHandler2 -> … -> ChannelHandlerN -> Tail

出站事件顺序

出站事件则从ChannelPipeline尾部开始，向头部传播。

Tail -> ChannelHandlerN -> … -> ChannelHandler2 -> ChannelHandler1 -> Header

只有理解了ChannelPipeline的处理顺序，我们才能正确的设置责任链上 ChannelHandler,才能正确的处理对应事件。

ChannelInitializer

ChannelInitializer 是 Netty 中一个非常重要的组件，它就像是一个 ChannelPipeline 的构建器

ChannelFuture

jdk线程池异步执行需要返回结果的通常返回的是Future,
ChannelFuture 接口继承 Future，
ChannelFuture 是 Netty 中用于表示一个异步操作结果的接口。在 Netty 中，许多 I/O 操作（如连接建立、数据写入、绑定端口等）都是异步执行的。

ChannelHandler

ChannelHandler 是 Netty 中用于处理 Channel 事件的核心组件。它是一个接口，定义了一系列方法来处理各种网络 I/O 事件，
如数据读取、写入、连接建立和关闭等。可以把 ChannelHandler 看作是一个事件处理器

ChannelInboundHandler:
处理入站事件，如连接建立、数据接收、异常捕获等。
常见实现：SimpleChannelInboundHandler, ChannelInboundHandlerAdapter
ChannelOutboundHandler:
处理出站事件，如绑定、连接、写入数据等。
常见实现：ChannelOutboundHandlerAdapter
ChannelDuplexHandler:
同时处理入站和出站事件。
常见实现：ChannelDuplexHandler

上面列的几个类比较底层，Netty 内置了许多ChannelHandler ,如果使用Netty开发某些功能肯定会打交道，我们只需要专学处理消息的读写即可。以下列举几个典型的后续大部分都会接触。

ByteToMessageDecoder

它是一个抽象类，它实现了 ChannelInboundHandler 接口,底层将数据读到ByteBuf中，我们需要将ByteBuf 转换为业务对象，再传递给后续处理器处理。

与之相对应的是MessageToByteEncoder ，将业务消息对象编码为"ByteBuf",再发送给客户端(出站事件)

StringDecoder 和 StringEncoder 就是对应的实现类。我们基于ByteToMessageDecoder也能实现内置的处理器的能力

public class MyByteToMessageDecoder extends ByteToMessageDecoder {@Overrideprotected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {msg = doDecode(in);out.add(msg);}}