使用reactor tcpclient时，如何释放池连接

Question

当我使用带有固定连接提供者的TCP客户端时，我不能重用连接。

他们使连接超过maxConnection变量。

这是我写的。

即使我使用10个maxConnection，比如“ConnectionProvider”。固定（“测试”，10）”，有22个空闲连接。天啊

//NettyClient.java

@AllArgsConstructor
public class NettyClient {

  private final int port;
  public final ConnectionProvider connectionProvider =     ConnectionProvider.fixed("TEST", 10);

  public void sendTest() {
    TcpClient c = TcpClient
      .create(connectionProvider)
      .port(port)
      .handle((in, out) -> {
        return out
      .sendString(Mono.just("string"))
      .then(in
        .receive()
        .asString()
        .flatMap(ss -> {
          out.withConnection(connection -> {
            connection.disposeNow();
          });

          return Mono.empty();
        }));
      })
      .option(ChannelOption.SO_KEEPALIVE, true)
      .wiretap(true);

    c.connect().subscribe();
  }
}

//NettyClientTest。Java语言

public class NettyClientTest {
  @Test
  public void send() throws InterruptedException {

    NettyClient nettyClient = new NettyClient(11);
    for (int i = 0; i < 20; i++) {
      nettyClient.sendTest();
    }

    nettyClient.sendTest();
    nettyClient.sendTest();
  }
}

14:55:27.397[reactor-tcp-nio-5]调试reactor。内蒂。资源。PooledConnectionProvider-[id:0x3444910e，L:/0:0:0:0:0:1:53928！R:/0:0:0:0:0:0:0:0:0:1:33333]通道已清理，现在0个活动连接和22个非活动连接

Answer 1

在您发布的示例中，您执行以下操作：

  out.withConnection(connection -> {
    connection.disposeNow();
  });

因此，每次收到服务器的响应时，都会关闭连接。由于有22个对服务器的请求，您将使用22个连接来执行测试。每个连接首先返回到池，然后立即关闭，因为这是您的请求。

ReactorNetty日志中缺少的正是连接关闭时的日志，所以我添加了这样的日志。如果您尝试0.8.6。测试结束时您将能够看到的BUILD-SNAPSHOT版本：

10:36:42.341 [reactor-tcp-nio-3] DEBUG r.n.r.PooledConnectionProvider - [id: 0x0dad123c, L:/0:0:0:0:0:0:0:1:51530 ! R:/0:0:0:0:0:0:0:1:8080] Channel closed, now 0 active connections and 0 inactive connections