netty长连接服务器断开后,客户端如何重新连接

0 0

netty长连接服务器断开后,客户端如何重新连接5

private static Bootstrap b = new Bootstrap();

public static void start() throws Exception {

    EventLoopGroup workerGroup = new NioEventLoopGroup();

    try {
// b = new Bootstrap(); // (1)
b.group(workerGroup); // (2)
b.channel(NioSocketChannel.class); // (3)
b.option(ChannelOption.SO_KEEPALIVE, true); // (4)
b.option(ChannelOption.ALLOW_HALF_CLOSURE,true);

        b.handler(new ChannelInitializer<SocketChannel>() {

            @Override
            protected void initChannel(SocketChannel ch) throws Exception {

                ChannelPipeline pipeline = ch.pipeline();

                // 以("\n")为结尾分割的解码器
                pipeline.addLast("framer", new DelimiterBasedFrameDecoder(Integer.MAX_VALUE, Delimiters.lineDelimiter()));

                // 字符串解码和编码
                pipeline.addLast("decoder", new StringDecoder());
                pipeline.addLast("encoder", new StringEncoder());

                // 自己的逻辑Handler
                pipeline.addLast("handler", new SimpleChannelInboundHandler() {

                    @Override
                    protected void channelRead0(ChannelHandlerContext channelHandlerContext, Object o) throws Exception {

                        logger.debug("接收到的状态内容：" + o.toString());

                    }

                    @Override
                    public void channelRegistered(ChannelHandlerContext ctx) throws Exception {

                        logger.debug("连接成功");
                    }

                    @Override
                    public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {

                    }

                    @Override
                    public void channelActive(ChannelHandlerContext ctx) throws Exception {

                        logger.debug("======channelActive========");
                    }

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

                        logger.debug("======channelInactive========");
                    }

                    @Override
                    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
                        logger.debug("======exceptionCaught========"+cause.getMessage());

                    }
                });

            }
        });
        // Start the client.
        ChannelFuture f = b.connect("127.0.0.1",8060).sync(); // (5)
        // Wait until the connection is closed.
        f.channel().closeFuture().sync();
    }finally{
            workerGroup.shutdownGracefully();
    }
}

netty

2014年5月26日 13:34

Q502691450
20
0 0 3

4个答案按时间排序按投票排序

0 0

ConnectionListener这个代码可否贴出，tkx

2014年10月17日 15:38

你好javaword
30
0 0 0

添加评论

0 0

前2天才实现了这个，后来整个设计又把长连接改成短连接..
就是短线重连，服务器重启的时候，等服务器启动好了，能让客户端重连上，对吧。
由于采用的是长连接，因此当connection断掉后，你client端的channelClosed是能感知到的。在这里写一个scheduleExecute，然后不断连接，直到成功。

长连接，就是不允许断，那么只要close你就去连就可以了

2014年5月26日 18:30

ccccccc2003
0
0 0 7

添加评论

0 0

 public class MyInboundHandler extends SimpleChannelInboundHandler {  
   private Client client;  
   public MyInboundHandler(Client client) {  
     this.client = client;  
   }  
   @Override  
   public void channelInactive(ChannelHandlerContext ctx) throws Exception {  
     final EventLoop eventLoop = ctx.channel().eventLoop();  
     eventLoop.schedule(new Runnable() {  
       @Override  
       public void run() {  
         client.createBootstrap(new Bootstrap(), eventLoop);  
       }  
     }, 1L, TimeUnit.SECONDS);  
     super.channelInactive(ctx);  
   }  
 } 
 
  public class Client  
 {  
   private EventLoopGroup loop = new NioEventLoopGroup();  
   public static void main( String[] args )  
   {  
     new Client().run();  
   }  
   public Bootstrap createBootstrap(Bootstrap bootstrap, EventLoopGroup eventLoop) {  
     if (bootstrap != null) {  
       final MyInboundHandler handler = new MyInboundHandler(this);  
       bootstrap.group(eventLoop);  
       bootstrap.channel(NioSocketChannel.class);  
       bootstrap.option(ChannelOption.SO_KEEPALIVE, true);  
       bootstrap.handler(new ChannelInitializer<SocketChannel>() {  
         @Override  
         protected void initChannel(SocketChannel socketChannel) throws Exception {  
           socketChannel.pipeline().addLast(handler);  
         }  
       });  
       bootstrap.remoteAddress("localhost", 8888);
       bootstrap.connect().addListener(new ConnectionListener(this)); 
     }  
     return bootstrap;  
   }  
   public void run() {  
     createBootstrap(new Bootstrap(), loop);
   }  
 }

2014年5月26日 14:43

bylijinnan
42
0 1 9