C#版发布和订阅阿里云消息(Mqtt 物联网接入)

【实例简介】C# 阿里云物联网套件 MQTT 与 客户端设备相互通信示例源码

修改这三项为你的设备数据后 即可使用

        private static string productKey = "pk";
        private static string deviceName = "deviceName";
        private static string deviceSecret = "设备secret";

另外，本示例接入的是 iot-as-mqtt.cn-shanghai.aliyuncs.com，如果是其他地区的服务器，请酌情修改即可

【实例截图】

【核心代码】

using System;
using System.Text;
using uPLibrary.Networking.M2Mqtt;
using uPLibrary.Networking.M2Mqtt.Messages;

namespace MqttDemo
{
    class Program
    {
        private static string productKey = "pk";
        private static string deviceName = "deviceName";
        private static string deviceSecret = "设备secret";
        static void Main(string[] args)
        {
            Console.WriteLine("Hello World!");
            String subTopic = "/"   productKey   "/"   deviceName   "/get";
            String pubTopic = "/"   productKey   "/"   deviceName   "/update";
            var client=AliIotClient.getAliIotClient( productKey,  deviceName,  deviceSecret);
            client.MqttMsgPublishReceived  = Client_MqttMsgPublishReceived;
            client.MqttMsgPublished  = Client_MqttMsgPublished;
            client.MqttMsgSubscribed  = Client_MqttMsgSubscribed;
            client.MqttMsgUnsubscribed  = Client_MqttMsgUnsubscribed;

            client.Subscribe(new string[] { subTopic }, new byte[] { 0 });
            var strValue = "{\"hello\":\"world!\"}";
            client.Publish(pubTopic, Encoding.UTF8.GetBytes(strValue), MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, false);

            var xx=Console.ReadLine();
        }

        private static void Client_MqttMsgUnsubscribed(object sender, MqttMsgUnsubscribedEventArgs e)
        {
            //取消订阅成功后的通知事件
            Console.WriteLine("Unsubscribe Success");
        }

        private static void Client_MqttMsgPublished(object sender, MqttMsgPublishedEventArgs e)
        {
            //消息发布成功后通知的事件
            Console.WriteLine("Publish Success");
        }

        private static void Client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
        {
            //接收我订阅的消息
            Console.WriteLine("Received New Message From Topic(" e.Topic "):"  Encoding.UTF8.GetString(e.Message));
        }

        private static void Client_MqttMsgSubscribed(object sender, MqttMsgSubscribedEventArgs e)
        {
            //订阅成功后的通知事件
            Console.WriteLine("Subscribe Success");
        }



    }
}