队列(MessageQueue)

队列的主要作用如下:存储顺序性 队列天然具备顺序性,即消息按照进入队列的顺序写入存储,同一队列间的消息天然存在顺序关系,队列头部为最早写入的消息,队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点(Offset...

顺序消息

如上图所示,消息组1和消息组4的消息混合存储在队列1中,云消息队列 RocketMQ 版 保证消息组1中的消息G1-M1、G1-M2、G1-M3是按发送顺序存储,且消息组4的消息G4-M1、G4-M2也是按顺序存储,但消息组1和消息组4中的消息不涉及顺序关系。...

消息(Message)

消息按照到达 云消息队列 RocketMQ 版 服务端的顺序存储队列中。消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。消息内部属性 系统保留属性 主题名称 定义:当前消息所属的主题的名称。集群内全局唯一。更...

消息存储和清理机制

背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义,消息按照达到服务器的先后顺序存储队列中,理论上每个队列都支持无限存储。但是在实际部署场景中,服务端节点的物理存储空间有限,消息无法做到永久存储。因此,在实际使用中...

领域模型概述

云消息队列 RocketMQ 版 通过流式特性的无限队列结构来存储消息,消息在队列内具备顺序存储特征。消息(Message):云消息队列 RocketMQ 版 的最小传输单元。消息具备不可变性,在初始化发送和完成存储后即不可变。消息消费 消费者分组...

顺序消息

消息存储 如上图所示,顺序消息的Topic中,每个逻辑队列对应一个物理队列,当消息按照顺序发送到Topic中的逻辑队列时,每个分区的消息将按照同样的顺序存储到对应的物理队列中。消息消费 云消息队列 RocketMQ 版 按照存储的顺序将消息投递...

消费者分组(ConsumerGroup)

消息按照到达 云消息队列 RocketMQ 版 服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。内部属性 消费者分组名称 定义:消费者分组的名称,用于区分不同的消费者分组。...

订阅关系(Subscription)

消息按照到达 云消息队列 RocketMQ 版 服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。内部属性 过滤类型 定义:消息过滤规则的类型。订阅关系中设置消息过滤规则后,...

消费者(Consumer)

消息按照到达 云消息队列 RocketMQ 版 服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。内部属性 消费者分组名称 定义:当前消费者关联的消费者分组名称,消费者必须关联...

生产者(Producer)

消息按照到达 云消息队列 RocketMQ 版 服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。内部属性 客户端ID 定义:生产者客户端的标识,用于区分不同的生产者。集群内全局...

基本概念

消息位点(MessageQueueOffset)消息是按到达 云消息队列 RocketMQ 版 服务端的先后顺序存储在指定主题的多个队列中,每条消息在队列中都有一个唯一的Long类型坐标,这个坐标被定义为消息位点。更多信息,请参见 消费进度管理。消费位点...

消费进度管理

消费进度原理 消息位点(Offset)参考 云消息队列 RocketMQ 版 主题 和 队列 的定义,消息是按到达服务端的先后顺序存储在指定主题的多个队列中,每条消息在队列中都有一个唯一的Long类型坐标,这个坐标被定义为消息位点。任意一个消息队列...

生产者负载均衡

策略原理:Hash算法 MessageGroupHash模式下,生产者发送消息时,以消息组为粒度,按照内置的Hash算法,将相同消息组的消息分配到同一队列中,保证同一消息组的消息按照发送的先后顺序存储。说明 Hash算法的具体原理,请参见 SipHash算法。...

混合云备份HBR

抵扣顺序 HBR存储费用的抵扣顺序为:存储资源包>SCU>按量计费 抵扣案例 陈先生2020年6月在华东1(杭州)购买了200 GB的备份库存储容量资源包和50 GB SCU,其6月份在华东1(杭州)地域标备份存储量为300 GB,则陈先生当月的存储费用抵扣...

文件存储NAS

抵扣顺序 NAS存储费用抵扣顺序为:存储包>资源包>SCU>按量付费 抵扣案例 陈先生2021年01月在华北2(北京)购买了500 GiB的通用型NAS资源包和100 GiB SCU,其01月份在华北2(北京)仅使用了容量型NAS,且容量型NAS每小时文件存储量为600 GiB...

存储容量单位包SCU

抵扣顺序 NAS存储费用的抵扣顺序如下图所示。抵扣示例 陈先生2021年01月在华北2(北京)购买了500 GiB的通用型NAS资源包和100 GiB SCU,其02月份在华北2(北京)通用容量型NAS每小时文件存储量为600 GiB,则陈先生当月的存储费用抵扣情况...

对象存储OSS

抵扣顺序 OSS存储费用的抵扣顺序为:地域存储包>中国大陆通用存储包>SCU>按量计费 抵扣案例 用户A于2021年6月在华东1(杭州)购买了500 GB的 标准-本地冗余存储包 和20 GB的SCU,其6月份在华东1(杭州)地域标准存储(本地冗余)类型文件...

存储容量单位包SCU

抵扣顺序 OSS存储费用的抵扣顺序为:地域存储包>中国内地通用存储包>SCU>按量计费 抵扣案例 用户A于2021年6月在华东1(杭州)购买了500 GB的 标准-本地冗余存储包 和20 GB的SCU,其6月份在华东1(杭州)地域标准存储(本地冗余)类型文件...

账单和用量查询

资源包抵扣顺序存储包>资源包>存储容量单位包SCU>按量付费。官网价 单文件系统实例一个月内在抵扣完存储包和资源包后,剩余按量付费的存储容量根据账单中对应的单价核算的结果。案例:华北2(北京)的张先生有一个通用容量型NAS文件系统...

步骤三:创建资源

普通消息:默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群中出现机器宕机时,可能会造成消息乱序。当 存储引擎 选择 云存储 时,默认选择 普通消息。分区顺序消息:默认情况下,保证相同Key的消息...

消息发送重试和流控机制

触发条件 云消息队列 RocketMQ 版 的消息流控触发条件如下:存储压力大:参考 消费进度管理 的原理机制,消费者分组的初始消费位点为当前队列的最大消费位点。若某些场景例如业务上新等需要回溯到指定时刻前开始消费,此时队列存储压力会...

物联网存储介绍

设备消息数据:主要数据为设备事件上报消息、平台控制指令下发消息和消息推送,具有消息有序性、消息队列多等特点,需要使用消息队列模型存储,并且支持消息保序、大量队列数以及低成本海量数据存储。设备时序数据:主要数据为传感器采集...

基本概念

分区顺序消息 默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群宕机时,不会造成消息乱序。但是会出现部分分区发送消息失败的情况,等到宕机机器重新上线后即可恢复正常。更多信息,请参见 存储引擎...

MQTT快速入门

注意事项 云消息队列 MQTT 版 需搭配后端消息存储队列一起使用,具体说明如下:云消息队列 MQTT 版 实例是一个无状态网关类型实例,用来完成IoT移动场景下的客户端连接维持和消息转发,本身并不提供消息数据持久化功能,具体的消息存储和...

如何快速测试云消息队列 Kafka 版服务端是否正常?

普通消息:默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群中出现机器宕机时,可能会造成消息乱序。当 存储引擎 选择 云存储 时,默认选择 普通消息。分区顺序消息:默认情况下,保证相同Key的消息...

作为Input接入

分区顺序消息:默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群中出现机器宕机时,仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败,等到分区恢复后即可恢复正常。当 存储引擎 ...

现代IM系统中的消息系统—模型

Sequence Id:顺序ID,队列中用于定位Message的位点信息,在队列顺序ID保持递增。Message:队列中承载消息的实体,包含了消息的完整内容。Timeline Data Timeline的数据部分就是Message,Message主要包含以下两部分。Message:消息实体,...

作为Input接入

分区顺序消息:默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群中出现机器宕机时,仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败,等到分区恢复后即可恢复正常。当 存储引擎 ...

作为Output接入

分区顺序消息:默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群中出现机器宕机时,仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败,等到分区恢复后即可恢复正常。当 存储引擎 ...

作为Input接入

分区顺序消息:默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群中出现机器宕机时,仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败,等到分区恢复后即可恢复正常。当 存储引擎 ...

作为Output接入

分区顺序消息:默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群中出现机器宕机时,仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败,等到分区恢复后即可恢复正常。当 存储引擎 ...

作为Output接入

分区顺序消息:默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群中出现机器宕机时,仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败,等到分区恢复后即可恢复正常。当 存储引擎 ...

作为Input接入

分区顺序消息:默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群中出现机器宕机时,仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败,等到分区恢复后即可恢复正常。当 存储引擎 ...

作为Output接入

分区顺序消息:默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群中出现机器宕机时,仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败,等到分区恢复后即可恢复正常。当 存储引擎 ...

将云消息队列 Kafka 版接入阿里云Elasticsearch

分区顺序消息:默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群中出现机器宕机时,仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败,等到分区恢复后即可恢复正常。当 存储引擎 ...

消费者负载均衡

如上图所述,队列Queue1中有4条顺序消息,这4条消息属于同一消息组G1,存储顺序由M1到M4。在消费过程中,前面的消息M1、M2被消费者Consumer A1处理时,只要消费状态没有提交,消费者A2是无法并行消费后续的M3、M4消息的,必须等前面的消息...

Kafka数据接入

分区顺序消息:默认情况下,保证相同Key的消息分布在同一个分区中,且分区内消息按照发送顺序存储。集群中出现机器宕机时,仍然保证分区内按照发送顺序存储。但是会出现部分分区发送消息失败,等到分区恢复后即可恢复正常。当 存储引擎 ...

消息轨迹

在分布式应用中,云消息队列 RocketMQ 版 作为全链路中异步解耦的关键服务,提供的消息轨迹数据可有效将业务上下游信息串联起来,帮助您更好地排查异常信息,定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数...

MQTT和RocketMQ进行数据互通(客户端上下线通知)

如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文以公网环境中的Java SDK为例说明...

数据加密

云消息队列 RabbitMQ 版 具有丰富的安全防护能力,通过多项合规认证,支持存储加密、传输加密等安全特性。为您的云端数据安全进行全方位的保驾护航,并满足您企业数据的安全与合规要求。存储加密 使用限制 地域限制:存储加密暂时仅华东1...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
文件存储 CPFS 对象存储 云消息队列 RocketMQ 版 云消息队列 Kafka 版 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用