netty 心跳与IdleStateHandler与断线重连

netty的心跳机制只是触发事件，但没有包心跳包，需要自己发心跳包

IdleStateHandler不是发心跳包，而是触发心跳机制，在你设定的时候内没有收到包，就触发读心跳，没有发包就触发写心跳，如果都没有，就触发all

参考
http://blog.csdn.net/albertfly/article/details/52182248
Netty Client重连实现

当我们用Netty实现一个TCP client时，我们当然希望当连接断掉的时候Netty能够自动重连。

Netty Client有两种情况下需要重连：

Netty Client启动的时候需要重连
在程序运行中连接断掉需要重连。

对于第一种情况，Netty的作者在stackoverflow上给出了 解决方案， 

对于第二种情况，Netty的例子uptime中实现了一种 解决方案。
而Thomas在他的 文章中提供了这两种方式的实现的例子。

实现ChannelFutureListener 用来启动时监测是否连接成功，不成功的话重试：

     

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

     

   }  

     

 }

ConnectionListener 负责重连：

     

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

     

    }  

     

  }  

     

}

同样在ChannelHandler监测连接是否断掉，断掉的话也要重连：

     

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

     

   }  

     

 }