Netty源码阅读之事件传输机制的简要分析

Dear 丶 2023-05-22 22:34 11阅读 0赞

前面提到，ChannelHandler可以用来处理inBound以及outBound事件；而inBound以及outBound事件的流转也是Netty中比较重要的一环；下面，将对Netty源码中对事件的传输机制进行简要的分析：

在Netty的事件传播过程中，总共有两种的传播方式，第一种方式是调用pipeline进行传播，另外的一种是直接以pipeline中的某个Context作为起始进行传播，框架的设计者采用了责任链模式来对这块进行了编码，环环相扣非常之巧妙，下面，我们来对事件的传输过程进行一个简要的分析。

1.inBound事件传播流程(read事件)

inBound事件为被动事件，一般是由I/O线程进行触发，找到HeadContext这个类，查找到channelRead()函数:

1.1 channelRead

@Override
            public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
                ctx.fireChannelRead(msg);
            }

继续往下查看函数的实现:

@Override
        public ChannelHandlerContext fireChannelRead(final Object msg) {
            invokeChannelRead(findContextInbound(), msg);
            return this;
        }

这里调用了findContextInbound()函数来查找下一个inbound节点，具体的实现如下:

private AbstractChannelHandlerContext findContextInbound() {
            AbstractChannelHandlerContext ctx = this;
            do {
                ctx = ctx.next;
            } while (!ctx.inbound);
            return ctx;
        }

之后，事件就会继续往下传递给下一个context进行处理。

2.outBound事件传播流程(write事件)

相较于前面的inBound事件，outBound事件多为用户发起的主动事件， 在调用ChannelHandlerContext.channel().write()

函数的时候，会首先找到尾结点并调用pipeline对象的write()函数进行处理:

@Override
        public ChannelFuture write(Object msg, ChannelPromise promise) {
            return pipeline.write(msg, promise);
        }

继续往下查看，我们会发现这里是调用了尾结点的write()方法，进行处理：

@Override
        public final ChannelFuture write(Object msg, ChannelPromise promise) {
            return tail.write(msg, promise);
        }

也就是说，当每一个outBoundHandler在调用write函数的时候，都会从尾结点开始不断往前传递事件，这和inBound事件的处理流程恰恰相反；而通过前面的分析，我们知道，inBound事件传递是可以从一个特定的context往后传播的，那么inBound事件的处理是否也有相类似的功能呢?

![format_png][]

对此，我们直接调用

ChannelHandlerContext.write()函数就能实现从当前的context往前传递事件的功能。

3.总结

由上面的分析我们可以得到结论:

3.1 通过pipeline进行inBound或者outBound事件处理流程

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70][]

3.2 通过context进行inBound或者outBound事件处理流程

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70 1][]

以上便是对netty中事件传输的简要分析；当然，对于事件处理这块还有很多细节没有全部展现，由于时间关系无法一一罗列，感兴趣的读者可以自行研究。

[format_png]: /images/20230521/b774931fbb4a44799f1262bbcc285d8e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70]: /images/20230521/7d3c8fc2d041447ca34bfa081c23eec1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbGlzaGFkYWE_size_16_color_FFFFFF_t_70 1]: /images/20230521/c9a959e2f5cc407d96f8c291c2878089.png