Netty斷線重連

最近使用Netty開發一個中轉服務，需要一直保持與Server端的連接，網絡中斷后需要可以自動重連，查詢官網資料，實現方案很簡單，核心思想是在channelUnregistered鈎子函數里執行重連。

創建連接

需要把configureBootstrap重構為一個函數，方便后續復用

1. EventLoopGroup group = new NioEventLoopGroup(); 

   ---

2. private volatile Bootstrap bootstrap; 

   ---

3.  

   ---

4. public void init(String host, int port) throws RobotException { 

   ---

5. this.serverIp = host; 

   ---

6. this.serverPort = port; 

   ---

7. try { 

   ---

8. // 創建並初始化 Netty 客戶端 Bootstrap 對象 

   ---

9. bootstrap = configureBootstrap(new Bootstrap(),group); 

   ---

10. bootstrap.option(ChannelOption.TCP_NODELAY, true); 

    ---

11. doConnect(bootstrap); 

    ---

12. } 

    ---

13. catch(Exception ex){ 

    ---

14. ex.printStackTrace(); 

    ---

15. throw new RobotException("connect remote control server error!",ex.getCause()); 

    ---

16. } 

    ---

17. } 

    ---

18.  

    ---

19. Bootstrap configureBootstrap(Bootstrap b, EventLoopGroup g) { 

    ---

20. b.group(g).channel(NioSocketChannel.class) 

    ---

21. .remoteAddress(serverIp, serverPort) 

    ---

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

    ---

23. @Override 

    ---

24. public void initChannel(SocketChannel channel) throws Exception { 

    ---

25. ChannelPipeline pipeline = channel.pipeline(); 

    ---

26. // 編解碼器 

    ---

27. pipeline.addLast(protoCodec); 

    ---

28. // 請求處理 

    ---

29. pipeline.addLast(RobotClient.this); 

    ---

30. } 

    ---

31. }); 

    ---

32.  

    ---

33. return b; 

    ---

34. } 

    ---

35.  

    ---

36. void doConnect(Bootstrap b) { 

    ---

37. try { 

    ---

38.  

    ---

39. ChannelFuture future = b.connect(); 

    ---

40. future.addListener(new ChannelFutureListener() { 

    ---

41. @Override 

    ---

42. public void operationComplete(ChannelFuture future) throws Exception { 

    ---

43. if (future.isSuccess()) { 

    ---

44. System.out.println("Started Tcp Client: " + serverIp); 

    ---

45. } else { 

    ---

46. System.out.println("Started Tcp Client Failed: "); 

    ---

47. } 

    ---

48. if (future.cause() != null) { 

    ---

49. future.cause().printStackTrace(); 

    ---

50. } 

    ---

51.  

    ---

52. } 

    ---

53. }); 

    ---

54. } catch (Exception e) { 

    ---

55. e.printStackTrace(); 

    ---

56. } 

    ---

57. } 

    ---

斷線重連

來看斷線重連的關鍵代碼：

1. @ChannelHandler.Sharable 

   ---

2. public class RobotClient extends SimpleChannelInboundHandler<RobotProto> { 

   ---

3. @Override 

   ---

4. public void channelUnregistered(ChannelHandlerContext ctx) throws Exception { 

   ---

5. // 狀態重置 

   ---

6. isConnected = false; 

   ---

7. this.serverStatus = -1; 

   ---

8.  

   ---

9. final EventLoop loop = ctx.channel().eventLoop(); 

   ---

10. loop.schedule(new Runnable() { 

    ---

11. @Override 

    ---

12. public void run() { 

    ---

13. doConnect(configureBootstrap(new Bootstrap(), loop)); 

    ---

14. } 

    ---

15. }, 1, TimeUnit.SECONDS); 

    ---

16. } 

    ---

17. } 

    ---

需要注意，Client類需要添加@ChannelHandler.Sharable注解，否則重連時會報錯

---

作者：Jadepeng
出處：jqpeng的技術記事本--http://www.cnblogs.com/xiaoqi
您的支持是對博主最大的鼓勵，感謝您的認真閱讀。
本文版權歸作者所有，歡迎轉載，但未經作者同意必須保留此段聲明，且在文章頁面明顯位置給出原文連接，否則保留追究法律責任的權利。