AMQP订阅推送
订阅:AMQP(Advanced Message Queuing Protocol)即高级队列消息协议。用户通过控制台创建订阅任务,也可以通过调用物联网平台的创建规则触发条件、创建规则动作、修改规则触发条件接口配置并激活规则,向平台获取发生变更的设备业务信息(如设备生命周期管理、设备数据上报、设备消息状态、设备状态等)和管理信息(软固件升级状态和升级结果)。订阅时必须指定具体的AMQP消息通道。
推送:订阅成功后,物联网平台根据用户订阅的数据类型,将对应的变更信息推送给指定的AMQP消息队列。如果用户没有订阅该类型的数据通知,即使数据发生了变更也不会进行推送。用户可通过AMQP的客户端与IoT平台建立链接,来接收数据。订阅推送的示意图如下图所示:
推送机制:物联网平台向用户推送消息后,如果用户接收成功,会向物联网平台回复响应(推荐自动响应方式)。如果用户建立链接后不拉取数据,则会导致数据积压在服务端。服务端仅保存最近24小时,且占用磁盘容量小于1GB的数据,如果用户不及时拉取数据,物联网平台会滚动清除超期和超出容量限制的数据。若用户收到消息后来不及响应,长链接中断,则未响应的数据会在下次链接后重新推送。
如何进行数据订阅
应用服务器接入到“设备接入服务”后,在控制台创建订阅任务,也可以通过调用API接口进行数据订阅。
- 在控制台配置AMQP订阅请参考配置AMQP服务端订阅。
- 通过API接口进行数据订阅请参考如何调用API和创建规则触发条件、创建规则动作、修改规则触发条件。