OneNET物联网平台06 消息队列MQ服务开启与配置
消息队列MQ可作为规则引擎对接的扩展增值服务使用，配合物联网套件，可形成具备设备接入、设备管理、消息分发、应用承载能力的高性能服务组合
消息队列MQ具有如下特点：
消息缓存
MQ服务支持消息缓存，可以有效的缓存由于网络或者应用服务器异常等原因导致的未能被即时消费的消息
队列缓存具有一定的容量上限，当队列容量达到上限后，服务将回收队列头部的数据
削峰去谷
MQ服务可以有效的缓冲前向突发的大并发量设备消息，以较低的较为平均的速率推送给消费客户端，从而减轻消费端压力
最多一次与至少一次
用户可以通过配置消息锁定时间来实现最多消费一次以及至少消费一次的消息模式，若启用消息锁定时间，在该时间内，若客户端无应答确认，则认为消费失败，锁定时间段之后，客户端可以再次消费到该未被确认的消息
消息过期时间
用户可以自定义消息过期时间，进入队列时长达到消息过期时间的消息将会被删除，即服务会删除进入队列超过一定时间的消息
顺序消息
对于同一个topic，所有消息按照先入先出（FIFO）的顺序进行发布和消费，保证严格的消息顺序性
消息回溯
支持用户自定义消费位置，重新消费队列中消息，例如设置为从头部消费，完成设置后，客户端将消费到来自队列中自定义位置之后的消息
只要消息没有因为超时或者缓存区已满而被删除，用户均可以通过指定消费位置重新消费到该消息
多方独立消费
服务支持用户为一个队列创建多个消费代理(sub)，消费代理之间相互独立，可以分别采用不同的配置消费同一队列中的数据
单点消费与集群消费
MQ服务支持一个或者多个client同时与同一个sub（订阅 subscription）建立订阅关系
当多个client同时与同一个topic中的同一个sub建立订阅关系时，MQ服务会认为客户端处于集群消费模式，消息将被均衡的发送至每个client，且每条消息仅能够被一个客户端消费
1、添加服务实例
服务实例是消息队列MQ独立服务与计费的实体，目前支持用户创建最多10个实例。
在Onenet平台找到消息队列MQ
首次开通消息队列MQ有15天的免费体验期，同意开通后添加实例
添加完成后如图所示：
2、添加topic
一个topic可以理解为一个实际的队列实体，服务实例中可以创建多个topic。
直接点击新建的yuyun-mq-test实例，进去后在topic管理页直接添加topic
添加成功后，如图：
3、添加订阅
点击查看新建的topic详情，进入topic详情页，在最下方点击“添加订阅”，订阅名称为yuyun-topic-data
OneNET物联网平台06 消息队列MQ服务开启与配置相关推荐
- OneNET物联网平台08 MQTT产品设备发送消息到消息队列MQ
一.消息生产 设备终端接入OneNET平台不同的产品套件,上传设备消息至OneNET平台: 开通消息队列MQ服务,创建消息队列MQ实例,添加topic和sub: 选择不同的 数据源 配置规则引擎和消息 ...
- 从“消息队列”到“服务总线”和“流处理平台”
作者简介 Gavin,程序员.软件架构师.企业架构师,关注智能制造. 本文是专栏<智能制造系统架构>中的文章,其它文章请参阅入坑智能制造系统架构. 消息队列是分布式系统中重要的组件,也是企 ...
- esp8266 esp12 AT指令连接wifi热点联网，HTTP获取OneNET物联网平台消息，控制四路远程开关
esp8266 esp12 使用AT指令联网非常方便,很适合应对已经开发好的成品需要增加联网功能的需求. 使用AT指令进行开发,大多数是产品已经开发好,只需要增加小数据量的联网功能,而且不想对既有成品 ...
- 中国移动 OneNET 物联网平台从入门到「放弃」
01. OneNET 物联网平台 中国移动 OneNET定位为 PaaS 服务,即在物联网应用和真实设备之间搭建高效.稳定.安全的应用平台:面向设备,适配多种网络环境和常见传输协议,提供各类硬件终端的 ...
- 消息队列的使用场景_消息队列MQ的特点、选型及应用场景
一.什么是消息队列 消息队列(Message Queue,简称MQ),指保存消息的一个容器,本质是个队列. 消息(Message)是指在应用之间传送的数据,消息可以非常简单,比如只包含文本字符串,也可 ...
- mqtt 域名连接_中国移动OneNet物联网平台，如何使用MQTT协议，进行连接
大家好,超子又和大家见面了,超子我能力有限,技术不高,有什么错误的地方,欢迎板砖.今天我们一起构建MQTT协议中的CONNECT报文,连接OneNet物联网平台,然后进行通信.前面的文章中,超子介绍阿 ...
- 后端技术：消息队列MQ/JMS/Kafka相关知识介绍
?今天给大家分享消息队列MQ/JMS/Kafka相关知识介绍 1.消息队列介绍 首先举个收快递的栗子,传统的收快递,快递小哥把我们的快递送到我们的手里.他需要什么条件嗯? 快递小哥有时间送, 我们有时 ...
- 消息中间件系列(四)：消息队列MQ的特点、选型、及应用场景详解
前面集中谈了分布式缓存Redis系列: 高并发架构系列:分布式锁的由来.特点.及Redis分布式锁的实现详解 高并发架构系列:Redis并发竞争key的解决方案详解 高并发架构系列:Redis缓存和M ...
- 消息队列MQ夺命连环11问：kafka、rabbitmq、rocketmq、activemq
<消息队列MQ如何保证消息的幂等性> <RabbitMQ架构> <ZeroMQ简介:一种高性能的异步消息传递库> <Rocketmq原理&最佳实践&g ...
最新文章
- python中count()方法
- mysql 建表代码
- angular日期输入框html,html5 – Angular2：日期格式文本框ngModel不起作用
- CentOS7 配置网络物理机ping不上虚拟机解决方法
- 67.二进制求和 （力扣leetcode） 博主可答疑该问题
- 华为薪资等级结构表_华为内部考核体系
- 算法设计之数字三角形问题
- 信道与信道容量（一）
- 试题 历届真题 大胖子走迷宫【第十届】【决赛】【C组】
- 电磁场与仿真软件(19)
- 初级计算机信息处理员笔试题,初级信息处理技术员计算机系统基础知识考试卷模拟考试^题...
- 解决lo: flags=73＜UP,LOOPBACK,RUNNING＞ mtu 65536 网络连接不通
- 涂鸦智能平台——mcu+nbiot
- 【干货】柔性电池的未来展望
- mysql聚类函数排序_聚类算法大盘点 - 如鱼饮水，冷暖自知 - OSCHINA - 中文开源技术交流社区...
- python小游戏-移动木板
- 记录vue table列表中的选择表格反写
- 消防工程师证的用途和发展前景
- 如何定位逻辑错误C语言,如何调试C程序的语法错误和逻辑错误
- R-交通事故数据分析报告