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

2024-02-19 17:14:26

在通过 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 });
  }
}

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

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

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

在通过 MqttClient 客户端连接之后,在服务端服务重启时,客户端如果没有重连机制,则无法再接收到订阅的消息. 使用的 Mqtt 组件为:M2Mqtt.Net.dll 一些特性发现 (1)如果提供的服务端地址是不可解析的,会引发异常无法实例化 MqttClient 对象. (2)Connect 无法连接时会引发异常,IsConnected 为 false. (3)服务端断开会触发客户端的 ConnectionClosed 事件,IsConnected 为 false. (4)重新 Conn
java WebSocket客户端断线重连的实现方法

目录前言 Maven依赖代码前言在工作中是否会遇到实用websocket客户端连接服务端的时候,网络波动,服务端断连的情况.会导致客户端被动断开连接.为了解决这个问题,需要对被动断开连接的情况进行捕获,并重新创建连接.这篇文章主要是提供可以直接使用的断线重连websocket客户端代码. Maven依赖 <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</a
java文件重命名(文件批量重命名)实例程序代码分享

首先,查到java里文件重命名的方法为:renameTo(); 我将180张图片放在d:\\backup下,用下面的程序进行重命名: 复制代码代码如下: public void reName(){ String dir = "D:\\backup\\"; File file = new File(dir); String fileName[] = file.list(); int number = fileName.length
Spring boot 数据库连接断线重连问题

问题描述我正在做的这个项目,数据库是跨区并且不由自己管理的.防火墙会每隔一段时间就自动断开数据库连接. 于是需要对application.properties的datasource进行配置.Ps:我使用是mybatis连接数据库. 配置及具体含义 #初始化连接 spring.datasource.initial-size=10 #最大空闲连接 spring.datasource.max-idle=20 #最小空闲连接 spring.datasource.min-idle=5 #最大连接数量 s
Python实现树莓派WiFi断线自动重连的实例代码

实现 WiFi 断线自动重连.原理是用 Python 监测网络是否断线,如果断线则重启网络服务. 1.Python 代码 autowifi.py,放在 /home/pi 目录下: #!/usr/bin/python import os, time while True: if '192' not in os.popen('ifconfig | grep 192').read(): print '\n****** wifi is down, restart... ******\n' os.syst
文件夹取其名称前两位重命名的批处理代码

将所有文件夹取其名称前两位重命名的批处理脚本: 复制代码代码如下: @echo off& setlocal enableDelayedExpansion set n = 41029 for /f "delims=" %%a in ('dir /ad /b') do (set a=%%a ren "%%a" 41029!a:~0,2! ) pause 对以上代码的解释: 其中 /ad 是只显示目录,就是剔除文件,只显示文件夹. /b是使用空格式(没有标题信息
用python实现批量重命名文件的代码

下面是最终代码 (windows下实现的) 复制代码代码如下: # -*- coding: cp936 -*- import os path = 'D:\\图片\\' for file in os.listdir(path): if os.path.isfile(os.path.join(path,file))==True: if file.find('.')<0: newname=file+'rsfdjndk.jpg' os.rename(os.path.join(path,file),os
Vbs备份指定文件到指定目录并且以日期重命名的实现代码

说到备份,相信大家都会想到的第一个方法就是通过windows系统自带的window backup功能进行数据备份.后来微软又出了system centere产品后,就出现了一个新的备份产品---system centere data backup manager(DPM).这些功能备份比较大的数据还可以,但是对于小文件的备份有点浪费了,因为有的时候由于工作需要备份几个重要的文件(配置文件),不需要全备,所以说呢,很多备份软件有点浪费,对于小文件的备份来说不是非常方便.以上仅仅是个人的想法.我算是
批处理重命名系列案例代码

批处理用于文本/文件的操作确实非常简单有力!不用多么复杂的代码,仅一个记事本加上简洁的代码即可搞定大部分文本/文件的操作,下面记录下我用过的一些代码,基本都是我在百度回答知友的一些代码,既给涧客们参考,也让起到备忘的作用.... 案例一. 想把一个文件夹里的全部文件都命名成001,002--这样按顺序,什么顺序无所谓,只要名字都变了就行,谁帮忙写个我给出的代码: @echo off setlocal enabledelayedexpansion set var=1000 for /r "%~d
python文件名批量重命名脚本实例代码

python文件名批量重命名脚本 #encoding=utf-8 import cv2 import os import shutil base_dir = r'文件所在的文件夹路径' SourseDir1 = r'源文件1名' SourseDir2 = r'源文件2名' DestDir = r'IMG' DestSourseDir1NameDirPath = os.path.join(base_dir,DestDir) if not os.path.exists(DestSourseDir1N

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

相关推荐

随机推荐