MQTTnet 3.0.5學習筆記

来源:https://www.cnblogs.com/ccsharppython/archive/2019/07/28/11261069.html
-Advertisement-
Play Games

段時間在使用MQTTnet，都說這個東西比較好,可是翻了翻網上沒有例子給參考一下。 今天算是找到了，給高手的帖子做個宣傳吧. 原網址如下：https://blog.csdn.net/chenlu5201314/article/details/94740765 由於GitHub上介紹的東西比較少，以我 ...


段時間在使用MQTTnet，都說這個東西比較好,可是翻了翻網上沒有例子給參考一下。

今天算是找到了，給高手的帖子做個宣傳吧.

原網址如下：https://blog.csdn.net/chenlu5201314/article/details/94740765

由於GitHub上介紹的東西比較少，以我的水平真是不知道怎麼用，先照葫蘆畫瓢，再看看怎麼回事吧：

功能：

把訂閱與發佈做成一個類，還帶有自動重連的功能

using System.Threading;　　　　
using System.Threading.Tasks;
using MQTTnet;　　　　　　　　　　
using MQTTnet.Client;　　　　　　//客戶端需要用到
using MQTTnet.Client.Options;  //具體連接時需要用到的屬性,ID的名稱,要連接Server的名稱,接入時用到的賬號和密碼,掉線時是否重新清除原有名稱,還有許多...
using MQTTnet.Packets;　　　　//這個沒用上
using MQTTnet.Protocol;　　  //這個也沒用上
using MQTTnet.Client.Receiving;　　　　//接收
using MQTTnet.Client.Disconnecting;　　//斷線
using MQTTnet.Client.Connecting;　　　　//連接

新建一個類：先寫一下變數和一些欄位

class HOSMQTT   
{        
private static MqttClient mqttClient = null;        
private static IMqttClientOptions options = null;        
private static bool runState = false;        
private static bool running = false;        
 /// <summary>        
/// 伺服器IP        
/// </summary>        
private static string ServerUrl = "182.61.51.85";        
/// <summary>        
/// 伺服器埠        
/// </summary>        
private static int Port = 61613;        
/// <summary>        
/// 選項 - 開啟登錄 - 密碼        
/// </summary>        
private static string Password = "ruichi8888";        
/// <summary>        
/// 選項 - 開啟登錄 - 用戶名        
/// </summary>        
private static string UserId = "admin";        
/// <summary>        
/// 主題        
/// <para>China/Hunan/Yiyang/Nanxian</para>        
/// <para>Hotel/Room01/Tv</para>        
/// <para>Hospital/Dept01/Room001/Bed001</para>        
/// <para>Hospital/#</para>        
/// </summary>        
private static string Topic = "China/Hunan/Yiyang/Nanxian";        
/// <summary>        
/// 保留        
/// </summary>        
private static bool Retained = false;       
 /// <summary>       
 /// 服務質量        
/// <para>0 - 至多一次</para>        
/// <para>1 - 至少一次</para>        
/// <para>2 - 剛好一次</para>        
/// </summary>        
private static int QualityOfServiceLevel = 0;
}

先看一下Start方法

public static void Start()
        {
            try
            {
                runState = true;
                Thread thread = new Thread(Work);　　　　//原帖中是這樣寫的 Thread thread = new Thread(new ThreadStart( Work));
                thread.IsBackground = true;
                thread.Start();
            }
            catch (Exception ex)
            {
                Console.WriteLine( "啟動客戶端出現問題:" + ex.ToString());
            }
        }

沒進入正題之前，先普及一下基本知識 

C#的ThreadStart 和 Thread  多線程，new Thread(t1);和new Thread(new ThreadStart(t1));沒有什麼區別.前者是.net的寫法，後者是C#的寫法

 

具體請看下麵的連接

https://www.cnblogs.com/rosesmall/p/8358348.html

進入整體，介紹連接方法 Work

private static void Work()
        {
            running = true;
            Console.WriteLine("Work >>Begin");
            try
            {
                var factory = new MqttFactory();　　　　　　　　//聲明一個MQTT客戶端的標準步驟 的第一步
                mqttClient = factory.CreateMqttClient() as MqttClient;  //factory.CreateMqttClient()實際是一個介面類型（IMqttClient）,這裡是把他的類型變了一下
                options = new MqttClientOptionsBuilder()　　　　//實例化一個MqttClientOptionsBulider
                    .WithTcpServer(ServerUrl, Port)
                    .WithCredentials(UserId, Password)
                    .WithClientId("XMan")
                    .Build();　　　　　　　　　　　　　　　　　　
                mqttClient.ConnectAsync(options);　　　　　　//連接伺服器
　　　　　　　　
　　　　　　　　　　//下麵這些東西是什麼，為什麼要這麼寫，直到剛纔我還是不懂，不過在GitHub的網址我發現了出處.
                mqttClient.ConnectedHandler = new MqttClientConnectedHandlerDelegate(new Func<MqttClientConnectedEventArgs, Task>(Connected));
                mqttClient.DisconnectedHandler = new MqttClientDisconnectedHandlerDelegate(new Func<MqttClientDisconnectedEventArgs, Task>(Disconnected));
                mqttClient.ApplicationMessageReceivedHandler = new MqttApplicationMessageReceivedHandlerDelegate(new Action<MqttApplicationMessageReceivedEventArgs>(MqttApplicationMessageReceived));
                while (runState)
                {

                    Thread.Sleep(100);

                }
            }
            catch(Exception exp)
            {

                Console.WriteLine(exp);
            }
            Console.WriteLine("Work >>End");

            running = false;

            runState = false;
        }

 

先來看看MqttClient 類裡面都有什麼東西

需要實現的介面，如何實現，說重點！

在GitHub上有個地方進去看看就知道了‘

 這個頁面的最下方寫著如何實現    https://github.com/chkr1011/MQTTnet/wiki/Upgrading-guide

private void Something()
{
    mqttClient.ApplicationMessageReceivedHandler = new MqttApplicationMessageReceivedHandlerDelegate(OnAppMessage);
    mqttClient.ConnectedHandler = new MqttClientConnectedHandlerDelegate(OnConnected);
    mqttClient.DisconnectedHandler = new MqttClientDisconnectedHandlerDelegate(OnDisconnected);
}

private async void OnAppMessage(MqttApplicationMessageReceivedEventArgs e)
{
}

private async void OnConnected(MqttClientConnectedEventArgs e)
{
}

private async void OnDisconnected(MqttClientDisconnectedEventArgs e)
{
}

在開始Connected方法之前有必要看一下關於同步和非同步的知識，

現學現賣簡單說一下：

Task就是非同步的調用，就在不影響主線程運行的另一個線程，但是他能像線程池一樣更高效的利用現有的空閑線程

async必須用來修飾Task ,void，或者Task<TResult>, await是等待非同步線程Task.Run()開始的後臺線程執行完畢。

記住要是Task 實現非同步功能，必須用 async 修飾，且async 與await成對出現。

詳見下麵大神寫的大作:https://www.cnblogs.com/doforfuture/p/6293926.html

下麵是什麼意思？

mqttClient.ConnectedHandler = new MqttClientConnectedHandlerDelegate(new Func<MqttClientConnectedEventArgs, Task>(Connected));

 

MqttClientConnectedHandlerDelegate 這個實例實現了mqttClient.ConnectedHandler介面

new Func<MqttClientConnectedEventArgs, Task>(Connected) ，

使用Func委托傳入MqttClientConnectedEventArgs類型的參數，返回的類型是Task,Task是一個類，這個類沒有返回值，如果有返回值就是Task<TResult>。

是委托就要帶一個方法取實現，這個方法就是Connected。

這句話的意思是，用MqttClientConnectedHandlerDelegate實現介面，同時使用委托取調用Connected的方法，並且給這個方法傳入一個MqttClientConnectedEventArgs參數，

這個委托的返回值是Task（就是不需要返回類型的非同步調用），這也就定義了Connected的類型必須是async Task。

好了來看下 Connected，這個函數什麼意思

就是與伺服器連接之後要乾什麼，訂閱一個Topic，或幾個Topic。連接之前已經連接了Connectasync(),如果斷線還會重連，後面會提到。

這個就連接之後需要做的事----訂閱！

        private static async Task Connected(MqttClientConnectedEventArgs e)
        {
            try
            {
                List<TopicFilter> listTopic = new List<TopicFilter>();
                if (listTopic.Count() <= 0)
                {
                    var topicFilterBulder = new TopicFilterBuilder().WithTopic(Topic).Build();
                    listTopic.Add(topicFilterBulder);
                    Console.WriteLine("Connected >>Subscribe " + Topic);
                }                await mqttClient.SubscribeAsync(listTopic.ToArray());
                Console.WriteLine("Connected >>Subscribe Success");
            }
            catch (Exception exp)
            {
                Console.WriteLine(exp.Message);
            }
        }

TopicFilter是一個Topic詳細信息的類

 

 掉線的發生時會執行這個函數

private static async Task Disconnected(MqttClientDisconnectedEventArgs e)
        {
            try
            {
                Console.WriteLine("Disconnected >>Disconnected Server");
                await Task.Delay(TimeSpan.FromSeconds(5));
                try
                {
                    await mqttClient.ConnectAsync(options);
                }
                catch (Exception exp)
                {
                    Console.WriteLine("Disconnected >>Exception " + exp.Message);
                }
            }
            catch (Exception exp)
            {
                Console.WriteLine(exp.Message);
            }
        }

越寫問題越多，這個為什麼斷線的時候會執行這個方法，這不是事件，只是介面！

怎麼實現的？看了一下源碼，一時只看了大概，這些功能的綁定都是在ConnectAsync的時候就完成了！

 

下麵接收到消息的時候

        /// <summary>
        /// 接收消息觸發事件
        /// </summary>
        /// <param name="e"></param>
        private static void MqttApplicationMessageReceived(MqttApplicationMessageReceivedEventArgs e)
        {
            try
            {
                string text = Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
                string Topic = e.ApplicationMessage.Topic; string QoS = e.ApplicationMessage.QualityOfServiceLevel.ToString();
                string Retained = e.ApplicationMessage.Retain.ToString();
                Console.WriteLine("MessageReceived >>Topic:" + Topic + "; QoS: " + QoS + "; Retained: " + Retained + ";");
                Console.WriteLine("MessageReceived >>Msg: " + text);
            }
            catch (Exception exp)
            {
                Console.WriteLine(exp.Message);
            }
        }

 

 最後就是發佈：一般會選擇0，如果選擇其他的情況在訂閱端不在的時候，伺服器可能會崩潰

/// <summary>       
        /// /// 發佈        
        /// <paramref name="QoS"/>        
        /// <para>0 - 最多一次</para>        
        /// <para>1 - 至少一次</para>        
        /// <para>2 - 僅一次</para>        
        /// </summary>       
        /// <param name="Topic">發佈主題</param>        
        /// <param name="Message">發佈內容</param>        
        /// <returns></returns>        
        public static void Publish( string Topic,string Message)
        {
            try
            {
                if (mqttClient == null)
                    return;
                if (mqttClient.IsConnected == false)
                    mqttClient.ConnectAsync(options);
                if (mqttClient.IsConnected == false)
                {
                    Console.WriteLine("Publish >>Connected Failed! ");
                    return;
                }
                Console.WriteLine("Publish >>Topic: " + Topic + "; QoS: " + QualityOfServiceLevel + "; Retained: " + Retained + ";");
                Console.WriteLine("Publish >>Message: " + Message);
                MqttApplicationMessageBuilder mamb = new MqttApplicationMessageBuilder()                 
                    .WithTopic(Topic)                 
                    .WithPayload(Message).WithRetainFlag(Retained);
                if (QualityOfServiceLevel == 0)
                {
                    mamb = mamb.WithAtMostOnceQoS();
                }
                else if (QualityOfServiceLevel == 1)
                {
                    mamb = mamb.WithAtLeastOnceQoS();
                }
                else if (QualityOfServiceLevel == 2)
                {
                    mamb = mamb.WithExactlyOnceQoS();
                }
                mqttClient.PublishAsync(mamb.Build());
            }
            catch (Exception exp)
            {
                Console.WriteLine("Publish >>" + exp.Message);
            }
        }

 

 

 

 紙上得來終覺淺，要改造成自己想要的些東西，還要花些功夫！不過這已經很好了！謝謝各位高手的貢獻

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 【Python基礎】09_Python中的元組
    1.元組的定義 Tuple (元組)與列表類似，元組的元素 不能修改 元組通常保存 不同類型 的數據 元組用()定義 info_tuple = ("張三"， 18， 1.75) 定義 元組名 = (元素1, 元素2, 元素3) 2.元組的創建 空元組 元組名 = () ，很少使用，因為定義後，元組無 ...
  • python學習-tuple
    # 元組。關鍵字：tuple# 定義好了，就不可以修改。只能讀。數據之間全部都是用,隔開。# 定義：()my_tuple = () # 空元組my_tuple2 = ("xj","female",18,170)# 定義方式二my_tuple3 = "hello","python","class17" ...
  • python元類深入理解
    1.python 中的類 在python中，類也是一個對象，只不過這個對象擁有生成實例的能力，我們一般使用class XXX來定義一個類，在python解釋器執行到這個地方的時候會自動創建出這個對象，python也為我們提供了手動創建類的方法，type()。type()這個方法對我們來說並不陌生，我 ...
  • Django -- 多表操作
    表之間的關係 一對一 xx=models.OneToOneField(to='要關聯的表名',to_field='要關聯表名的欄位',on_delete=models.CASCADE) # on_delete 刪除時的一些級聯效果,to_field可以不用寫,預設是關聯到另一張表的主鍵,on_fie ...
  • 【Python基礎】07_Python中的模塊
    1.模塊的概念 模塊 就好比 工具包，要想使用這個工具包中的工具，就需要 導入import 這個模塊 每一個以擴展名 .py 結尾的 Python源代碼文件 都是一個 模塊 在模塊中定義的 全局變數、函數 都是模塊能夠提供給外界直接使用的工具 註： 可以在模塊中定義 變數或者函數 模塊名也是一個標識 ...
  • MVC + EFCore 完整教程19-- 最簡方法讀取json配置：自定義configuration讀取配置文件
    問題引出： ASP.NET Core 預設將 Web.config移除了，將配置文件統一放在了 xxx.json 格式的文件中。 有Web.config時，我們需要讀到配置文件時，一般是這樣的： var value1= ConfigurationManager.ConnectionStrings["... ...
  • [VB.NET Tips]賦值運算千萬要註意
    賦值運算符是一個語句，不能在表達式中使用，表達式中的等號表示相等而不是賦值。 上示例： 在這個例子中，第一條語句將5賦給x，第二條語句中，第一個等號是賦值。而第二個等號是相等。 因此該語句首先計算x是否等於5，然後把結果(True)賦給變數y。 這個一定要註意，不然的話，在代碼可能會出現無法捕獲的副 ...
  • .NET Core CSharp初級篇 1-8泛型、逆變與協變
    .NET Core CSharp 初級篇 1 8 本節內容為泛型 為什麼需要泛型 泛型是一個非常有趣的東西，他的出現對於減少代碼復用率有了很大的幫助。比如說遇到兩個模塊的功能非常相似，只是一個是處理int數據，另一個是處理string數據，或者其他自定義的數據類型，但我們沒有辦法，只能分別寫多個方法 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類