Mqtt使用教程，簡介

時間 2019-11-18

標籤 mqtt 使用教程簡介简体版

原文原文鏈接

1，簡介

MQTT協議（Message Queuing Telemetry Transport），翻譯過來就是遙信消息隊列傳輸，是IBM公司於1999年提出的，如今最新版本是3.1.1。MQTT是一個基於TCP的發佈訂閱協議，設計的初始目的是爲了極有限的內存設備和網絡帶寬很低的網絡不可靠的通訊，很是適合物聯網通訊html

特色：前端

1輕量，java

2能夠在網絡差的環境中使用算法

3 使用發佈訂閱模式chrome

4遺囑apache

5消息有三種QOS(消息質量)（0只發布無論關心不收到，1最少收到一次，2確保收到一次，只一次）瀏覽器

愈來愈的的物聯網，互聯網應用在使用Mqtt協議，小黃車就是其中之一。能夠被用做即時通信，消息隊列，消息推送（智聯招聘企業版就使用mqtt作前端的消息推送）等等。各類語言的成熟庫都有。安全

總之就是很棒，應用很廣，未來會更廣。服務器

2 C#中使用Mqtt

Net也不少庫網絡

咱們這裏使用MQTTnet

using MQTTnet;
using MQTTnet.Client.Connecting;
using MQTTnet.Client.Disconnecting;
using MQTTnet.Client.Options;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Security.Cryptography;
using System.Text;
using System.Threading.Tasks;

namespace AliyunMqtt2
{
    class Program
    {

        static void Main(string[] args)
        {
    
            string CId = "1";                   //用戶標識ID
            String userName = "admin";         //用戶名
            String passWord = "password";          //密碼
            var will = new MqttApplicationMessage() { Topic = "lastwill", Payload = System.Text.Encoding.UTF8.GetBytes("我掉線了") };//定義遺囑消息



         
       

            IMqttClientOptions Option = new MqttClientOptionsBuilder().WithTcpServer("127.0.0.1", 61613)//地址端口號
          .WithClientId(CId)                                            //客戶端標識Id要惟一。
          .WithCredentials(userName, passWord)                          //用戶名,密碼
          .WithWillMessage(will)                                         //加上遺囑消息
           .WithCleanSession() 
           .Build();

            MqttFactory factory = new MqttFactory();
            var mqttClient = factory.CreateMqttClient();   //建立客戶端實例


            mqttClient.Connected += (object sender, MqttClientConnectedEventArgs e) =>         //鏈接成功
            {
                Console.WriteLine("鏈接成功:" + CId);


                var topics = new List<TopicFilter>();
                topics.Add(new TopicFilter() { Topic = "傢俱/#" });

                mqttClient.SubscribeAsync(topics);//訂閱
                Console.WriteLine("訂閱成功:");

                mqttClient.PublishAsync("傢俱/飲水機/加熱/10度", "10");//發佈
                Console.WriteLine("發佈成功");

            };
            mqttClient.Disconnected += (object sender, MqttClientDisconnectedEventArgs e) =>
            {
                Console.WriteLine("斷開鏈接:" + CId);


            };
            mqttClient.ApplicationMessageReceived += (object sender, MqttApplicationMessageReceivedEventArgs e) =>
            {
                ///收到消息
                string content = System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
                Console.WriteLine($"收到消息 msg={content}:");


            };
           
                mqttClient.ConnectAsync(Option);

         
            Console.ReadLine();
         
        }


    }
}