AMQP消息订阅概述
消息订阅是开发者中心基于AMQP标准协议实现的数据订阅功能。AMQP(Advanced Message Queuing Protocol)即高级消息队列协议。用户在创建AccessKey、配置和启动消息订阅规则后,平台会按照配置信息将已订阅的消息类型转发至指定消息队列中,然后用户使用客户端连接队列即可获取订阅的消息数据。
AMQP消息订阅数据流转如下图:
AMQP服务端订阅优势:
● 支持多消费组。同一个账号,可以在开发环境下使用消息队列A订阅产品A,同时在正式环境下消息队列B订阅产品B。 如果多个不同消费队列同时订阅产品B,则不同消费队列可同时收到来自设备B的相同信息。
● 方便排查问题。支持查看客户端状态、查看堆积和消费速率。
● 线性扩展。在消费者能力足够,即客户端机器足够的情况下,可轻松线性扩展推送能力。
● 消息堆积队列。设备实时消息直接推送,推送失败时进入会堆积队列,不会丢失设备消息。即使消费者的客户端宕机,或因消费能力不足堆积了消息,当消费端恢复后,未接收的设备消息也可以继续正常消费。
使用AMQP服务端订阅,需先在开发者中心控制台创建消息队列和配置订阅规则,请参见SaaS管理,然后开发AMQP客户端,接入开发者中心订阅消息,请参见AMQP客户端接入说明。
免责声明:
移远开发者中心将根据需要,不定期发布或迭代更新版本。移远开发者中心的发布或更新将导致用户AMQP客户端断开连接。移远将尽一切合理方式提前通知,但为保证用户的连续使用,请用户确保使用具备断线重连机制的AMQP客户端接入移远开发者中心。 移远开发者中心无法保证或承诺IoT平台服务的连续性。因用户未使用具备断线重连机制的AMQP客户端而产生的任何形式(直接、间接或其它)的损失或损害,不论是合同、侵权或其它,移远开发者中心均不承担任何责任和义务。