Netty实战 IM即时通讯系统（五）客户端启动流程
生活随笔
收集整理的這篇文章主要介紹了
Netty实战 IM即时通讯系统（五）客户端启动流程
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
##
Netty實戰 IM即時通訊系統（五）客戶端啟動流程零、 目錄
- Netty 簡介
- Netty 環境配置
- 服務端啟動流程
- 實戰： 客戶端和服務端雙向通信
- 數據傳輸載體ByteBuf介紹
- 客戶端與服務端通信協議編解碼
- 實現客戶端登錄
- 實現客戶端與服務端收發消息
- pipeline與channelHandler
- 構建客戶端與服務端pipeline
- 拆包粘包理論與解決方案
- channelHandler的生命周期
- 使用channelHandler的熱插拔實現客戶端身份校驗
- 客戶端互聊原理與實現
- 群聊的發起與通知
- 群聊的成員管理（加入與退出，獲取成員列表）
- 群聊消息的收發及Netty性能優化
- 心跳與空閑檢測
- 總結
- 擴展
五、 客戶端啟動流程
客戶端啟動demo
/*** 客戶端啟動流程* */public class Test_05_客戶端啟動流程 {public static void main(String[] args) {NioEventLoopGroup workerGroup = new NioEventLoopGroup();Bootstrap bootstrap = new Bootstrap();bootstrap// 指定線程模型.group(workerGroup)// 指定IO 模型.channel(NioSocketChannel.class)// 指定業務處理邏輯.handler(new ChannelInitializer<NioSocketChannel>() {@Overrideprotected void initChannel(NioSocketChannel ch) throws Exception {}});// 建立連接bootstrap.connect("127.0.0.1" , 8000).addListener(future ->{if(future.isSuccess()) {System.out.println("連接成功");}else {System.out.println("連接失敗");}});}}失敗重連
在網絡差的情況下 ， 客戶端第一次連接可能會失敗 ， 這個時候我們可能會嘗試重新連接 ， 重新連接的邏輯寫在連接失敗的邏輯塊里
// 建立連接bootstrap.connect("127.0.0.1" , 8000).addListener(future ->{if(future.isSuccess()) {System.out.println("連接成功");}else {System.out.println("連接失敗");//TODO: 重新連接邏輯}});重新連接時依然是調用相同的邏輯 ， 所以我們把連接的代碼抽取出來， 實現代碼復用 ， 在連接失敗的情況下使用遞歸的方法 實現重連
public static void connect(Bootstrap bootstrap, String IP, int port) {// 建立連接bootstrap.connect(IP, port).addListener(future -> {if (future.isSuccess()) {System.out.println("連接成功");} else {System.out.println("連接失敗,執行重連");connect(bootstrap, IP, port);}});}以上代碼就實現了重連機制 ， 但是在通常情況下連接失敗不會立即重連 ， 而是通過一個指數退避的方式 ， 比如 每隔1秒、2秒、4秒、8秒 ， 以2的次冪來實現建立連接 ， 然后到達一定次數之后就放棄重連
connect(bootstrap , "127.0.0.1" , 8000 , 5);public static void connect(Bootstrap bootstrap, String IP, int port ,int maxRetry , int... retryIndex) {// 建立連接bootstrap.connect(IP, port).addListener(future -> {// 由于閉包特性 不能修改外部的變量 所有需要在閉包內定義一個相同的變量 拷貝外部變量的值int[] finalRetryIndex ;if (future.isSuccess()) {System.out.println("連接成功");} else if(maxRetry == 0){System.out.println("到達重試最大次數，放棄重連");}else {// 初始化 重試計數if(retryIndex.length == 0) {finalRetryIndex = new int[] {0};}else {finalRetryIndex = retryIndex;}//計算時間間隔int delay = 1 << finalRetryIndex[0];// 執行重試System.out.println(new Date()+"連接失敗,剩余重連次數:"+maxRetry+","+delay+"秒后執行第"+(finalRetryIndex[0]+1)+"次重連...");bootstrap.config().group().schedule(()->{connect(bootstrap, IP, port , maxRetry-1 , finalRetryIndex[0]+1);}, delay, TimeUnit.SECONDS);}});}執行結果：Thu Dec 27 11:04:19 CST 2018連接失敗,剩余重連次數:5,1秒后執行第1次重連...Thu Dec 27 11:04:21 CST 2018連接失敗,剩余重連次數:4,2秒后執行第2次重連...Thu Dec 27 11:04:24 CST 2018連接失敗,剩余重連次數:3,4秒后執行第3次重連...Thu Dec 27 11:04:29 CST 2018連接失敗,剩余重連次數:2,8秒后執行第4次重連...Thu Dec 27 11:04:38 CST 2018連接失敗,剩余重連次數:1,16秒后執行第5次重連...到達重試最大次數，放棄重連客戶端啟動其他方法
attr(): attr()方法可以給客戶端channel也就是NioSocketChannel綁定自定義屬性 ， 然后我們通過channel.attr()取出屬性。 說白了就是給NioSocketChannel維護一個Map 而已
//設置屬性bootstrap.attr(AttributeKey.newInstance("clientName"), "NettyClient");//業務邏輯bootstrap.handler(new ChannelInitializer<NioSocketChannel>() {@Overrideprotected void initChannel(NioSocketChannel ch) throws Exception {// 取出屬性Attribute<Object> attr = ch.attr(AttributeKey.valueOf("clientName"));System.out.println("客戶端名稱："+attr.get());}});option(): option()可以給連接設置一些TCP底層的相關屬性 ： (ChannelOption相關參數詳解在 上一節《服務端啟動流程》中有連接地址)
// 設置TCP 相關的屬性// 設置連接超時時間bootstrap.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5000);// 開啟TCP 心跳機制bootstrap.option(ChannelOption.SO_KEEPALIVE, true);總結：
疑問：
總結
以上是生活随笔為你收集整理的Netty实战 IM即时通讯系统（五）客户端启动流程的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： Netty实战 IM即时通讯系统（四）服
- 下一篇： Netty实战 IM即时通讯系统（六）实