C# Mqtt 断线重连的实现代码

在通过 mqttclient 客户端连接之后，在服务端服务重启时，客户端如果没有重连机制，则无法再接收到订阅的消息。

使用的 mqtt 组件为：m2mqtt.net.dll

一些特性发现

（1）如果提供的服务端地址是不可解析的，会引发异常无法实例化 mqttclient 对象。
（2）connect 无法连接时会引发异常，isconnected 为 false。
（3）服务端断开会触发客户端的 connectionclosed 事件，isconnected 为 false。
（4）重新 connect 需要重新 subscribe 订阅主题。
（5）mqttclient.subscribe 第一个参数为订阅主题数组，第二个为相应的 qoslevel，两个数组长度必须一致，否则会异常。

重连流程控制

主要代码实现

（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);
      }

      // 如果还没连接不符合结束条件则睡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）尝试连接部分

// 发起一次连接，连接成功则订阅相关主题 
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 });
  }
}

实测效果不错，其中延时时间可以适当调整。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。