.NET Core 跨平台物联网开发：设置委托事件(二)

时间 2019-11-30

标签 core 跨平台联网开发设置委托事件繁體版

原文原文链接

系列教程目录

(一) 链接阿里云IOT

(二) 设置委托事件

(三) 上报属性

(四) SDK文档属性、方法、委托、类

http://pan.whuanle.cn/index.php?dir=uploads/阿里云IOT/AliIOTXFclient-dll类库&responsephp

下载三个库，头部引入便可使用html

using AliIOTXFClient;

示例下载地址服务器

http://pan.whuanle.cn/index.php?dir=uploads/阿里云IOT/demo示例网络

本章示例 AliIOTXF.Tweide

生命周期

事件类型

目前只设置了五个委托事件post

XFMQTT.ConnectionClosedEventHandler 
XFMQTT.PubedEventHandler
XFMQTT.PubEventHandler
XFMQTT.SubedEventHandler
XFMQTT.UnSubedEventHandler

委托	说明
XFMQTT.PubEventHandler	订阅回调 - 当收到服务器消息时
XFMQTT.PubedEventHandler	当 QOS=1或2时，收到订阅触发
XFMQTT.SubedEventHandler	向服务器发布 Topic 时
XFMQTT.SubedEventHandler	向服务器发布 Topic 失败时
XFMQTT.ConnectionClosedEventHandler	断开链接

MQTT是一种可靠的消息推送协议，QOS保证了消息必须完整地推送给另外一端，关于QOS具体能够百度~this

QOS = 0 ，最多一次
QOS = 1，至少一次
QOS = 2，只有一次

表明消息推送地可靠程度，当 QOS = 1是，在网络波动等状况下，可能会存在屡次重复的一次推送。阿里云

使用默认的委托方法：

            // 使用默认的委托事件
            client.UseDefaultEventHandler();

经过上一篇文章，程序已经能够运行、链接到阿里云服务器，而且能够订阅发布消息。spa

这些操做都会触发事件，经过 UseDefaultEventHandler() 方法，使用的默认的方法绑定到事件。code

自定义事件方法

删除这一行代码

client.UseDefaultEventHandler();

头部引入

using uPLibrary.Networking.M2Mqtt.Messages;

注意，这五个委托方法的参数是不同的。

XFMQTT.PubEventHandler

订阅回调 - 当收到服务器消息时触发

委托方法以下

         委托方法(object sender, MqttMsgPublishEventArgs e)
        {

        }

MqttMsgPublishEventArgs 是与接收消息有关的对象，其属性以下：

        // message topic
        private string topic;
        // message data
        private byte[] message;
        // duplicate delivery
        private bool dupFlag;
        // quality of service level
        private byte qosLevel;
        // retain flag
        private bool retain;

SDK 默认的委托方法

        public void Default_PubEventHandler(object sender, MqttMsgPublishEventArgs e)
        {
            // handle message received
            string topic = e.Topic;
            string message = Encoding.ASCII.GetString(e.Message);
            Console.WriteLine("- - - - - - - - - - ");
            Console.WriteLine("get topic message,Date: " + DateTime.Now.ToLongTimeString());
            Console.WriteLine("topic: " + topic);
            Console.WriteLine("get messgae :\n" + message);
        }

那么咱们来写一个自定义委托方法

里面的怎么写都行，方法名称随意

        public static void 收到消息(object sender, MqttMsgPublishEventArgs e)
        {
            Console.WriteLine("topic名称："+e.Topic);
            Console.WriteLine("接收时间：" + DateTime.Now.ToLongDateString());
            Console.WriteLine("消息内容：\n"+Encoding.ASCII.GetString(e.Message));
        }

在删除 client.UseDefaultEventHandler(); 的位置加上

client.PubEventHandler += 收到消息;

XFMQTT.PubedEventHandler

当 QOS=1或2时，收到订阅触发

原型

委托方法(object sender, MqttMsgPublishedEventArgs e)
    {

    }

MqttMsgPublishedEventArgs 属性

        // message identifier
        ushort messageId;

        // published flag
        bool isPublished;

SDK 默认方法

        public void Default_PubedEventHandler(object sender, MqttMsgPublishedEventArgs e)
        {
            Console.WriteLine("- - - - - - - - - - ");
            Console.WriteLine("published,Date: " + DateTime.Now.ToLongTimeString());
            Console.WriteLine("MessageId: " + e.MessageId + "    Is Published: " + e.IsPublished);
        }

咱们来自定义写，方法名称随意

        public static void 重复收到消息(object sender, MqttMsgPublishedEventArgs e)
        {
            Console.WriteLine("接收时间: " + DateTime.Now.ToLongTimeString());
            Console.WriteLine("消息id: " + e.MessageId + "    Is Published: " + e.IsPublished);
        }

加上

client.PubedEventHandler += 重复收到消息;

XFMQTT.SubedEventHandler

向服务器发布 Topic 时触发

原型

void 发布消息时(object sender, MqttMsgSubscribedEventArgs e)

MqttMsgSubscribedEventArgs 属性

        /// <summary>
        /// Message identifier
        /// </summary>
        public ushort MessageId {get;set;}

        /// <summary>
        /// List of granted QOS Levels
        /// </summary>
        public byte[] GrantedQoSLevels{get;set;}

        // message identifier
        ushort messageId;
        // granted QOS levels
        byte[] grantedQosLevels;

SDK 默认写法

        public void Default_SubedEventHandler(object sender, MqttMsgSubscribedEventArgs e)
        {
            Console.WriteLine("- - - - - - - - - - ");
            Console.WriteLine("Sub topic,Date: " + DateTime.Now.ToLongTimeString());
            Console.WriteLine("MessageId: " + e.MessageId);
            Console.WriteLine("List of granted QOS Levels:    " + Encoding.UTF8.GetString(e.GrantedQoSLevels));
        }

咱们来自定义写，方法名称随意

        public static void 发布消息时(object sender, MqttMsgSubscribedEventArgs e)
        {
            Console.WriteLine("向服务器发送了消息");
            Console.WriteLine("发送时间: " + DateTime.Now.ToLongTimeString());
            Console.WriteLine("消息id: " + e.MessageId);
            Console.WriteLine("QOS 为 :    " + Encoding.UTF8.GetString(e.GrantedQoSLevels));
        }

加上

client.SubedEventHandler += 发布消息时;

XFMQTT.UnSubedEventHandler

向服务器发布 Topic 失败时触发

void 发送失败(object sender, MqttMsgUnsubscribedEventArgs )
{

}

MqttMsgUnsubscribedEventArgs 属性

        /// <summary>
        /// Message identifier
        /// </summary>
        public ushort MessageId
        {
            get { return this.messageId; }
            internal set { this.messageId = value; }
        }

SDK 写法

        public void Default_UnSubedEventHandler(object sender, MqttMsgUnsubscribedEventArgs e)
        {
            Console.WriteLine("- - - - - - - - - - ");
            Console.WriteLine("Sub topic error,Date: " + DateTime.Now.ToLongTimeString());
            Console.WriteLine("MessageId:    " + e.MessageId);
        }

咱们自定义写

        public static void 发送失败(object sender, MqttMsgUnsubscribedEventArgs e)
        {
            Console.WriteLine("消息发送失败 ");
            Console.WriteLine("时间: " + DateTime.Now.ToLongTimeString());
            Console.WriteLine("失败的消息 MessageId:    " + e.MessageId);
        }

加上

client.UnSubedEventHandler += 发送失败;

XFMQTT.ConnectionClosedEventHandler

断开链接时触发