Netty Client重连实现

     
1
     
2
     
3
     
4
     
5
     
6
     
7
     
8
     
9
     
10
     
11
     
12
     
13
     
14
     
15
     
16
     
17
     
18
     
19
     
20
     
21
     
22
     
23
     
24
     
25
     
26
     
27
     
28

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

     
1
     
2
     
3
     
4
     
5
     
6
     
7
     
8
     
9
     
10
     
11
     
12
     
13
     
14
     
15
     
16
     
17
     
18
     
19

     
public class ConnectionListener implements ChannelFutureListener {  
     
  private Client client;  
     
  public ConnectionListener(Client client) {  
     
    this.client = client;  
     
  }  
     
  @Override  
     
  public void operationComplete(ChannelFuture channelFuture) throws Exception {  
     
    if (!channelFuture.isSuccess()) {  
     
      System.out.println("Reconnect");  
     
      final EventLoop loop = channelFuture.channel().eventLoop();  
     
      loop.schedule(new Runnable() {  
     
        @Override  
     
        public void run() {  
     
          client.createBootstrap(new Bootstrap(), loop);  
     
        }  
     
      }, 1L, TimeUnit.SECONDS);  
     
    }  
     
  }  
     
}

     
1
     
2
     
3
     
4
     
5
     
6
     
7
     
8
     
9
     
10
     
11
     
12
     
13
     
14
     
15
     
16
     
17

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