2

在 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");                   
                }

            }
        });
    }
4

2 回答 2

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 的引导程序略有不同，但逻辑是相同的。这也是同步的、阻塞的和忽略的InterruptedException；在真正的应用程序中，您可能会向 注册 aChannelFutureListener并Future在完成时收到通知Future。

在 OP 编辑​​问题后添加：

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

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

于 2013-02-21T16:54:31.107 回答
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);                                          
                }
            }

        }
    });
于 2013-02-22T14:47:10.660 回答