MQTT for UWP

Posted 2020-08-15 Yixin-Ran

老规矩，先简单介绍下MQTT：

　　MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是IBM开发的一个即时通讯协议，有可能成为物联网的重要组成部分。该协议支持所有平台，几乎可以把所有联网物品和外部连接起来，被用来当做传感器和致动器（比如通过Twitter让房屋联网）的通信协议，在未来几年，MQTT的应用会越来越广，值得关注。

通过MQTT协议，目前已经扩展出了数十个MQTT服务器端程序，可以通过php，JAVA，Python，C，C#等系统语言来向MQTT发送相关消息。

此外，国内很多企业都广泛使用MQTT作为android手机客户端与服务器端推送消息的协议。其中Sohu，Cmstop手机客户端中均有使用到MQTT作为消息推送消息。据Cmstop主要负责消息推送的高级研发工程师李文凯称，随着移动互联网的发展，MQTT由于开放源代码，耗电量小等特点，将会在移动消息推送领域会有更多的贡献，在物联网领域，传感器与服务器的通信，信息的收集，MQTT都可以作为考虑的方案之一。在未来MQTT会进入到我们生活的各各方面（摘自百度百科）。

　　很显然，UWP也是有MQTT的，要使用它需要安装M2Mqtt这个Nuget包。引用

　　　　using uPLibrary.Networking.M2Mqtt;
　　　　using uPLibrary.Networking.M2Mqtt.Messages;

Mqtt的使用非常简单，首先new 一个MqttClient，然后Connect，Subscribe订阅消息，此时就可以接受到你订阅的房间的消息了，可以通过Publish发布消息.

下面是具体实现：

      public void ConnMqtt()
        {
            string mqtthost = "your ip address";
            int mqttport = your port;
            string mqttServer = "your server";
            mc.Connect(mqttServer);
            //mc = new MqttClient(mqtthost,mqttport,false, MqttSslProtocols.None); 
            mc.MqttMsgPublishReceived += Mc_MqttMsgPublishReceived;
            try
            { 
                string clientId = Guid.NewGuid().ToString();
                mc.Connect(clientId);
                //mc.Connect(clientId,"username","password"); 
            }
            catch(Exception ex)
            {
                Debug.WriteLine(ex.Message);
            }
            SubscribeMqtt(new[] { "test" });  //订阅
        }
        public void SubscribeMqtt(string[] topics) //订阅
        {
            mc.Subscribe(topics, new[] { MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE });
        }
        public void PublishMqtt(string topic, string message) //发布，发布时自己也能收到消息
        {
            var v = mc.Publish(topic, Encoding.UTF8.GetBytes(message), MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE, true);
        }
        async private void Mc_MqttMsgPublishReceived(object sender, uPLibrary.Networking.M2Mqtt.Messages.MqttMsgPublishEventArgs e)
        {
            var msg = Encoding.UTF8.GetString(e.Message);
            await this.Dispatcher.RunAsync(Windows.UI.Core.CoreDispatcherPriority.Normal, () =>
            {
                ReciveTextBox.Text += msg + "\r\n";
            }); 
        }