如何在Reactor网络中为TcpServer添加ChannelInitializer

Question

我有一个NettyServerCustomizer,它的下一个代码是：

@Override
    public HttpServer apply(final HttpServer httpServer) {
        return httpServer.tcpConfiguration(tcpServer -> tcpServer
            .bootstrap(serverBootstrap -> serverBootstrap
                .childHandler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    public void initChannel(final SocketChannel ch) throws Exception {
                        final ChannelPipeline p = ch.pipeline();
                        p.addFirst(new MyCustomChannelInboundHandlerAdapter());
                    }
                })));
    }

但是reactor-netty从版本0.9.10开始就不推荐使用bootstrap方法，请访问:https://github.com/reactor/reactor-netty/pull/1175。

如何使用新的API获得相同的行为？

Answer 1

这是不推荐的，因为在Reactor Netty 1.0.0中，不再使用bootstrap和serverbootstrap。https://github.com/reactor/reactor-netty/releases/tag/v1.0.0在0.9.x中没有替换这个特定的用例。在1.1.0中，替换的是DoonChannelInit如果您的构建限制了不推荐使用的API的使用，请打开一个特性请求，我们将尝试从1.1.0版本回端口API。