netty维护连接以及如何通知channelfuture失败

Question

我正在尝试在客户端中创建一个while循环，该循环试图维护到服务器多个连接。当通道处理程序从服务器得到某些响应（错误）时，它应该关闭该通道并将该通道标记为future Failed。

Channel channel = this.channelPool.acquire().syncUninterruptibly().getNow();
// release channel when closed to unblock creating new channel.
channel.closeFuture().addListener((ChannelFutureListener) future -> {
    // not success wait and retry
    if(!future.isSuccess()){
         trySleep();
    }
    // close normally, no error, release so can create another connection immediately
    this.channelPool.release(future.channel());
});

null

这个例子是保持一个连接的好方法。但它需要单例，这是我想避免的。谢谢！

Answer 1

只是使用ChannelAttribute传递信息。

ctx.channel().attr(OneAttribute).set(true);
ctx.close();

然后

channel.closeFuture().addListener((ChannelFutureListener) future -> {
// not success wait and retry
if(future.channel().attr(OneAttribute) == some value){
     trySleep();
}
// close normally, no error, release so can create another connection immediately
this.channelPool.release(future.channel());