mqtt

參考 http://blog.csdn.net/leytton/article/details/51896738

 

一、引入M2MQTT的dll庫文件

點擊此處下載 

二、創建客戶端鏈接並訂閱

//建立客戶端實例
MqttClient client = new MqttClient(IPAddress.Parse(MQTT_BROKER_ADDRESS)); //主機爲IP時
MqttClient client = new MqttClient(MQTT_BROKER_ADDRESS); //當主機地址爲域名時

// 註冊消息接收處理事件，還能夠註冊消息訂閱成功、取消訂閱成功、與服務器斷開等事件處理函數
client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;

//生成客戶端ID並鏈接服務器
string clientId = Guid.NewGuid().ToString();
client.Connect(clientId);

// 訂閱主題"/home/temperature" 消息質量爲 2
client.Subscribe(new string[] { "/home/temperature" }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });

...

void client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
{
//處理接收到的消息
string msg = System.Text.Encoding.Default.GetString(e.Message);
        textBox1.AppendText("收到消息:" + msg + "\r\n");
}

 

三、發佈消息

// 發佈消息到主題 "/home/temperature" 消息質量爲 2,不保留
client.Publish("/home/temperature", Encoding.UTF8.GetBytes("hello"), MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, false);