【问题标题】:Adding Netty Handler after Channel Initialization: Netty 4.0.17.Final通道初始化后添加 Netty Handler:Netty 4.0.17.Final
【发布时间】:2014-09-07 21:15:14
【问题描述】:

我创建了一个带有 channelInitializer 的 NettyServer,它在 initChannel 方法中设置了管道。然后我打电话给

b.bindPort(port).sync().channel().pipeline().addLast(handler).

在管道初始化之前添加了处理程序,我猜是因为同步只等待通道被创建。

问题是,在管道已经初始化之后,如何在管道末尾添加处理程序?

另外,如何确保在服务器接收到任何消息之前添加最后一个处理程序?

谢谢。

【问题讨论】:

  • 从 netty 4.X 开始,我相信您的处理程序是在使用您的通道初始化程序初始化管道之后添加的。

标签: netty


【解决方案1】:

Netty in Action这本书有以下几点:

您可以在初始化程序中添加多个处理程序:

    @Override
    protected void initChannel(Channel ch) throws Exception {
      ChannelPipeline pipeline = ch.pipeline();
      if (client) {
          pipeline.addLast("codec", new HttpClientCodec());
      } else {
          pipeline.addLast("codec", new HttpServerCodec());
      }
      pipeline.addLast("aggegator",
        new HttpObjectAggregator(512 * 1024));
    }

可以即时修改 ChannelPipeline,这意味着您甚至可以在另一个 ChannelHandler 中添加/删除/替换 ChannelHandler 或让它自行删除。这允许编写灵活的逻辑,例如多路复用器

当您稍后添加处理程序时,您可以使用 handlerAdded 事件存储 ChannelHandlerContext 以供以后使用:

    @Override
    public void handlerAdded(ChannelHandlerContext ctx) {
      this.ctx = ctx;
    }

WebSocketServerProtocolHandler 可能是寻找动态改变管道的一个很好的例子。

【讨论】:

  • 我在初始化程序中添加了多个处理程序,但我想在初始化后动态添加一个。我不必这样做——我可以将处理程序传递给初始化程序——但这会使我的代码更清晰。我想我可以做 addAfter(lastHandler,handler) 而不是 addLast(handler),但这需要知道 lasthandler,使代码不那么健壮。
  • api docs netty.io/5.0/api 非常适合 Channel 包、图片、好文字等。
猜你喜欢
  • 1970-01-01
  • 2017-08-10
  • 1970-01-01
  • 2015-06-18
  • 2021-01-13
  • 2023-03-30
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多