资讯 OneNET新能力MQ(消息队列)上线
OneNET新能力MQ(消息队列)上线
新年伊始,OneNET能力大家族迎来两名新成员:DMP和MQ。为了好的完善相关功能,让用户使用更顺畅,我们即将面向所有用户开启公测活动。
MQ消息队列能力
简介
消息队列MQ是为实现应用层快速可靠地获取设备消息而推出的消息中间件服务,服务模型如下:
其中:
(1)topic为队列实体,一个MQ服务中可以创建多个队列实体;
(2)sub(订阅 subscription)为实际消费者,一个队列可以支持多个消费者,消费者之间相互独立,可分别采用不同的模式消费队列中的数据。
队列中的消息源来自产品中的设备,用户可以通过配置转发规则,将需要的消息转发至对应的队列中。
用户消费数据之前,首先需要创建topic与sub(订阅 subscription),然后使用客户端与某个topic的某个sub建立订阅关系,才能消费到队列中的数据。
服务特点
▪消息缓存
MQ服务支持消息缓存,可以有效的缓存由于网络或者应用服务器异常等原因导致的未能被即时消费的消息
▪削峰去谷
MQ服务可以有效的缓冲前向突发的大并发量设备消息,以较低的较为平均的速率推送给消费客户端,从而减轻消费端压力
▪最多一次与至少一次
用户可以通过配置消息锁定时间来实现最多消费一次以及至少消费一次的消息模式,若启用消息锁定时间,在该时间内,若客户端无应答确认,则认为消费失败,锁定时间段之后,客户端可以再次消费到该未被确认的消息
▪消息过期时间
用户可以配置消息过期时间,即系统会回收进入队列超过一定时间的消息
▪自定义消费位置
支持用户自定义消费位置,例如从头部消费,从尾部消费或者从队列中某个位置消费,完成设置后,客户端将消费到来自队列中自定义位置之后的消息
▪多方独立消费
服务支持用户为一个队列创建多个消费者,消费者之间相互独立,可以分别采用不同的配置消费同一队列中的数据
▪单点消费与集群消费
MQ服务支持一个或者多个client同时与同一个sub(订阅 subscription)建立订阅关系
当多个client同时与同一个topic中的同一个sub建立订阅关系时,MQ服务会认为客户端处于集群消费模式,消息将被均衡的发送至每个client,且每条消息仅能够被一个客户端消费,如下图所示:
DMP设备管理能力
简介
OneNET DMP是针对物联网设备管理需要,提供机卡一体化管理特色能力,设备概况统计、设备信息增强管理、远程升级、故障追踪等功能,用于终端&物联网卡故障排查、机卡关系管理、终端状态查询、通信业务使用情况查询等场景。
技术详情:https://open.iot.10086.cn/iotbox/information/detail?id=239