阿里云物联网 .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();

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

相关实践学习
钉钉群中如何接收IoT温控器数据告警通知
本实验主要介绍如何将温控器设备以MQTT协议接入IoT物联网平台,通过云产品流转到函数计算FC,调用钉钉群机器人API,实时推送温湿度消息到钉钉群。
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品,7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前,请先开通下方两个云产品,让学习更流畅: IoT物联网平台:https://iot.console.aliyun.com/ LinkWAN物联网络管理平台:https://linkwan.console.aliyun.com/service-open
目录
相关文章
|
15天前
|
开发框架 .NET 开发者
简化 ASP.NET Core 依赖注入(DI)注册-Scrutor
Scrutor 是一个简化 ASP.NET Core 应用程序中依赖注入(DI)注册过程的开源库,支持自动扫描和注册服务。通过简单的配置,开发者可以轻松地从指定程序集中筛选、注册服务,并设置其生命周期,同时支持服务装饰等高级功能。适用于大型项目,提高代码的可维护性和简洁性。仓库地址:<https://github.com/khellang/Scrutor>
37 5
|
2月前
|
存储 开发框架 JSON
ASP.NET Core OData 9 正式发布
【10月更文挑战第8天】Microsoft 在 2024 年 8 月 30 日宣布推出 ASP.NET Core OData 9,此版本与 .NET 8 的 OData 库保持一致,改进了数据编码以符合 OData 规范,并放弃了对旧版 .NET Framework 的支持,仅支持 .NET 8 及更高版本。新版本引入了更快的 JSON 编写器 `System.Text.UTF8JsonWriter`,优化了内存使用和序列化速度。
|
1月前
|
开发框架 .NET C#
在 ASP.NET Core 中创建 gRPC 客户端和服务器
本文介绍了如何使用 gRPC 框架搭建一个简单的“Hello World”示例。首先创建了一个名为 GrpcDemo 的解决方案,其中包含一个 gRPC 服务端项目 GrpcServer 和一个客户端项目 GrpcClient。服务端通过定义 `greeter.proto` 文件中的服务和消息类型,实现了一个简单的问候服务 `GreeterService`。客户端则通过 gRPC 客户端库连接到服务端并调用其 `SayHello` 方法,展示了 gRPC 在 C# 中的基本使用方法。
42 5
在 ASP.NET Core 中创建 gRPC 客户端和服务器
|
23天前
|
开发框架 缓存 .NET
GraphQL 与 ASP.NET Core 集成:从入门到精通
本文详细介绍了如何在ASP.NET Core中集成GraphQL,包括安装必要的NuGet包、创建GraphQL Schema、配置GraphQL服务等步骤。同时,文章还探讨了常见问题及其解决方法,如处理复杂查询、错误处理、性能优化和实现认证授权等,旨在帮助开发者构建灵活且高效的API。
26 3
|
3月前
|
开发框架 监控 前端开发
在 ASP.NET Core Web API 中使用操作筛选器统一处理通用操作
【9月更文挑战第27天】操作筛选器是ASP.NET Core MVC和Web API中的一种过滤器,可在操作方法执行前后运行代码,适用于日志记录、性能监控和验证等场景。通过实现`IActionFilter`接口的`OnActionExecuting`和`OnActionExecuted`方法,可以统一处理日志、验证及异常。创建并注册自定义筛选器类,能提升代码的可维护性和复用性。
|
3月前
|
开发框架 .NET 中间件
ASP.NET Core Web 开发浅谈
本文介绍ASP.NET Core,一个轻量级、开源的跨平台框架,专为构建高性能Web应用设计。通过简单步骤,你将学会创建首个Web应用。文章还深入探讨了路由配置、依赖注入及安全性配置等常见问题,并提供了实用示例代码以助于理解与避免错误,帮助开发者更好地掌握ASP.NET Core的核心概念。
112 3
|
2月前
|
开发框架 JavaScript 前端开发
一个适用于 ASP.NET Core 的轻量级插件框架
一个适用于 ASP.NET Core 的轻量级插件框架
|
2月前
|
API
使用`System.Net.WebClient`类发送HTTP请求来调用阿里云短信API
使用`System.Net.WebClient`类发送HTTP请求来调用阿里云短信API
41 0
|
3月前
|
开发框架 NoSQL .NET
利用分布式锁在ASP.NET Core中实现防抖
【9月更文挑战第5天】在 ASP.NET Core 中,可通过分布式锁实现防抖功能,仅处理连续相同请求中的首个请求,其余请求返回 204 No Content,直至锁释放。具体步骤包括:安装分布式锁库如 `StackExchange.Redis`;创建分布式锁服务接口及其实现;构建防抖中间件;并在 `Startup.cs` 中注册相关服务和中间件。这一机制有效避免了短时间内重复操作的问题。
|
4月前
|
开发框架 监控 .NET
开发者的革新利器:ASP.NET Core实战指南,构建未来Web应用的高效之道
【8月更文挑战第28天】本文探讨了如何利用ASP.NET Core构建高效、可扩展的Web应用。ASP.NET Core是一个开源、跨平台的框架,具有依赖注入、配置管理等特性。文章详细介绍了项目结构规划、依赖注入配置、中间件使用及性能优化方法,并讨论了安全性、可扩展性以及容器化的重要性。通过这些技术要点,开发者能够快速构建出符合现代Web应用需求的应用程序。
78 0

相关产品

  • 物联网平台