如何将连接更改为挂起状态？ReactorNetty

Question

嗨，我是ReactorNetty的新手。

我正在尝试使用连接池通过TCP协议传输。因此，我在应用程序启动时构建了ConnectionProvider，并将其作为参数提供给TcpClient。

  @PostConstructpublic void init() {     
    provider = ConnectionProvider.builder("fixed")            
                .maxConnections(20)            
                .pendingAcquireMaxCount(200)            
                .pendingAcquireTimeout(Duration.ofSeconds(20))            
                .maxIdleTime(Duration.ofSeconds(10))            
                .maxLifeTime(Duration.ofSeconds(20))       
                .build();
  } 

public void send(String ip, int port, String logText) {    
    TcpClient tcpClient = TcpClient.create(provider)            
                          .host(ip)            
                          .port(port);    
    tcpClient.connect().subscribe(connection -> {        
              System.out.println("connection : " + connection);       
              connection.outbound().sendString(Mono.just(logText)).then().subscribe();           
    });
} 

发送20次后，应用程序抛出

PoolAcquireTimeoutException:Pool#acquire(Duration has been pending for more than the configured timeout of 20000ms

如果我删除。pendingAcquireMaxCount（200）和。pendingAcquireTimeout（持续时间秒（20））在构建连接提供程序时，它抛出

PoolAcquirePendingLimitException: pending acquire queue has reached its maximum size of 40

我想这是因为连接没有正确返回到池。

我如何解决这个问题？？

Answer 1

当连接池被完全使用时，您可以将挂起的连接请求设置为没有限制，使用作为配置的生成器属性的值：

provider = ConnectionProvider.builder("fixed")
     .maxConnections(20)
     .pendingAcquireMaxCount(-1) // no limits on pending connection requests
     .maxIdleTime(Duration.ofSeconds(10)) // you should better increase the max-idle value as well        
     .maxLifeTime(Duration.ofSeconds(20))       
     .build();