当前位置: 首页 > article >正文

.net 使用MQTT订阅消息

在nuGet下载M2Mqtt   V4.3.0版本。(支持.net framework)

订阅主题

public void LoadMQQCData()
{string enpoint = "xxx.xxx.x.x";//ip地址int port = 1883;//端口string user = "usrname";//用户名string pwd = "pwd";//密码string clientid = Guid.NewGuid().ToString(); // 获取一个独一无二的idstring[] topic = new string[] { "topic" };//订阅主题byte[] qosLevels = new byte[] { MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE }; // qos=1MqttClient client = new MqttClient(enpoint, port, false, null, null, MqttSslProtocols.None);//消息接受client.MqttMsgPublishReceived += new MqttClient.MqttMsgPublishEventHandler(messageReceive);//连接Brokerclient.Connect(clientid, user, pwd);client.Subscribe(topic, qosLevels);}

接收数据

static void messageReceive(object sender, MqttMsgPublishEventArgs e)
{Thread.Sleep(1000 * 30);//等待半分钟 等待质控数据入库//接收到的数据byte[] Bytes = e.Message;//获取站点编号try{string sstation = e.Topic.Substring(e.Topic.IndexOf("qc") - 10, 9);if (!string.IsNullOrEmpty(sstation) && sstation.Length == 9){ //代表该(SS4201089)站点做了质控do some things;}}catch (Exception ex){MessageServcie.Instance.OnShowMessageDelegate.Invoke("出错:" + ex.Message.ToString(), false);}}

http://www.lryc.cn/news/2403076.html

相关文章:

  • Python实现快速排序的三种经典写法及算法解析
  • 【递归、搜索与回溯】综合练习(四)
  • 强化学习入门:Gym实现CartPole随机智能体
  • STM32:CAN总线精髓:特性、电路、帧格式与波形分析详解
  • 贝叶斯深度学习!华科大《Nat. Commun.》发表BNN重大突破!
  • 【大模型LLM学习】Flash-Attention的学习记录
  • 三、元器件的选型
  • 精益数据分析(95/126):Socialight的定价转型启示——B2B商业模式的价格策略与利润优化
  • stm32_DMA
  • 物联网数据归档之数据存储方案选择分析
  • 【自动驾驶避障开发】如何让障碍物在 RViz 中‘显形’?呈现感知数据转 Polygon 全流程
  • 【C语言】C语言经典小游戏:贪吃蛇(上)
  • usbutils工具的使用帮助
  • vue2中使用jspdf插件实现页面自定义块pdf下载
  • 如何防止服务器被用于僵尸网络(Botnet)攻击 ?
  • 基于cornerstone3D的dicom影像浏览器 第二十九章 自定义菜单组件
  • 【Block总结】DBlock,结合膨胀空间注意模块(Di-SpAM)和频域模块Gated-FFN|即插即用|CVPR2025
  • 【学习笔记】单例类模板
  • 字符串加密(华为OD)
  • 口罩佩戴检测算法AI智能分析网关V4工厂/工业等多场景守护公共卫生安全
  • Double/Debiased Machine Learning
  • HarmonyOS Next 弹窗系列教程(4)
  • 【C】-递归
  • 飞马LiDAR500雷达数据预处理
  • Kerberos面试内容整理-在 Linux/Windows 中的 Kerberos 实践
  • 在 Allegro PCB Editor 中取消(解除或删除)已创建的 **Module** 的操作指南
  • 基于springboot的校园社团信息系统的设计与实现
  • nodejs里面的http模块介绍和使用
  • mamba架构和transformer区别
  • 嵌入式鸿蒙开发环境搭建操作方法与实现