在Netty IO中服务器停止服务请求后如何重新连接到服务器

Question

线程“main”io.netty.channel.abstractchannel$AnnotatedConnectException：连接被拒绝：无进一步信息：/127.0.0.1:8888在sun.nio.channel.checkConnect（本机方法）在sun.nio.channel.socketchannel.finishConnect（未知源）在io.netty.channel.socket.nio.nicketchannel.dofinishConnect（niosocketchannel.java:325)在原因：java.net.ConnectException：连接被拒绝：没有进一步信息...还有11个

下面的行是我的连接线程的运行部分。

EventLoopGroup group = new NioEventLoopGroup();
Bootstrap bootstrap = new Bootstrap();
bootstrap.group(group);
bootstrap.channel(NioSocketChannel.class).handler(new 
ChannelInitializer<SocketChannel>() {

        protected void initChannel(SocketChannel socketChannel) throws 
Exception {
            socketChannel.pipeline().addLast(new 
LengthFieldBasedFrameDecoder(64 * 1024, 0, 2));
            socketChannel.pipeline().addLast(ClientHandler);
        }

    });
    bootstrap.option(ChannelOption.SO_REUSEADDR,true);
    ChannelFuture channelFuture=null;
try 
{
    channelFuture = bootstrap.connect(new InetSocketAddress(IP, 
port)).sync();      
    channelFuture.awaitUninterruptibly();
    channelFuture.addListener(new ChannelFutureListener() {
        @Override
        public void operationComplete(ChannelFuture channelFuture)
         {
        try
        {
            if (channelFuture.isSuccess()) {
            if(connectfuture!=null) connectfuture.cancel(true);log.debug("Cancelled connection thread scheduler");

        } else {
            channelFuture.cause().printStackTrace();
        connectfuture=channelFuture.channel().eventLoop().scheduleAtFixedRate(new ClientConnectorThread(ClientHandler,IP,port) , 5,30, TimeUnit.SECONDS);
        }
        }
        catch(Exception ex)
        {
            ex.printStackTrace();
        }
        }
        } );

}

catch (InterruptedException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    }

Answer 1

当我想要实现重新连接逻辑时，我会按照以下方式执行

为捕获空闲状态的管道添加两个处理程序

pipeline.addLast(new ReadTimeoutHandler(readTimeout, TimeUnit.SECONDS));
pipeline.addLast("ReconnectionHandler", new ReconnectionHandler());

在reconnectionhandler捕获readtimeouthandler激发的用户事件中，断开通道并尝试重新连接

public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
    if (evt instanceof IdleStateEvent) {
        IdleStateEvent e = (IdleStateEvent) evt;
        if (e.state() == IdleState.READER_IDLE) {
            ctx.close();
        }
    } else {
        ctx.fireUserEventTriggered(evt);
    }
}

public void channelUnregistered(final ChannelHandlerContext ctx) throws Exception {
    final EventLoopGroup eventLoopGroup = ctx.channel().eventLoop().parent();
    eventLoopGroup.schedule(() -> {
        bootstrap.connect()
    }, reconnectDelay, TimeUnit.SECONDS);
    ctx.fireChannelUnregistered();
}