无法在Reactornetty版本0.9.10上设置WriteTimeout

Question

我已经使用SpringWebFlux版本2.3.0编写了一个反应式API。发布Reactornetty版本0.9.10。作为API SLA的一部分，如果服务器执行的WriteTimeout超过了规定的配置，我想让请求超时。

分享下面截取的代码，我在这里为NettyReactiveWebServerFactory实现了一个定制器。

@Bean
  public WebServerFactoryCustomizer serverFactoryCustomizer() {
    return new NettyTimeoutCustomizer();
  }

  class NettyTimeoutCustomizer implements WebServerFactoryCustomizer<NettyReactiveWebServerFactory> {

    @Override
    public void customize(NettyReactiveWebServerFactory factory) {
      int connectionTimeout = 1000;
      int writeTimeout = 1;
          factory.addServerCustomizers(server -> server.tcpConfiguration(tcp ->
              tcp.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, connectionTimeout)
                  .doOnConnection(connection ->
                      connection.addHandlerLast(new WriteTimeoutHandler(writeTimeout)))));
    }
  }

尽管有定制器，WriteTimeout仍不能用于API。

Answer 1

不要定义WebServerFactoryCustomizer bean，而是创建NettyReactiveWebServerFactory的bean来覆盖Spring的自动配置。

  @Bean
  public NettyReactiveWebServerFactory nettyReactiveWebServerFactory() {
    NettyReactiveWebServerFactory webServerFactory = new NettyReactiveWebServerFactory();
    webServerFactory.addServerCustomizers(new MyCustomizer());
    return webServerFactory;
  }

现在，MyCustomizer的外观如下所示：

public class MyCustomizer implements NettyServerCustomizer {

  @Override
  public HttpServer apply(HttpServer httpServer) {
    return httpServer.tcpConfiguration(tcpServer -> tcpServer.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 1000)
        .bootstrap(serverBootstrap -> serverBootstrap.childHandler(new ChannelInitializer<Channel>() {
          @Override
          protected void initChannel(Channel channel) throws Exception {
            channel.pipeline().addLast("writeTimeoutHandler", new WriteTimeoutHandler(1));
          }
        }))
    );
  }
}

这是API官方文件中建议的方式