Nettyで切断された後に自動的にTCPサーバーに接続する方法

Question

netty NIOを使用してTCP接続を確立するシナリオがありますが、サーバーがダウンしたときに、 可用性リスナーをサーバーに接続する方法はありますか？

Answer 1

は、すぐに再接続または再接続タスクのスケジューリングを試みることによってchannelInactiveで反応するクライアントパイプラインの最初のものとして持つことができます。 Exponential Backoff library例はこちら

public class ReconnectionTask extends Runnable, ChannelFutureListener { 

    Channel previous; 

    public ReconnectionTask(Channel c) { 
     this.previous = c; 
    } 

    @Override 
    public void run() { 
     Bootstrap b = createBootstrap(); 
     b.remoteAddress(previous.remoteAddress()) 
      .connect() 
      .addListener(this); 
    } 

    @Override 
    public void operationComplete(ChannelFuture future) throws Exception { 
     if (!future.isSuccess()) { 
      // Will try to connect again in 100 ms. 
      // Here you should probably use exponential backoff or some sort of randomization to define the retry period. 
      previous.eventLoop() 
        .schedule(this, 100, MILLISECONDS); 
      return; 
     } 
     // Do something else when success if needed. 
    } 
} 

チェック：例えば

、

public class DisconnectionHandler extends ChannelInboundHandlerAdapter { 

    @Override 
    public void channelInactive(final ChannelHandlerContext ctx) throws Exception { 

    Channel channel = ctx.channel(); 

    /* If shutdown is on going, ignore */ 
    if (channel.eventLoop().isShuttingDown()) return; 

    ReconnectionTask reconnect = new ReconnectionTask(channel); 
    reconnect.run(); 
    } 

} 

ReconnectionTask

はこのようなものになるだろう。