Netty连接重试次数

Question

在Netty中重试连接

我正在构建一个客户端套接字系统。要求是：第一次尝试连接到远程服务器当第一次尝试失败时，继续尝试，直到服务器联机。

我想知道netty中是否有这样的功能来做这件事，或者我如何最好地解决这个问题。

非常感谢你

这是我正在纠结的代码片段:

protected void connect() throws Exception {

        this.bootstrap = new ClientBootstrap(new NioClientSocketChannelFactory(
                Executors.newCachedThreadPool(),
                Executors.newCachedThreadPool()));

        // Configure the event pipeline factory.
        bootstrap.setPipelineFactory(new SmpPipelineFactory());

        bootstrap.setOption("writeBufferHighWaterMark", 10 * 64 * 1024);
        bootstrap.setOption("sendBufferSize", 1048576); 
        bootstrap.setOption("receiveBufferSize", 1048576);
        bootstrap.setOption("tcpNoDelay", true);
        bootstrap.setOption("keepAlive", true);
        // Make a new connection.
        final ChannelFuture connectFuture = bootstrap
                .connect(new InetSocketAddress(config.getRemoteAddr(), config
                        .getRemotePort()));

        channel = connectFuture.getChannel();
        connectFuture.addListener(new ChannelFutureListener() {

            @Override
            public void operationComplete(ChannelFuture future)
                    throws Exception {
                if (connectFuture.isSuccess()) {
                    // Connection attempt succeeded:
                    // Begin to accept incoming traffic.
                    channel.setReadable(true);
                } else {
                    // Close the connection if the connection attempt has
                    // failed.
                    channel.close();
                    logger.info("Unable to Connect to the Remote Socket server");                   
                }

            }
        });
    }

Answer 1

谢谢布莱恩·罗奇连接的变量是易失性的，可以在代码或进一步处理之外访问。

final InetSocketAddress sockAddr = new InetSocketAddress(
                config.getRemoteAddr(), config.getRemotePort());
    final ChannelFuture connectFuture = bootstrap
            .connect(sockAddr);

    channel = connectFuture.getChannel();
    connectFuture.addListener(new ChannelFutureListener() {

        @Override
        public void operationComplete(ChannelFuture future)
                throws Exception {
            if (future.isSuccess()) {
                // Connection attempt succeeded:
                // Begin to accept incoming traffic.
                channel.setReadable(true);
                connected = true;
            } else {
                // Close the connection if the connection attempt has
                // failed.
                channel.close();                    
                if(!connected){
                    logger.debug("Attempt to connect within " + ((double)frequency/(double)1000) + " seconds");
                    try {
                        Thread.sleep(frequency);
                    } catch (InterruptedException e) {
                        logger.error(e.getMessage());
                    }   
                    bootstrap.connect(sockAddr).addListener(this);                                          
                }
            }

        }
    });

Answer 2

假设netty 3.x，最简单的例子是：

// Configure the client.
ClientBootstrap bootstrap = new ClientBootstrap(
        new NioClientSocketChannelFactory(
                Executors.newCachedThreadPool(),
                Executors.newCachedThreadPool()));


ChannelFuture future = null;

while (true)
{
    future = bootstrap.connect(new InetSocketAddress("127.0.0.1", 80));
    future.awaitUninterruptibly();
    if (future.isSuccess()) 
    {
        break;
    }
}

显然，您希望为设置最大尝试次数等的循环提供自己的逻辑。Netty 4.x 的引导程序略有不同，但逻辑是相同的。这也是同步的，阻塞的，并忽略中断的异常;在实际应用程序中，您可以向未来注册一个频道未来通知，并在未来完成时收到通知。

在OP编辑后添加问题:

您有一个正在收到通知的ChannelFutureListener。如果您想重试连接，您必须让该侦听器持有对引导程序的引用，或者向您的主线程传达连接尝试失败并让它重试操作。如果您让侦听器这样做（这是最简单的方法），请注意您需要限制重试次数以防止无限递归——它是在Netty工作线程的上下文中执行的。如果您再次用尽重试，您需要将其传达回主线程；您可以通过易失性变量来做到这一点，或者可以使用观察者模式。

在处理异步时，您必须同时思考。有很多方法可以剥那只猫的皮。