C#中Mqtt斷線怎么自動(dòng)重連

這篇文章主要介紹“C#中Mqtt斷線怎么自動(dòng)重連”，在日常操作中，相信很多人在C#中Mqtt斷線怎么自動(dòng)重連問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”C#中Mqtt斷線怎么自動(dòng)重連”的疑惑有所幫助！接下來，請跟著小編一起來學(xué)習(xí)吧！

在通過 MqttClient 客戶端連接之后，在服務(wù)端服務(wù)重啟時(shí)，客戶端如果沒有重連機(jī)制，則無法再接收到訂閱的消息。

使用的 Mqtt 組件為：M2Mqtt.Net.dll

一些特性發(fā)現(xiàn)

（1）如果提供的服務(wù)端地址是不可解析的，會(huì)引發(fā)異常無法實(shí)例化 MqttClient 對象。（2）Connect 無法連接時(shí)會(huì)引發(fā)異常，IsConnected 為 false。（3）服務(wù)端斷開會(huì)觸發(fā)客戶端的 ConnectionClosed 事件，IsConnected 為 false。（4）重新 Connect 需要重新 Subscribe 訂閱主題。（5）MqttClient.Subscribe 第一個(gè)參數(shù)為訂閱主題數(shù)組，第二個(gè)為相應(yīng)的 qosLevel，兩個(gè)數(shù)組長度必須一致，否則會(huì)異常。

重連流程控制

主要代碼實(shí)現(xiàn)

（1）線程主體

// 自動(dòng)重連主體private void _TryContinueConnect(){  if (IsConnected) return;  Thread retryThread = new Thread(new ThreadStart(delegate  {    while (_MqttClient == null || !_MqttClient.IsConnected)    {      if (_ToClose) break;      if (_MqttClient == null)      {        _BuildClient();        Thread.Sleep(3000);        continue;      }      try      {        _TryCount++;        _Connect();       }      catch (Exception ce)      {        Debug.WriteLine("re connect exception:" + ce.Message);      }      // 如果還沒連接不符合結(jié)束條件則睡2秒      if (!_MqttClient.IsConnected)      {        Thread.Sleep(2000);      }    }  }));        retryThread.Start();}

（2）實(shí)例化部分

// 實(shí)例化客戶端private void _BuildClient(){  try  {    _MqttClient = new MqttClient(_MqttServer);  }  catch (Exception e)  {    Debug.WriteLine("build client error:" + e.Message);    return;  }  // 消息到達(dá)事件綁定  _MqttClient.MqttMsgPublishReceived += client_MqttMsgPublishReceived;  // 連接斷開事件綁定  _MqttClient.ConnectionClosed += (sender, e) =>  {    if (!_ToClose)    {      // 嘗試重連      _TryContinueConnect();    }  };}

（3）嘗試連接部分

// 發(fā)起一次連接，連接成功則訂閱相關(guān)主題 private void _Connect(){  if (String.IsNullOrEmpty(_MqttUsername))  {    var b = _MqttClient.Connect(_MqttClientId);  }  else  {    var b = _MqttClient.Connect(_MqttClientId, _MqttUsername, _MqttUserpass);  }   if (_MqttClient.IsConnected)  {    _MqttClient.Subscribe(new string[] { "topic1", "topic2" },      new byte[] { MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE, MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE });  }}

到此，關(guān)于“C#中Mqtt斷線怎么自動(dòng)重連”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請繼續(xù)關(guān)注億速云網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)砀鄬?shí)用的文章！