使用Reactor Netty配置TcpClient通讯
<p>使用Reactor Netty配置TcpClient通讯:</p><pre><code>@Bean<br>ClientHttpConnector clientHttpConnector(ReactorResourceFactory resourceFactory) {<br> TcpClient tcpClient = TcpClient.create(resourceFactory.getConnectionProvider())<br> .runOn(resourceFactory.getLoopResources()).option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 60000)<br> .doOnConnected((connection) -> connection.addHandlerLast(new ReadTimeoutHandler(60)));<br> return new ReactorClientHttpConnector(HttpClient.from(tcpClient));<br>}</code></pre><p><br></p>
收藏(1)
分享
相关标签: