获取和释放与TcpClient连接池的连接（ReactorNetty）

Question

我已经按照这里的示例中所述配置了TcpClient。我试图使以下代码在服务器意外关闭连接的情况下具有弹性：

TcpClient tcpClient = getTcpClient();

public Mono<String> sendMessage(Mono<bytes[]> request) {
    Connection connection = getConnectionFromPool(tcpClient);
    return connection
        .outbound()
        .sendByteArray(request)
        .then()
        .then(connection.inbound().receive().asString().as(Mono::from));
}

在这种情况下，我希望方法“getConnectionFromPool”能够从池中检索连接，或者如果没有可用的连接，则打开一个新连接。

注意到后。connect（）最终服从于ConnectionProvider。acquire（），我尝试使用tcpClient。connect（），但有必要更改方法返回类型，如下所示：

public Mono<Mono<String>> sendMessage1(Mono<String> request) {
    return this.tcpClient
        .connect()
        .map(connection ->
            connection
                .outbound()
                .sendByteArray(request.map(String::getBytes))
                .then()
                .then(connection.inbound().receive().asString().as(Mono::from))
            );
}

显然这是不可取的。如何直接从池中获取Connection实例？我是否缺少一个简单的Mono运算符，或者我是否错误地使用了TcpClient API？

非常感谢任何帮助。

Answer 1

用平面地图代替地图怎么样？

public Mono<String> sendMessage1(Mono<String> request) {
    return this.tcpClient
            .connect()
            .flatMap(connection ->
                    connection
                            .outbound()
                            .sendByteArray(request.map(String::getBytes))
                            .then()
                            .then(connection.inbound().receive().asString().as(Mono::from))
            );
}