老規矩，先簡單介紹下MQTT： MQTT（Message Queuing Telemetry Transport，消息隊列遙測傳輸）是IBM開發的一個即時通訊協議，有可能成為物聯網的重要組成部分。該協議支持所有平臺，幾乎可以把所有聯網物品和外部連接起來，被用來當做感測器和致動器（比如通過Twitte ...
老規矩，先簡單介紹下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, MqttMsgPublishEventArgs e) { var msg = Encoding.UTF8.GetString(e.Message); await this.Dispatcher.RunAsync(Windows.UI.Core.CoreDispatcherPriority.Normal, () => { ReciveTextBox.Text += msg + "\r\n"; }); }
