开发笔记:Mqtt使用教程，简介

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();
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();

}
}
}