其實重連機制並不是多麼多高深的技術，其實就是一個在客戶端做一個簡單的判斷，如果連線斷了，那麼就重新呼叫連線服務端的程式碼

當然，我們重連的動作肯定是發生在斷連之後發生的，我們可以在上篇的心跳機制的基礎上，簡單地修改一下客戶端的啟動程式碼就可以了：

我們在連線斷了之後，我們一般會在finally的方法中去釋放資源，這邊我們應該不去釋放資源，我們在finally裡面進行重連：

整個客戶端的程式碼如下：

1. package com.lyncc.netty.heartbeats;  
2. import java.util.concurrent.TimeUnit;  
3. import io.netty.bootstrap.Bootstrap;  
4. import io.netty.channel.ChannelFuture;  
5. import io.netty.channel.ChannelInitializer;  
6. import io.netty.channel.ChannelOption;  
7. import io.netty.channel.ChannelPipeline;  
8. import io.netty.channel.EventLoopGroup;  
9. import io.netty.channel.nio.NioEventLoopGroup;  
10. import io.netty.channel.socket.SocketChannel;  
11. import io.netty.channel.socket.nio.NioSocketChannel;  
12. import io.netty.handler.codec.string.StringDecoder;  
13. import io.netty.handler.codec.string.StringEncoder;  
14. import io.netty.handler.logging.LogLevel;  
15. import io.netty.handler.logging.LoggingHandler;  
16. import io.netty.handler.timeout.IdleStateHandler;  
17. publicclass HeartBeatsClient {  
18.     publicvoid connect(int port, String host) throws Exception {  
19.      // Configure the client.
20.         EventLoopGroup group = new NioEventLoopGroup();  
21.         ChannelFuture future = null;  
22.         try {  
23.             Bootstrap b = new Bootstrap();  
24.             b.group(group)  
25.              .channel(NioSocketChannel.class)  
26.              .option(ChannelOption.TCP_NODELAY, true)  
27.              .handler(new LoggingHandler(LogLevel.INFO))  
28.              .handler(new ChannelInitializer<SocketChannel>() {  
29.                  @Override
30.                  publicvoid initChannel(SocketChannel ch) throws Exception {  
31.                      ChannelPipeline p = ch.pipeline();  
32.                      p.addLast("ping", new IdleStateHandler(0, 4, 0, TimeUnit.SECONDS));  
33.                      p.addLast("decoder", new StringDecoder());  
34.                      p.addLast("encoder", new StringEncoder());  
35.                      p.addLast(new HeartBeatClientHandler());  
36.                  }  
37.              });  
38.             future = b.connect(host, port).sync();  
39.             future.channel().closeFuture().sync();  
40.         } finally {  
41. //          group.shutdownGracefully();
42.           if (null != future) {  
43.               if (future.channel() != null && future.channel().isOpen()) {  
44.                   future.channel().close();  
45.               }  
46.           }  
47.           System.out.println("準備重連");  
48.           connect(port, host);  
49.           System.out.println("重連成功");  
50.         }  
51.     }  
52.     /** 
53.      * @param args 
54.      * @throws Exception 
55.      */
56.     publicstaticvoid main(String[] args) throws Exception {  
57.         int port = 8080;  
58.         if (args != null && args.length > 0) {  
59.             try {  
60.                 port = Integer.valueOf(args[0]);  
61.             } catch (NumberFormatException e) {  
62.                 // 採用預設值
63.             }  
64.         }  
65.         new HeartBeatsClient().connect(port, "127.0.0.1");  
66.     }  
67. }  

伺服器控制檯：

客戶端：

好了，這樣就可以重連~這只是一個簡單的Demo，真實的生產場景用法可能並不是這樣的