请问，Netty是如何把连接转换为Channel的？

  • Z时代
  • 2024-01-10
  • 分类：IT

  • 最近在阅读 Netty 的源码，但是有个地方一直没搞懂，

  • 服务端启动类 ServerBootstrap.java 中有个嵌套类 ServerBootstrapAcceptor，它的 channelRead(ctx, msg) 方法可以直接将 Object msg 强转为 Channel 对象。

  • 在调用 channelRead(ctx, msg) 方法之前，Netty 是在什么地方将客户端的连接转换为 Channel 的呢？有点头疼！

  • 下图是ServerBootstrapAcceptor源代码截图，使用的Netty版本是 netty-all:4.1.15.Final

图片描述

回答：

2019年3月24日18:58:36

  • 问题是我提的，这个问题困扰我很久了，之前对 Netty 各组件不熟悉，只能先看书、看视频慢慢理解；前两天又一次看到代码ServerBootstrap.ServerBootstrapAcceptor#channelRead(ctx, msg) 还是很晕，遂发帖提问。自己也在思索，寻找答案！就在发布问答之后的几个小时之后，我想到一种解题思路，现列举如下（仔细编写提问，有时也能帮助找到答案）：

  • 我是用 IntelliJ IDEA 的 Find Usages 找到调用关系的。（很惭愧，阅读源码不多，所以之前一直没使用 Find Usages 这个功能来辅助摸清调用关系）

图片描述

  • 如上图，最关键的一处调用就是 processSelectedKey(k, ch) 方法了，这个方法的命名也能够说明问题，它是用来处理SelectionKey的，

  • 在 NioEventLoop 的 processSelectedKey(SelectionKey k, AbstractNioChannel ch) 方法中有对 java.nio 的 SelectionKey 的 OP_CONNECT, OP_WRITE, OP_READ, OP_ACCEPT 的判断

  • 看到这里，我基本就明白了。找到了对 OP_ACCEPT 的处理，就找到了对客户端连接的处理了，SocketChannel 就在随后的代码中创建出来的（一个SocketChannel就对应一个与客户端的连接！）。

  • 在 NioEventLoop#processSelectedKey(k, ch)方法中调用了unsafe#read()，这里的unsafe对应的是AbstractNioMessageChannel的内部类NioMessageUnsafe，在NioMessageUnsafe#read()方法内部又调用了NioServerSocketChannel的doReadMessages(buf:List)方法，就是在这里SocketChannel被创建。

以上是 请问，Netty是如何把连接转换为Channel的？ 的全部内容， 来源链接： utcz.com/p/181333.html

回到顶部