怎么在C#中使用Mqtt實現(xiàn)一個斷線重連功能？針對這個問題，這篇文章詳細介紹了相對應(yīng)的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

創(chuàng)新互聯(lián)是一家專業(yè)提供師宗企業(yè)網(wǎng)站建設(shè),專注與網(wǎng)站制作、成都網(wǎng)站設(shè)計、H5建站、小程序制作等業(yè)務(wù)。10年已為師宗眾多企業(yè)、政府機構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)的建站公司優(yōu)惠進行中。

（1）如果提供的服務(wù)端地址是不可解析的，會引發(fā)異常無法實例化 MqttClient 對象。

（2）Connect 無法連接時會引發(fā)異常，IsConnected 為 false。
（3）服務(wù)端斷開會觸發(fā)客戶端的 ConnectionClosed 事件，IsConnected 為 false。
（4）重新 Connect 需要重新 Subscribe 訂閱主題。
（5）MqttClient.Subscribe 第一個參數(shù)為訂閱主題數(shù)組，第二個為相應(yīng)的 qosLevel，兩個數(shù)組長度必須一致，否則會異常。

重連流程控制

主要代碼實現(xiàn)

（1）線程主體

// 自動重連主體
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）實例化部分

// 實例化客戶端
private void _BuildClient()
{
  try
  {
    _MqttClient = new MqttClient(_MqttServer);
  }
  catch (Exception e)
  {
    Debug.WriteLine("build client error:" + e.Message);
    return;
  }

  // 消息到達事件綁定
  _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實現(xiàn)一個斷線重連功能問題的解答就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識。

分享題目：怎么在C#中使用Mqtt實現(xiàn)一個斷線重連功能
新聞來源：http://jinyejixie.com/article16/ppicgg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供商城網(wǎng)站、網(wǎng)站營銷、企業(yè)網(wǎng)站制作、網(wǎng)站設(shè)計、域名注冊、響應(yīng)式網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)