Netty 随记之 ChannelHandlerContext 与 Channel 的 writeAndFlush 的区别

原文地址

ChannelHandlerContext 的 writeAndFlush 方法会将数据写到 ChannelPipeline 中当前 ChannelHandler 的下一个 ChannelHandler 开始处理。

ChannelHandlerContext#writeAndFlush 实现源码：

private void write(Object msg, boolean flush, ChannelPromise promise) {
        AbstractChannelHandlerContext next = findContextOutbound();
        final Object m = pipeline.touch(msg, next);
        EventExecutor executor = next.executor();
        if (executor.inEventLoop()) {
            if (flush) {
                next.invokeWriteAndFlush(m, promise);
            } else {
                next.invokeWrite(m, promise);
            }
        } else {
            AbstractWriteTask task;
            if (flush) {
                task = WriteAndFlushTask.newInstance(next, m, promise);
            }  else {
                task = WriteTask.newInstance(next, m, promise);
            }
            safeExecute(executor, task, promise, m);
        }
    }

private AbstractChannelHandlerContext findContextOutbound() {
        AbstractChannelHandlerContext ctx = this;
        do {
            ctx = ctx.prev;
        } while (!ctx.outbound);
        return ctx;
    }

Channel 的 writeAndFlush 方法会将数据写到 ChannelPipeline 中最后一个 ChannelHandler 然后数据从尾部开始向头部方向流动会经过所有的 ChannelHandler, ChannelPipeline 中的所有 ChannelHandler 都可以处理数据。

public final ChannelFuture writeAndFlush(Object msg) {
        return tail.writeAndFlush(msg);
    }