【Netty】关于netty的入门问题

1、netty 是什么

2、关于netty 中的 pipeline.addLast(xxxxHandler)

这个 xxxHandler 是 ChannelHandlerAdapter 的实现类，
ChannelHandlerAdapter 有好些方法，也很常见，
一直有一些问题，这里加了这么多handler，它在执行的时候，是每一个都会经过的吗？发送的时候会经过吗？响应的时候会经过吗？是不是每次的发送和响应，这些handler都会经过呢？这些Handler 方法，实现的方法，不尽相同，虽然大多数都是重写 channelRead 或 channelRead0 方法，为什么这样子呢，

一直疑惑中：至此，做一下笔记：

• 这么多handler，每一个都会经过吗？
  会经过的，但，如果对应的方法没有重写的话，其实也和没有调用是差不太多。只有重写过的方法，可能才会有业务意义。

• 发送的时候会经过吗？
  在这里，发送包的时候，不会经过，因为 ChannelHandlerAdapter 都是在处理消息响应的时候，
  如果要处理发送时候添加业务，比如在

  • bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise)：在连接远程端点之前，将 Channel 绑定到本地地址。
  • connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise)：在发起连接到远程端点之前执行连接操作。
  • write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)：将要发送给远程端点的消息写入 Channel。
  • flush(ChannelHandlerContext ctx)：刷新数据，确保数据被发送到远程端点。

  这几类型的操作的前后进行操作，那就需要添加另外一个 handler —— ChannelOutboundHandler 这个Handler 才能够满足冤枉。
  不过用得不多。

• 响应的时候会经过吗？（这里说的响应，其实指的是：收到消息的时候，非发送状态，即响应状态）
  是的。如果是实现ChannelHandlerAdapter的handler， 它是对于消息响应时做的方法重写。比如

  • channelRegistered(ChannelHandlerContext ctx)：当 Channel 注册到 EventLoop 后被调用。
  • channelUnregistered(ChannelHandlerContext ctx)：当 Channel 从 EventLoop 取消注册后被调用。
  • channelActive(ChannelHandlerContext ctx)：当 Channel 处于活动状态（已经连接到远程端点）时被调用。
  • channelInactive(ChannelHandlerContext ctx)：当 Channel 处于非活动状态（已经断开与远程端点的连接）时被调用。
  • channelRead(ChannelHandlerContext ctx, Object msg)：当从 Channel 读取到新的数据时被调用。（特别是这个，或者是 channelRead0)
  • channelReadComplete(ChannelHandlerContext ctx)：当 Channel 中的数据读取完成时被调用。 (和这个用得多，读取响应消息，用得多)
  • exceptionCaught(ChannelHandlerContext ctx, Throwable cause)：当处理过程中捕获到异常时被调用。

  所以，一般情况下，看到的 handler都是对于响应的handle, encode, decode 的除外，编解码的是属于另外一种的 handler。

• channelRead 或 channelRead0 方法 有什么不同呢？

channelRead 和 channelRead0 都是 Netty 中用于处理接收到的消息的方法，它们之间的区别在于参数的类型。

具体来说，区别如下：
channelRead(ChannelHandlerContext ctx, Object msg)：
参数 msg 的类型是 Object，即通用的消息类型。
这个方法是在 ChannelInboundHandler 接口中定义的。
在 Netty 4.x 版本中使用。


channelRead0(ChannelHandlerContext ctx, I msg)：
参数 msg 的类型是泛型类型 I，即特定的消息类型。
这个方法是在 SimpleChannelInboundHandler 类中定义的。
在 Netty 5.x 版本及以后的版本中使用。

需要注意的是，在 Netty 5.x 版本之前，Netty 使用的是 channelRead 方法来处理接收到的消息。而在 Netty 5.x 版本及以后，为了提供更好的类型安全性和便利性，引入了 channelRead0 方法，并将其定义在 SimpleChannelInboundHandler 类中。

这两个方法都是被动触发的，当有数据从网络中读取到时，Netty 会自动调用相应的方法来处理这些数据。开发者可以根据实际需求选择合适的方法来处理接收到的消息。

• channelRead 和 channelReadComplete 有什么不同

channelRead 和 channelReadComplete 是 ChannelInboundHandler 接口中的两个方法，用于处理从 Channel 读取数据的不同阶段。

channelRead(ChannelHandlerContext ctx, Object msg) 方法在从 Channel 读取到新的数据时被调用。每当有新的数据可供读取时，该方法就会被触发执行。您可以在这个方法中对接收到的数据进行解析、处理和相应的逻辑操作。

channelReadComplete(ChannelHandlerContext ctx) 方法在 Channel 中的数据读取完成时被调用。它表示当前读取操作已经完成，可以进行相应的后续处理。在这个方法中，您可以执行一些收尾工作，比如刷新数据或发起进一步操作。

通常情况下，channelRead 方法可能会被多次调用，每次读取到一部分数据。而当所有数据都被读取完毕后，channelReadComplete 方法会被调用一次，表示整个数据读取过程已经完成。

需要注意的是，在 channelRead 方法中处理数据时，可能并不一定是完整的消息。对于基于 TCP 的协议，例如 HTTP 或自定义协议，一个完整的消息可能会被分成多个 TCP 包进行传输。因此，您可能需要在接收到足够的数据后才能进行完整的处理，或者缓存已接收到的数据等待后续的组装。

总结起来，channelRead 方法用于处理从 Channel 读取到的数据，而 channelReadComplete 方法表示整个数据读取过程已经完成。

• 和 channelReadComplete 相比，channelRead 可能是一个未完成的状态，那它有什么样的应用场景呢？

channelRead 方法的主要应用场景是在接收到数据的过程中进行实时处理和解析。由于网络传输的特性，可能无法一次性获取完整的消息，而是需要逐步接收并处理数据。

以下是一些使用 channelRead 的常见场景：

数据流处理：当从 Channel 接收到数据流时，可以使用 channelRead 方法对数据进行流式处理，逐个读取和处理数据块，而不必等待所有数据完全接收。

消息解析和处理：在协议层面的通信中，可以使用 channelRead 方法将接收到的字节流逐步解析为具体的消息格式，并在解析到足够的内容后进行相应的逻辑处理。

分段数据处理：某些协议或数据格式可能将大的数据块分成多个数据段进行传输，channelRead 可以用于在每个数据段到达时进行处理，直到接收到完整的数据。

长连接处理：在长连接场景中，channelRead 方法可以用于实时处理每次接收到的数据片段，例如即时聊天、实时推送等。

需要注意的是，在使用 channelRead 进行数据处理时，可能需要进行数据缓存，以便在接收到完整的数据后进行组装和处理。

总结起来，channelRead 方法的应用场景主要是需要逐步接收和处理数据的情况，可以进行实时处理和解析。

（有一些场景下，可能没有 compelete 。。。。）
在一些拆很多个小包，流式传输，长连接等场景下，可能永远都等不到 compelete, 可能等到了也很久后，或一次性要处理的东西就太多了，这种场景下， compelete 不见得是好的。

• bootstrap.connect(ip, port) 客户端向服务端发起连接，会执行pipeline下面的 handler吗
  客户端向服务端发起连接时，这些 handler 也是会走的。
  这个时候， ChannelHandlerAdapter 中的 connect 方法，也会体现出来，通过重写这个 connect, 前后添加业务逻辑是可以的。