阿里云物联网 .NET Core 客户端 | CZGL.AliIoTClient:3. 订阅Topic与响应Topic

简介: CZGL.AliIoTClient 将 Topic 分为五种分别是:普通Topic、属性上报、属性下发、事件上报、服务调用,除了普通 Topic,每种 Topic 都有消息的发送、响应。 普通 Topic ,消息发送或,根据 MQTT 协议,SDK 严格保证消息能够到达另一端。

CZGL.AliIoTClient 将 Topic 分为五种

分别是:普通Topic、属性上报、属性下发、事件上报、服务调用,除了普通 Topic,每种 Topic 都有消息的发送、响应。

普通 Topic ,消息发送或,根据 MQTT 协议,SDK 严格保证消息能够到达另一端。
设备推送属性、事件等数据到服务器,则服务器要响应,
服务器推送(下发)数据到设备,则设备要响应。
当然,这些响应可有可无,无实质的影响。

每种、每个 Topic 都有特定的 MQTT 通讯地址,这些地址已经在 CZGL.AliIoTClient 中自动生成,你仅需填写普通 Topic 的通讯地址即可。


1) 订阅 Topic

订阅 Topic 前,需要在阿里云物联网定义相应的 Topic 以及设置 订阅 权限,
普通 Topic ,使用 string[] 包含列表,然后在调用连接方法时作为参数传入,亦可在连接服务器后,添加需要的订阅。
普通 Topic 可以动态添加,属于 热订阅 。

使用方法:

 // 设置要订阅的Topic、运行接收内容的Topic
            string[] topics = new string[] { 
                                client.CombineHeadTopic("get"),
                                "/a1xrkGSkb5R/mire/user/get1" };

            client.ConnectIoT(topics,null,60);

Topic 地址比较长,你可以记录 .../user/ 后的内容,使用 CombineHeadTopic() 可自动生成,

client.CombineHeadTopic("get") 

2)响应

当你使用属性、事件、服务功能,对服务器进行数据传输时,服务器会做出响应,你可以选择接收响应,也可以不接收响应。
CZGL.AliIoTClient 默认不接收服务器的响应信息。实际上这些响应信息一般只在调测时需要。

响应方法 说明
OpenEventPostReply() 接收上报事件后服务器的响应
OpenPropertyPostReply() 接收设备属性上传后服务器的响应
OpenServicePostRaw() 允许服务器调用服务 新版本已经取消这个设置
OpenPropertyDownPost() 允许服务器下发设置设备属性指令

注意,这些响应,必须在连接客户端前设置,并且在客户端已经连接后,不能再使用以上方法,否则会弹出异常。
已修复,你可以在程序的任意阶段打开接收功能,任意取消和打开。

查看这些功能是否打开:

public CZGL.AliIoTClient.OpenTopic getOpenTopic()

OpenTopic 具有 8 个属性,用于获取或设置是否打开某种功能的接收。

属性 说明 默认值
CommonTopic 是否接收普通Topic 固定为true,不能更改
PropertyUpRawReplyTopic 设备上传透传属性数据后服务器的响应 false
PropertyPostReplyTopic 设备上传Alink json属性数据后服务器的响应 false
PropertyDownRaw 服务器下发设置属性的命令,透传 false
PropertyDownPost 服务器下发设置属性的命令,Alink json false
EventUpRawReply 设备事件上报,接收服务器的响应,透传 false
EventPostReply 设备事件上报,接收服务器的响应,Alink json false
ServiceDownRaw 服务器调用服务,透传 false
ServicePostRaw 服务器调用服务,Alink json false

由于区分 透传 和 Alink json,若是透传,设置上面的 Alink json 项,是无效的,反之亦然。


3)连接服务器后


在连接服务器后,你还可以增加要订阅的普通 Topic:

public void TopicAdd(string[] topics, [byte[] QOS = null])

示例:

client.TopicAdd(new string[]{ client.CombineHeadTopic("get") })

移除已经订阅的 Topic:

public void TopicRemove(string[] topics)

在连接服务器后,可以取消接收服务器的响应信息,但是不能再重新接收。

方法 说明
CloseEventPostReply() 不再接收设备上传事件后服务器的响应
ClosePropertyPostReply() 不再接收设备上传属性后服务器的响应
CloseServicePostRaw() 不允许服务器下发调用设备服务的指令已删除此设置
ClosePropertyDownPost() 不允许服务器下发设置设备属性的指令

你可以在客户端连接服务器后,取消接收响应。但是,取消后,不能再订阅!
已修复,你可以在程序任意阶段取消后再打开接收。


4) Topic 说明

获取已经订阅的Topic列表:

public string[] GetSubedList { get; }

示例:

var topicList = client.GetSubedList;

服务器设置设备属性、调用服务等功能,由于采用 MQTT 通讯,是订阅/推送形式的,所以,无论什么功能的数据传输,本质还是Topic。
因此,那些设备属性上报、设置设备属性等,可以配置 Topic 属性。

CZGL.AliIoTClient 中,客户端可以订阅需要的 Topic,连接服务器后,服务器可以向所有 Topic 发送数据,但只有客户端指定订阅的 Topic,客户端才会接收到推送,不然无论在控制台怎么点击发送,客户端都是不会接收到的。

有个地方需要注意的是,对于普通Topic,是随客户端连接时的配置,决定服务器是否能够推送消息到客户端,动态的。

而属性、事件、服务这些功能,会保存上一次的配置。当你打开

client.OpenPropertyPostReply();

接收属性上传到服务器的响应后,在程序删除

client.OpenPropertyPostReply();

再次运行,依然会接收到响应,除非设置

client.ClosePropertyPostReply();

设备上传数据到服务器,服务器会做出响应,当然,服务器设置设备属性、调用设备服务时,客户端也可以做出响应。将在后面的章节讲述。

相关实践学习
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品,7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前,请先开通下方两个云产品,让学习更流畅: IoT物联网平台:https://iot.console.aliyun.com/ LinkWAN物联网络管理平台:https://linkwan.console.aliyun.com/service-open
目录
相关文章
|
4月前
|
消息中间件 安全 物联网
海量接入、毫秒响应:易易互联携手阿里云构筑高可用物联网消息中枢
面对换电生态高速发展的通信挑战,易易互联通过采用阿里云 MQTT + RocketMQ 的融合解决方案,成功构建了“海量接入、实时响应、弹性处理、安全可信”的物联网通信底座。该架构不仅显著提升了系统稳定性与可扩展性,更保障了高并发场景下的业务连续性,为实现“让换电成为营运补能第一选择”的战略目标提供了坚实的技术支撑。
270 39
|
8月前
|
物联网
(手把手)在华为云、阿里云搭建自己的物联网MQTT消息服务器,免费IOT平台
本文介绍如何在阿里云搭建自己的物联网MQTT消息服务器,并使用 “MQTT客户端调试工具”模拟MQTT设备,接入平台进行消息收发。
2904 42
|
10月前
|
存储 监控 安全
工业物联网关应用:PLC数据通过智能网关上传阿里云实战
本文介绍如何使用智能网关将工厂PLC数据传输至阿里云平台,适合中小企业远程监控设备状态。硬件准备包括三菱FX3U PLC、4G智能网关和24V电源。接线步骤涵盖PLC编程口与网关连接、运行状态检测及天线电源接入。配置过程涉及通讯参数、阿里云对接和数据点映射。PLC程序关键点包括数据上传触发和温度值处理。阿里云平台操作包含实时数据查看、数据可视化和规则引擎设置。最后提供常见故障排查表和安全建议,确保系统稳定运行。
965 1
|
11月前
|
物联网 数据挖掘 BI
基于阿里云物联网平台(IoT)的智能家居系统开发与部署
随着物联网技术的发展,智能家居成为提升生活品质的重要方向。阿里云物联网平台提供设备接入、数据管理及应用开发能力,支持亿级设备接入、高效数据管理和灵活应用开发,确保系统安全。本文通过实战案例展示如何基于该平台构建智能家居系统,涵盖设备接入、远程控制、场景联动与数据分析等功能,助力企业快速部署智能家居解决方案。
|
存储 边缘计算 物联网
阿里云物联网平台:推动万物互联的智能化解决方案
随着物联网技术的快速发展,阿里云物联网平台为企业提供了一体化的解决方案,包括设备接入、数据管理和智能应用等核心功能。平台支持海量设备接入、实时数据采集与存储、边缘计算,并具备大规模设备管理、高安全性和开放生态等优势。广泛应用于智能制造、智慧城市和智能家居等领域,助力企业实现数字化转型。
1577 5
|
移动开发 中间件 .NET
ASP.NET Core 2 学习笔记(三)中间件
原文:ASP.NET Core 2 学习笔记(三)中间件 之前ASP.NET中使用的HTTP Modules及HTTP Handlers,在ASP.NET Core中已不复存在,取而代之的是Middleware。
1091 56
|
开发框架 前端开发 .NET
ASP.NET Core 核心特性学习笔记「下」
ASP.NET Core 核心特性学习笔记「下」
|
开发框架 前端开发 中间件
ASP.NET Core 核心特性学习笔记「上」
ASP.NET Core 核心特性学习笔记「上」
|
SQL 机器学习/深度学习 Cloud Native
.NET 云原生架构师训练营(模块二 基础巩固 EF Core 更新和迁移)--学习笔记
- 状态 - 自动变更检测 - 不查询删除和更新 - 并发
340 0
.NET 云原生架构师训练营(模块二 基础巩固 EF Core 更新和迁移)--学习笔记
|
SQL Cloud Native 架构师
.NET 云原生架构师训练营(模块二 基础巩固 EF Core 查询)--学习笔记
- 关联数据加载 - 客户端与服务端运算 - 跟踪与不跟踪 - 复杂查询运算 - 原生 SQL 查询 - 全局查询筛选器
373 0
.NET 云原生架构师训练营(模块二 基础巩固 EF Core 查询)--学习笔记

相关产品

  • 物联网平台