C#编写MQTT客户端软件

        主要参考C#MQTT编程06--MQTT服务器和客户端(winform版)_c#mqttserver-CSDN博客

        但由于使用的.NET版本和MQTT库版本存在差异，因此有些不同。

        MQTT协议内容在此不做描述，仅介绍VS使用C#的实现过程。本次使用VS2015，.netframwork4.6。

        C#语言本身没有MQTT的库，当然你也可以利用TCP自行完成MQTT协议实现，一般我们采用第三方的mqtt库。

        新建一个winform项目，在解决方案资源管理器的“引用”右键，选择“管理Nuget程序包”，找到下面两个包并安装。注意，我这里用的版本是V3.0.0。

        接下来根据需要绘制窗体，添加控件。这里有两个按钮，一个连接MQTT服务器，一个是断开，然后就是订阅和发布相关的输入框和按钮。除此以外，我这边需要测试发布几条指令，做到下方的按钮里了，省的手动输入。

        接下来是代码

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Runtime;
using System.Windows.Forms;
using System.Threading.Tasks;using MQTTnet.Protocol;
using MQTTnet.Client;
using MQTTnet.Client.Options;
using MQTTnet.Extensions.ManagedClient;
using MQTTnet;namespace MQTT
{public partial class Form1: Form{private IManagedMqttClient mqttClient;private bool conFlag = false;private int timeout = 0;public Form1(){InitializeComponent();}private async void button1_Click(object sender, EventArgs e){var mqttclientOptions = new MqttClientOptionsBuilder().WithClientId("mushike").WithTcpServer("39.105.165.228", 1883).WithCredentials("admin", "admin");var options = new ManagedMqttClientOptionsBuilder().WithAutoReconnectDelay(TimeSpan.FromSeconds(5)).WithClientOptions(mqttclientOptions.Build()).Build();//开启await mqttClient.StartAsync(options);timer1.Enabled = true;timeout = 0;}private async void button2_Click(object sender, EventArgs e){if (mqttClient != null){if (mqttClient.IsStarted){await mqttClient.StopAsync();}timer1.Enabled = false;button1.BackColor = SystemColors.Control;}}private void Form1_Load(object sender, EventArgs e){var factory = new MqttFactory();mqttClient = factory.CreateManagedMqttClient();//创建客户端对象//绑定断开事件mqttClient.UseDisconnectedHandler(async ee =>{               // 等待 5s 时间await Task.Delay(TimeSpan.FromMilliseconds(500));WriteLog("\r\n与服务器之间的连接断开");conFlag = false;});//绑定接收事件mqttClient.UseApplicationMessageReceivedHandler(aa =>{try{string msg = aa.ApplicationMessage.ConvertPayloadToString();WriteLog("\r\n>> 收到主题：" + aa.ApplicationMessage.Topic  +  "，\r\n内容为：" + msg);//WriteLog(">>> 消息：" + msg + "，QoS =" + aa.ApplicationMessage.QualityOfServiceLevel + "，客户端=" + aa.ClientId + "，主题：" + aa.ApplicationMessage.Topic);}catch (Exception ex){WriteLog($"\r\n+ 消息 = " + ex.Message);}});//绑定连接事件mqttClient.UseConnectedHandler(ee =>{WriteLog("\r\n>> 连接到服务器成功");conFlag = true;});}private void WriteLog(string message){if(textBox1.InvokeRequired){textBox1.Invoke(new Action(() =>{textBox1.AppendText(message);}));}else{textBox1.AppendText(message);}}private void button3_Click(object sender, EventArgs e){if (conFlag == false)return;string topic = textBox2.Text;string message = textBox3.Text;mqtt_publish(topic, message);}private async void button4_Click(object sender, EventArgs e){if (conFlag == false)return;string topic = textBox4.Text;if (string.IsNullOrWhiteSpace(topic)){WriteLog("\r\n>> 请输入主题");return;}await mqttClient.SubscribeAsync(new TopicFilterBuilder().WithTopic(topic).WithAtMostOnceQoS().Build());//最多一次， QoS 级别0WriteLog($"\r\n>> 成功订阅");}private async void mqtt_publish(string topic,string message){if (conFlag == false)return;if (string.IsNullOrWhiteSpace(topic)){WriteLog("\r\n>> 请输入主题");return;}var result = await mqttClient.PublishAsync(topic,message,MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce);//恰好一次， QoS 级别1  WriteLog($"\r\n>> 主题：{topic}，\r\n消息：{message}，\r\n结果： {result.ReasonCode}");}private void textBox1_MouseDoubleClick(object sender, MouseEventArgs e){this.textBox1.Text = "";}private void timer1_Tick(object sender, EventArgs e){timeout++;if (conFlag == true){button1.BackColor = Color.Green;timer1.Enabled = false;}else{if (timeout > 30){timeout = 0;timer1.Enabled = false;WriteLog("\r\n>> 连接服务器失败");}}}private void button11_Click(object sender, EventArgs e){string topic = "test111";string message = "#01R00\r";mqtt_publish(topic, message);}private void button10_Click(object sender, EventArgs e){string topic = "test111";string message = "#01R01\r";mqtt_publish(topic, message);}private void button5_MouseDown(object sender, MouseEventArgs e){string topic = "test333";string message = "F10209100000000100000000E4";mqtt_publish(topic, message);}private void button5_MouseUp(object sender, MouseEventArgs e){string topic = "test333";string message = "F10209100000000000000000E5";mqtt_publish(topic, message);}private void button6_MouseDown(object sender, MouseEventArgs e){string topic = "test333";string message = "F10209100000000200000000E3";mqtt_publish(topic, message);}private void button6_MouseUp(object sender, MouseEventArgs e){string topic = "test333";string message = "F10209100000000000000000E5";mqtt_publish(topic, message);}private void button8_MouseDown(object sender, MouseEventArgs e){string topic = "test333";string message = "F10209100000000000020000E3";mqtt_publish(topic, message);}private void button8_MouseUp(object sender, MouseEventArgs e){string topic = "test333";string message = "F10209100000000000000000E5";mqtt_publish(topic, message);}private void button7_MouseDown(object sender, MouseEventArgs e){string topic = "test333";string message = "F10209100000000000040000E1";mqtt_publish(topic, message);}private void button7_MouseUp(object sender, MouseEventArgs e){string topic = "test333";string message = "F10209100000000000000000E5";mqtt_publish(topic, message);}private void button9_MouseDown(object sender, MouseEventArgs e){string topic = "test333";string message = "F10209100000000020000000C5";mqtt_publish(topic, message);}private void button9_MouseUp(object sender, MouseEventArgs e){string topic = "test333";string message = "F10209100000000000000000E5";mqtt_publish(topic, message);}}
}

         本次参照 C#MQTT编程06--MQTT服务器和客户端(winform版)_c#mqttserver-CSDN博客 编写MQTT相关的代码时，报了一堆错，本质原因还是版本不一致导致，比如使用参考博客的MQTTNet V3.0.15就用不了。因此需要特别注意，本次使用的环境为VS2015+.Net 4.6+MQTTNet V3.0.0。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/791348.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

SQL server 查询数据库中所有的表名及行数

SQL server 查询数据库中所有的表名及行数

SQL server 查询数据库中所有的表名及行数 select a.name,b.rows from sysobjects as ainner join sysindexes as bon a.id b.id where (a.type u)and (b.indid in (0, 1)) and b.rows<50 and b.rows>20 order by a.name, b.rows desc;
阅读更多...
Express框架搭建项目 node.js

Express框架搭建项目 node.js

文章目录 引言Express框架介绍express安装环境准备写一个简单的项目展示 文章总结 引言 Express是一个基于Node.js平台的轻量级Web应用框架&#xff0c;它提供了简洁的API和丰富的功能&#xff0c;使得开发者能够快速地构建Web服务器和API。本文将带领大家从零开始&#xff0c…
阅读更多...
GDAL源码剖析（六）之GDAL开发及其调试

GDAL源码剖析（六）之GDAL开发及其调试

GDAL源码剖析&#xff08;六&#xff09;之GDAL开发及其调试-CSDN博客 一、简单的调用 关于GDAL的使用&#xff0c;网上的资料都很多&#xff0c;主要还是要熟悉GDAL的组织结构&#xff0c;类以及类的函数等&#xff0c;熟悉了&#xff0c;使用GDAL就不在话下了。最常用的就是…
阅读更多...
苹果手表Apple Watch录了两个半小时的录音，却只能播放4秒，同步到手机也一样，还能修复好吗？

苹果手表Apple Watch录了两个半小时的录音，却只能播放4秒，同步到手机也一样，还能修复好吗？

好多人遇到这个情况&#xff0c;用苹果手表Apple Watch录音&#xff0c;有的录1个多小时&#xff0c;有的录了3、4小时&#xff0c;甚至更长时间&#xff0c;因为手表没电&#xff0c;忘记保存等原因造成录音损坏&#xff0c;都是只能播放4秒&#xff0c;同步到手机也一样&…
阅读更多...
JavaScript基础代码练习之冒泡排序

JavaScript基础代码练习之冒泡排序

一、要求对一个数组进行冒泡排序&#xff0c;并将排序后的结果输出到控制台。在代码中&#xff0c;数组 arr 包含了一组数字&#xff0c;然后使用嵌套的循环来进行冒泡排序。 二、编写代码 <!DOCTYPE html> <html lang"en"><head><meta chars…
阅读更多...
软件测试用例(2)

软件测试用例(2)

具体的设计方法 -- 黑盒测试 因果图 因果图是一种简化的逻辑图, 能直观地表明程序的输入条件(原因)和输出动作(结果)之间的相互关系. 因果图法是借助图形来设计测试用例的一种系统方法, 特别适用于被测试程序具有多种输入条件, 程序的输出又依赖于输入条件的各种情况. 因果图…
阅读更多...
深挖苹果Find My技术，伦茨科技ST17H6x芯片赋予产品功能

深挖苹果Find My技术，伦茨科技ST17H6x芯片赋予产品功能

苹果发布AirTag发布以来&#xff0c;大家都更加注重物品的防丢&#xff0c;苹果的 Find My 就可以查找 iPhone、Mac、AirPods、Apple Watch&#xff0c;如今的Find My已经不单单可以查找苹果的设备&#xff0c;随着第三方设备的加入&#xff0c;将丰富Find My Network的版图。产…
阅读更多...
fastadmin学习08-查询数据渲染到前端

fastadmin学习08-查询数据渲染到前端

index.php查询&#xff0c;这个是前台的index.php public function index() {$slideImgs Db::name("slideimg")->where("status",,normal)->limit(5)->order(sort,desc)->select();$productList Db::name("product")->where(…
阅读更多...
python的垃圾回收

python的垃圾回收

引用计数器为主&#xff0c;标记清除和分代回收为辅 1 引用计数器 在python程序运行时&#xff0c;会根据数据类型的不同找到其对应的结构体&#xff0c;根据结构体中的字段来进行创建相关的数据&#xff0c;然后将对象添加到refchain双像链表中&#xff0c;每个对象中的ob_re…
阅读更多...
Java中生成JWT令牌

Java中生成JWT令牌

1. 在pom.xml中引入依赖 <dependency><groupId>io.jsonwebtoken</groupId><artifactId>jjwt</artifactId><version>0.9.1</version> </dependency> 2. 使用Jwts的相关方法生成令牌 import io.jsonwebtoken.Jwts; import io.…
阅读更多...
【单片机家电产品学习记录--蜂鸣器】

【单片机家电产品学习记录--蜂鸣器】

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 单片机家电产品–蜂鸣器 前言 记录学习单片机家电产品内容 已转载记录为主 一、知识点 1电子电路学习笔记&#xff08;17&#xff09;——蜂鸣器 蜂鸣器种类和原理 2疑…
阅读更多...
虹科Pico汽车示波器 | 免拆诊断案例 | 2019款别克GL8豪华商务车前照灯水平调节故障

虹科Pico汽车示波器 | 免拆诊断案例 | 2019款别克GL8豪华商务车前照灯水平调节故障

一、故障现象 一辆2019款别克GL8豪华商务车&#xff0c;搭载LTG发动机&#xff0c;累计行驶里程约为10.7万km。车主反映&#xff0c;车辆行驶过程中组合仪表提示前照灯水平调节故障。 二、故障诊断 接车后试车&#xff0c;起动发动机&#xff0c;组合仪表上提示“前照灯水平…
阅读更多...
20.安全性测试与评估

20.安全性测试与评估

每年都会涉及&#xff1b;可能会考大题&#xff1b;多记&#xff01;&#xff01;&#xff01; 典型考点&#xff1a;sql注入、xss&#xff1b; 从2个方面记&#xff1a; 1、测试对象的功能、性能&#xff1b; 2、相关设备的工作原理&#xff1b; 如防火墙&#xff0c;要了解防…
阅读更多...
各类系统业务功能架构图整理

各类系统业务功能架构图整理

一、前言 很多软件系统一直经久不衰&#xff0c;主要这些系统都是一些生产工作经营不可或缺的系统。比如财务系统&#xff0c;商城系统&#xff0c;支付系统&#xff0c;供应链系统&#xff0c;人力资源管理系统&#xff0c;ERP系统等等。这些系统不管大公司还是小公司往往都需…
阅读更多...
海外媒体宣发:如何利用6种链游媒体宣发方式推广游戏-华媒舍

海外媒体宣发:如何利用6种链游媒体宣发方式推广游戏-华媒舍

在如今的游戏产业中&#xff0c;游戏宣发是非常重要的一环。而链游&#xff08;即以网游为主的游戏&#xff09;的媒体宣发方式在推广游戏中具有重要地位。本文将介绍6种链游媒体宣发方式&#xff0c;帮助游戏开发者和宣发人员更好地推广自己的游戏。 1. 游戏新闻稿 游戏新闻稿…
阅读更多...
【科研笔记】知识星球不可选择内容爬虫

【科研笔记】知识星球不可选择内容爬虫

知识星球不可选择内容爬虫 1 背景2 实现3 拓展遗留问题1 背景 针对与知识星球中，电脑打开网页不可选择复制粘贴的问题，进行爬虫处理，获取网页的内容，并保存在本地 2 实现 需要下载python，和爬虫的第三方库selenium，可以查看博客中有关selenium的内容进行回顾。当前使用…
阅读更多...
【多线程】震惊~这是我见过最详细的ReentrantLock的讲解

【多线程】震惊~这是我见过最详细的ReentrantLock的讲解

一.与synchronized相比ReentrantLock具有以下四个特点: 可中断&#xff1a;synchronized只能等待同步代码块执行结束&#xff0c;不可以中断&#xff0c;强行终断会抛出异常, 而reentrantlock可以调用线程的interrupt方法来中断等待&#xff0c;继续执行下面的代码。 在获取锁…
阅读更多...
Windows 禁用 Defender

Windows 禁用 Defender

原文&#xff1a;https://blog.iyatt.com/?p8078 2024.4.4 Windows 11 专业版 23H2 Beta 预览版 进入安全中心&#xff0c;关闭所有&#xff0c;特别是篡改防护选项 打开注册表 地址栏粘粘路径 计算机\HKEY_LOCAL_MACHINE\SOFTWARE\Policies\Microsoft\Windows Defende…
阅读更多...
【Clang+LLVM+honggfuzz学习】（二）honggfuzz的安装与试用

【Clang+LLVM+honggfuzz学习】（二）honggfuzz的安装与试用

书接上篇【ClangLLVMhonggfuzz学习】&#xff08;一&#xff09;LLVM简介、安装和第一个Hello Pass 本篇介绍honggfuzz的安装与简单使用 本文架构&#xff0c;PS:可选择观看哦 前言git安装试用编写测试文件demo.c设置环境变量开始fuzzFuzz-ing疑问 前言 漏洞检测做毕设&#…
阅读更多...
Spark 的结构化 APIs——RDD，DataFrame, Dataset, SparkSQL 使用和原理总结

Spark 的结构化 APIs——RDD，DataFrame, Dataset, SparkSQL 使用和原理总结

文章目录 前言RDD的底层是什么?结构化 Spark主要优点和好处 DataFrame APISpark的基本数据类型Spark的结构化和复杂数据类型Schemas 和创建 DataFramesColumns 和 ExpressionsRows通用的 DataFrame 算子 The Dataset API有类型 Objects、无类型 Objects 和通用 Rows创建 Datas…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023