我的MQTT操作类(M2Mqtt.Net)

2023-11-09 09:22
文章标签 操作 net mqtt m2mqtt

本文主要是介绍我的MQTT操作类(M2Mqtt.Net),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

类本体
4.3.0

public   class MQTTMain{public   MqttClient mqttClient =null ; public   bool MQTTMainConnect(string MenZuNo, string ServerIP, int ServerPort, string UserName, string Pwd){try{string EMQX_CLIENT_ID = $"称重端-{MenZuNo}-{OPCommon.PCControl.GetPCInfos.GetMachineName()}";mqttClient = new MqttClient(ServerIP, ServerPort, false, null, null, MqttSslProtocols.None);mqttClient.Connect(EMQX_CLIENT_ID, UserName, Pwd);//需要录入账号密码return true; }catch (Exception ex){OPCommon.LogWrite.WriteLog("MQTT链接错误,信息是:"+ex.Message);return false;} }/// <summary>/// 发布主题/// </summary>/// <param name="MenZuNo"></param>/// <param name="ServerIP"></param>/// <param name="ServerPort"></param>/// <param name="UserName"></param>/// <param name="Pwd"></param>/// <returns></returns>public   bool MQTTMainPublish(string Zhuti, string MsgInfo ){try{mqttClient.Publish(Zhuti, System.Text.Encoding.UTF8.GetBytes(MsgInfo), MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, false);return true;}catch (Exception ex){OPCommon.LogWrite.WriteLog("MQTT发送错误,信息是:" + ex.Message);return false;}}

连接的应用

 /// <summary>/// MQTT链接重新连接/// </summary>public void ThisMQTTConntect(){if (ThisMQTTS.mqttClient == null || !ThisMQTTS.mqttClient.IsConnected){ThisMQTTS.MQTTMainConnect(GModel.MainSetupAll.BangNo, GModel.MainSetupAll.ServerIp, GModel.MainSetupAll.ServerPort, GModel.MainSetupAll.ServerUser, GModel.MainSetupAll.Pwd);}if (ThisMQTTS.mqttClient != null && ThisMQTTS.mqttClient.IsConnected){ThisMQTTS.mqttClient.MqttMsgPublishReceived += Client_MqttMsgPublishReceived;ThisMQTTS.mqttClient.ConnectionClosed += TryReconnectAsync;ThisMQTTS.mqttClient.Subscribe(new string[] { GModel.DingyueZhuti }, new byte[] { MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE });//订阅主题}}

断开重连:

 private void TryReconnectAsync(object sender, EventArgs ex){if (!ThisMQTTS.mqttClient.IsConnected && !IsThisClose){OPCommon.LogWrite.WriteLog($"{this.Name}当前断开");Thread.Sleep(2000);Thread retryThread = new Thread(new ThreadStart(delegate{OPCommon.LogWrite.WriteLog($"{this.Name}第一次重连");ThisMQTTConntect();if (!ThisMQTTS.mqttClient.IsConnected){OPCommon.LogWrite.WriteLog($"{this.Name}第二次重连!");Thread.Sleep(5000);ThisMQTTConntect();}else{OPCommon.LogWrite.WriteLog($"{this.Name}第一次重连成功!");}}));retryThread.Start();} } 

MQTT数据接受

/// <summary>///  MQTT操作/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void Client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e){//string topic = e.Topic.ToString();//主题内容string MsgFromMQTT = System.Text.Encoding.UTF8.GetString(e.Message);//数据内容}

发送数据

 if (ThisMQTTS.mqttClient != null && ThisMQTTS.mqttClient.IsConnected){ThisMQTTS.MQTTMainPublish(GModel.DingyueZhuti, SetToServer);OPCommon.LogWrite.WriteLog("数据发送成功:" + SetToServer);ChengzhongMainWath.Restart();}

这篇关于我的MQTT操作类(M2Mqtt.Net)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/375286

相关文章

Python调用Orator ORM进行数据库操作

《Python调用OratorORM进行数据库操作》OratorORM是一个功能丰富且灵活的PythonORM库,旨在简化数据库操作,它支持多种数据库并提供了简洁且直观的API,下面我们就... 目录Orator ORM 主要特点安装使用示例总结Orator ORM 是一个功能丰富且灵活的 python O

python使用fastapi实现多语言国际化的操作指南

《python使用fastapi实现多语言国际化的操作指南》本文介绍了使用Python和FastAPI实现多语言国际化的操作指南,包括多语言架构技术栈、翻译管理、前端本地化、语言切换机制以及常见陷阱和... 目录多语言国际化实现指南项目多语言架构技术栈目录结构翻译工作流1. 翻译数据存储2. 翻译生成脚本

0基础租个硬件玩deepseek,蓝耘元生代智算云|本地部署DeepSeek R1模型的操作流程

《0基础租个硬件玩deepseek,蓝耘元生代智算云|本地部署DeepSeekR1模型的操作流程》DeepSeekR1模型凭借其强大的自然语言处理能力,在未来具有广阔的应用前景,有望在多个领域发... 目录0基础租个硬件玩deepseek,蓝耘元生代智算云|本地部署DeepSeek R1模型,3步搞定一个应

轻松上手MYSQL之JSON函数实现高效数据查询与操作

《轻松上手MYSQL之JSON函数实现高效数据查询与操作》:本文主要介绍轻松上手MYSQL之JSON函数实现高效数据查询与操作的相关资料,MySQL提供了多个JSON函数,用于处理和查询JSON数... 目录一、jsON_EXTRACT 提取指定数据二、JSON_UNQUOTE 取消双引号三、JSON_KE

C++实现封装的顺序表的操作与实践

《C++实现封装的顺序表的操作与实践》在程序设计中,顺序表是一种常见的线性数据结构,通常用于存储具有固定顺序的元素,与链表不同,顺序表中的元素是连续存储的,因此访问速度较快,但插入和删除操作的效率可能... 目录一、顺序表的基本概念二、顺序表类的设计1. 顺序表类的成员变量2. 构造函数和析构函数三、顺序表

使用C++实现单链表的操作与实践

《使用C++实现单链表的操作与实践》在程序设计中,链表是一种常见的数据结构,特别是在动态数据管理、频繁插入和删除元素的场景中,链表相比于数组,具有更高的灵活性和高效性,尤其是在需要频繁修改数据结构的应... 目录一、单链表的基本概念二、单链表类的设计1. 节点的定义2. 链表的类定义三、单链表的操作实现四、

Python利用自带模块实现屏幕像素高效操作

《Python利用自带模块实现屏幕像素高效操作》这篇文章主要为大家详细介绍了Python如何利用自带模块实现屏幕像素高效操作,文中的示例代码讲解详,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1、获取屏幕放缩比例2、获取屏幕指定坐标处像素颜色3、一个简单的使用案例4、总结1、获取屏幕放缩比例from

通过prometheus监控Tomcat运行状态的操作流程

《通过prometheus监控Tomcat运行状态的操作流程》文章介绍了如何安装和配置Tomcat,并使用Prometheus和TomcatExporter来监控Tomcat的运行状态,文章详细讲解了... 目录Tomcat安装配置以及prometheus监控Tomcat一. 安装并配置tomcat1、安装

Python中操作Redis的常用方法小结

《Python中操作Redis的常用方法小结》这篇文章主要为大家详细介绍了Python中操作Redis的常用方法,文中的示例代码简洁易懂,具有一定的借鉴价值,有需要的小伙伴可以了解一下... 目录安装Redis开启、关闭Redisredis数据结构redis-cli操作安装redis-py数据库连接和释放增

Go语言利用泛型封装常见的Map操作

《Go语言利用泛型封装常见的Map操作》Go语言在1.18版本中引入了泛型,这是Go语言发展的一个重要里程碑,它极大地增强了语言的表达能力和灵活性,本文将通过泛型实现封装常见的Map操作,感... 目录什么是泛型泛型解决了什么问题Go泛型基于泛型的常见Map操作代码合集总结什么是泛型泛型是一种编程范式,允