c# winform MQTT客户端实例

【实例简介】

    比较实用的客户端测试工具

【实例截图】

【核心代码】

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using uPLibrary.Networking.M2Mqtt;
using uPLibrary.Networking.M2Mqtt.Messages;
using System.Threading;

namespace StdioMQTT
{
    public partial class FrmMain : Form
    {
        private MqttClient mqttClient;
        public FrmMain()
        {


            InitializeComponent();
        }

        private void FrmMain_Load(object sender, EventArgs e)
        {
            this.txtClientId.Text = Guid.NewGuid().ToString();
            this.txtServer.Text = "3gssubw.mqtt.iot.gz.baidubce.com";
           //  this.txtServer.Text = "1wizgc5.mqtt.iot.gz.baidubce.com";

            txtSubscribe.Text = "/client/pub/42012";
            txtPublishTopic.Text = "/client/pub/42012";
        }

        private void btnConnect_Click(object sender, EventArgs e)
        {
            if (this.mqttClient != null)
            {
                List<string> lst = new List<string>();
                foreach(SubscribeModel model in this.lstSubscribeTopic.Items)
                {
                    lst.Add(model.Topic);
                }
          //      this.lstSubscribeTopic.Items.Clear();
                if (lst.Count > 0)
                {
                    ushort us = this.mqttClient.Unsubscribe(lst.ToArray());
                }
                this.mqttClient.Disconnect();
            }
           // this.mqttClient = new MqttClient(this.txtServer.Text);
            
                mqttClient = new MqttClient(this.txtServer.Text,
                                              1884,
                                              true, // 开启TLS
                                              MqttSslProtocols.TLSv1_0, // TLS版本
                                              null,
                                              null
                                             );
                mqttClient.ProtocolVersion = MqttProtocolVersion.Version_3_1;
            //  Console.WriteLine(Guid.NewGuid().ToString());
            byte success = mqttClient.Connect(this.txtClientId.Text,
                                          "3gssubw/park",//, "1wizgc5/park",
                                          "jP92bfHnd0LFQ6Ex",// "S7bSWctKFrp1c4K3"
                                            true, // cleanSession
                                            60); // keepAlivePeriod


            this.mqttClient.ConnectionClosed = MqttClient_ConnectionClosed;
            this.mqttClient.MqttMsgPublished = MqttClient_MqttMsgPublished;
            this.mqttClient.MqttMsgPublishReceived = MqttClient_MqttMsgPublishReceived;
            this.mqttClient.MqttMsgSubscribed = MqttClient_MqttMsgSubscribed;
            this.mqttClient.MqttMsgUnsubscribed = MqttClient_MqttMsgUnsubscribed;
          //  byte success = this.mqttClient.Connect(this.txtClientId.Text);
            if(success != 0 && this.mqttClient.IsConnected)
            {
                this.MsgBox("连接失败！");
                return;
            }
            this.btnConnect.Text = "断开连接";
         }

        private void MqttClient_ConnectionClosed(object sender, EventArgs e)
        {
          //  Console.WriteLine("连接关闭！");
            // Invoke => { async () => { this.MsgBox("连接关闭！")}};
            // ;
            this.Invoke(new EventHandler(delegate

            {

                this.MsgBox("连接关闭！");

            }));
        }

        private void MqttClient_MqttMsgUnsubscribed(object sender, MqttMsgUnsubscribedEventArgs e)
        {
            Action action = () => {
               for(int i = 0; i < this.lstSubscribeTopic.Items.Count; i )
                {
                    SubscribeModel subscribeModel = this.lstSubscribeTopic.Items[i] as SubscribeModel;
                    if(subscribeModel != null && subscribeModel.UnsubscribeId == e.MessageId)
                    {
                        this.lstSubscribeTopic.Items.Remove(subscribeModel);
                        break;
                    }
                }
            };
            this.Invoke(action);
        }

        private void MqttClient_MqttMsgSubscribed(object sender, MqttMsgSubscribedEventArgs e)
        {
            byte[] bys = e.GrantedQoSLevels;
            ushort messageId = e.MessageId;
        }

        private void MqttClient_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
        {
            byte[] bys = e.Message;
            string content = Encoding.UTF8.GetString(bys);
            string topic = e.Topic;
            bool dupFlag = e.DupFlag;
            byte qosLevel = e.QosLevel;
            bool retain = e.Retain;
            Action action = () => {
                this.rtbRecive.AppendText($"接收时间：{DateTime.Now}{Environment.NewLine}");
                this.rtbRecive.AppendText($"主题：{topic}{Environment.NewLine}");
                this.rtbRecive.AppendText($"内容：{content}{Environment.NewLine}");
                this.rtbRecive.Focus();
                this.rtbRecive.Select(this.rtbRecive.TextLength, 0);
                this.rtbRecive.ScrollToCaret();
            };
            this.Invoke(action);
            
        }

        private void MqttClient_MqttMsgPublished(object sender, MqttMsgPublishedEventArgs e)
        {
          
            ushort messageId = e.MessageId;

        }
        private void btnAddSubscribe_Click(object sender, EventArgs e)
        {
            if (!string.IsNullOrEmpty(this.txtSubscribe.Text))
            {
                for(int i = 0; i < this.lstSubscribeTopic.Items.Count; i )
                {
                    SubscribeModel subscribeModel = this.lstSubscribeTopic.Items[i] as SubscribeModel;
                    if(subscribeModel.Topic == this.txtSubscribe.Text)
                    {
                        this.MsgBox("主题重复了！");
                        return;
                    }
                }
                if (this.mqttClient != null)
                {
                    SubscribeModel subscribeModel = new SubscribeModel(this.txtSubscribe.Text, MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE);
                    subscribeModel.Subscribe(this.mqttClient);
                    this.lstSubscribeTopic.Items.Add(subscribeModel);
                }
            }
        }

        private void FrmMain_FormClosing(object sender, FormClosingEventArgs e)
        {
            this.mqttClient?. Disconnect();

           this.mqttClient.ConnectionClosed -= this.MqttClient_ConnectionClosed;
        }

        private void btnSendPublish_Click(object sender, EventArgs e)
        {
            string topic = this.txtPublishTopic.Text;
            string content = this.rtbSendPublish.Text;
            if(!string.IsNullOrEmpty(topic) && !string.IsNullOrEmpty(content))
            {
                byte[] bys = Encoding.UTF8.GetBytes(content);
                ushort? publishId = this.mqttClient?.Publish(topic, bys, MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE, false);
            }
        }

        private void btnClear_Click(object sender, EventArgs e)
        {
            this.rtbRecive.Clear();
        }

        private void lstSubscribeTopic_MouseDoubleClick(object sender, MouseEventArgs e)
        {
            SubscribeModel subscribeModel = this.lstSubscribeTopic.SelectedItem as SubscribeModel;
            if(subscribeModel != null)
            {
                subscribeModel.Unsubscribe(this.mqttClient);
            }
        }
    }
    /// <summary>
    /// 订阅
    /// </summary>
    public class SubscribeModel
    {
        public string Topic { get; set; }
        public byte Qos { get; set; }
        public ushort MessageId { get; set; }
        public ushort UnsubscribeId { get; set; }
        public SubscribeModel(string topic, byte qos)
        {
            this.Topic = topic;
            this.Qos = qos;
        }
        public void Subscribe(MqttClient mqttClient)
        {
            string[] topics = new string[] { this.Topic };
            byte[] qos = new byte[] { this.Qos };
            this.MessageId = mqttClient.Subscribe(topics, qos);

        }
        public void Unsubscribe(MqttClient mqttClient)
        {
            string[] topics = new string[] { this.Topic };
            this.UnsubscribeId = mqttClient.Unsubscribe(topics);
        }
        public override string ToString()
        {
            return $"主题：{this.Topic},质量：{this.Qos},消息ID:{this.MessageId}";
        }
    }
}