顺序存储队列-顺序存储队列文档介绍内容-阿里云

获取MQTT客户端在线状态

应用场景云消息队列 MQTT 版需结合后端存储消息队列产品，如云消息队列 RocketMQ 版等使用，来和部署在云端服务器上的应用（下文简称为业务应用）完成业务流程。获取客户端在线状态主要的应用场景如下：主业务流程中需要根据客户端是否...

基本概念

顺序消息云消息队列 RocketMQ 版提供的一种按照顺序进行发布和消费的消息类型，分为全局顺序消息和分区顺序消息。更多信息，请参见顺序消息。全局顺序消息对于指定的一个Topic，所有消息按照严格的先入先出（FIFO）的顺序进行发布和...

主题（Topic）

队列列表定义：队列作为主题的组成单元，是消息存储的实际容器，一个主题内包含一个或多个队列，消息实际存储在主题的各队列内。更多信息，请参见队列（MessageQueue）。取值：系统根据队列数量给主题分配队列，队列数量创建主题时定义。...

创建RabbitMQ Source Connector

本文介绍如何在云消息队列 Kafka 版控制台创建流入任务，将云消息队列 RabbitMQ 版中的数据快速导入至云消息队列 Kafka 版。前提条件您已购买云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见步骤二：购买和...

存储引擎对比

在创建Topic时，您可以为云消息队列 Kafka 版选择云存储或Local存储引擎。云存储依托阿里云云盘算法、低延迟、低成本、弹性伸缩能力更好，适用于大多数场景；若有特殊需求，例如Compact、幂等、事务、分区顺序消息等，建议您选择Local...

消息查询

磁盘使用率介于[85%,90%)区间，无论消息是否超过消息保留时长，根据服务端存储消息的时间先后顺序直接清除消息。磁盘使用率≥90%，为了保证稳定性，服务开启禁写保护，暂时无法写入新消息。重要云消息队列 Kafka 版在清除消息时，会至少...

使用限制

企业铂金版：存储时长为3天，若您购买实例的存储空间规格不足时，云消息队列 RocketMQ 版会按存储时间滚动删除最早的消息，此时消息的存储时长可能不足3天。说明定时消息和延时消息的存储时长以定时或延时时长到期的时间为开始进行计算。...

死信队列

重要对于顺序消息消费产生的死信消息，不支持从死信队列重新发送，您需要将消息从死信队列导出后自行处理。死信消息被重新发送后不会在死信队列中立即被删除，等到死信消息的有效期到期后才会被自动删除。单条重发在云消息队列 RocketMQ...

发布者最佳实践

分区顺序单个分区（Partition）内，消息是按照发送顺序储存的，是基本有序的。默认情况下，云消息队列 Kafka 版为了提升可用性，并不保证单个分区内绝对有序，在升级或者宕机时，会发生少量消息乱序（某个分区挂掉后把消息Failover到其它...

应用场景

消息的顺序收发云消息队列 RocketMQ 版顺序消息分为两种情况：全局顺序：对于指定的一个Topic，所有消息将按照严格的先入先出（FIFO）的顺序，进行顺序发布和顺序消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块...

现代IM系统中的消息系统—架构

而消息的存储，通常要求消息能根据会话顺序来排序，会话顺序通常由端的会话来决定，而不是服务端的同步顺序来定，这是两种顺序要求。支持根据顺序ID的随机定位：可根据SequenceId随机定位到Timeline中的某个位置，从这个位置开始正序或逆序...

开源对比

云消息队列 RabbitMQ 版是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...

仪表盘

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RocketMQ 版提供仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。本文介绍仪表盘的应用场景、业务背景...

如何优化高并发IM系统架构

介绍如何使用表格存储的主键增列功能优化高并发IM系统架构。背景在构建社交IM和朋友圈应用时，最基本的需求是将用户发送的消息和朋友圈的更新及时、准确地更新给该用户的好友。这需要为用户发送的每一条消息或者朋友圈更新设置一个序号...

DBMS_AQADM

您可以使用 DBMS_AQADM 包中的存储过程创建并管理消息队列和队列表。表 1.DBMS_AQADM函数/存储过程函数/存储过程返回类型说明 ALTER_QUEUE N/A 修改现有的队列。ALTER_QUEUE_TABLE N/A 修改现有的队列表。CREATE_QUEUE N/A 创建队列。...

仪表盘

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RocketMQ 版提供可实时进行数据统计的仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。本文介绍仪表盘...

常见问题

云消息队列 RocketMQ 版存储需要挂载磁盘吗？客户端连接常见问题客户端连接时出现“signature validate by dauth failed”错误客户端连接时出现“TimeoutException”错误客户端返回“valid resource owner failed”错误客户端返回...

基础术语

顺序消息 Ordered message 消息队列提供的一种按照顺序进行发布和消费的消息类型，分为全局顺序消息和分区顺序消息，当前仅支持分区顺序消息。详情请参见顺序消息。分区顺序消息 Partitionally ordered message 对于指定的一个 Topic，...

数据格式

数据格式数据格式支持的连接器 JSON 消息队列Kafka、Upsert Kafka、Elasticsearch、对象存储OSS，云数据库MongoDB、StarRocks。Canal 消息队列Kafka、对象存储OSS。Debezium 消息队列Kafka、对象存储OSS。Maxwell 消息队列Kafka、对象...

为什么消息已经过期还未被删除？

磁盘容量不足（即磁盘水位达到85%）时，无论消息是否超过消息保留时长，都将根据服务端存储消息的时间先后顺序提前删除旧的消息，以确保服务可用性。可能原因消息所保存的Segment片段大小未超过1 GB，消息不会被删除。说明为了减少存储...

Topic的存储有哪些类型？

云存储和Local存储。云消息队列 Kafka 版实例支持云存储和Local存储。详情请参见存储引擎对比。

云消息队列 Kafka 版何时删除旧消息？

磁盘使用率介于[85%,90%)区间：无论消息是否超过消息保留时长，根据服务端存储消息的时间先后顺序直接清除消息。磁盘使用率≥90%：为了保证稳定性，服务开启禁写保护，暂时无法写入新消息。重要一般情况下，为了保证您的业务健康性（拥有...

API概览

本产品（微消息队列 MQTT/2020-04-20）的OpenAPI采用 RPC 签名风格，签名细节参见签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求...

表格存储

消息数据表格存储自研的Timeline模型主要用于消息数据，能够抽象出支撑海量Topic的轻量级消息队列，可以存储大量社交信息，包括IM聊天，以及评论、跟帖和点赞等Feed流信息。目前表格存储Timeline模型已被应用在众多IM系统中，例如支撑钉钉...

查询消息轨迹

云消息队列 RocketMQ 版将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...

企业铂金版计费说明

说明云消息队列 RocketMQ 版有4种消息类型：普通消息、定时和延时消息、事务消息以及顺序消息，其中，定时和延时消息、事务消息以及顺序消息为高级特性消息。更多信息，请参见消息类型列表。Topic数上限：表示指定实例下可创建的最大...

云存储网关软件版公测

云存储网关软件版是一款可以安装在阿里云用户ECS上或者用户本地数据中心客户端的产品，提供类似ossfs的功能，使用云存储网关软件版可以将OSS桶挂载到客户端本地以POSIX文件接口进行访问，从而您可以像操作本地文件一样操作OSS里面的文件。...

消费者分类

顺序性保障基于云消息队列 RocketMQ 版顺序消息的定义，SimpleConsumer在处理顺序消息时，会按照消息存储的先后顺序获取消息。即需要保持顺序的一组消息中，如果前面的消息未处理完成，则无法获取到后面的消息。适用场景 ...

Topic引流

您在升级云消息队列 Kafka 版实例的流量规格时，可能会触发集群横向扩容。集群横向扩容完成后，您需要进行Topic引流，使Topic流量重新均匀分布到扩容后的集群上。否则原有的Topic流量还是打在扩容前的集群节点上，原有的Topic的峰值流量...

普通消息

普通消息为云消息队列 RocketMQ 版中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景普通消息一般应用于微服务解耦、事件驱动、数据集成等...

步骤二：创建资源

在调用SDK收发消息前，您需要提前创建云消息队列 RocketMQ 版的相关资源，包括创建云消息队列 RocketMQ 版实例、获取实例的接入点、创建Topic、创建ConsumerGroup。调用SDK时，需要将这些资源信息填写到SDK代码中。前提条件创建专有...

订阅者最佳实践

云消息队列 Kafka 版没有处理失败消息的设计，实践中通常会打印失败的消息或者存储到某个服务（例如创建一个Topic专门用来放失败的消息），然后定时检查失败消息的情况，分析失败原因，根据情况处理。消费延迟云消息队列 Kafka 版的消费...

使用Canal和RocketMQ实现数据库变更订阅处理

不涉及高阶参数配置数据同步Topic和顺序性设置 Canal传输数据库变更事件到云消息队列 RocketMQ 版默认遵循一定的顺序性原则，在早期版本中每个任务默认是发送到云消息队列 RocketMQ 版单个Topic的单个分区。Topic设置方法可以使用 ...

使用Canal和RocketMQ实现数据库变更订阅处理

MQ_INST_1266540465*_BYSLmTAL 高阶参数配置数据同步Topic和顺序性设置 Canal传输数据库变更事件到云消息队列 RocketMQ 版默认遵循一定的顺序性原则，在早期版本中每个任务默认是发送到云消息队列 RocketMQ 版单个Topic的单个分区。...

死信消息

使用限制保存死信消息的Topic只支持普通消息和顺序消息类型的Topic，事务消息类型和定时消息类型的Topic不能作为死信Topic。不支持将生产原消息的Topic作为死信Topic（避免出现循环雪崩的问题）。在死信消息转存流程中，若系统发现死信...

Serverless实例计费说明

计费公式每小时存储费用＝存储空间占用大小（GB）×存储单价（元/G/小时）计费单价地域存储空间单价（元/GB/小时）所有支持地域 0.0014 Topic费用云消息队列 RocketMQ 版的Serverless实例按照Topic数量收取费用。说明 Topic费用是只要...

接口和参数说明

云消息队列 RocketMQ 版提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从云消息队列 RocketMQ 版获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息云消息队列 RocketMQ 版支持以下两种消息获取方式：Push...

Demo工程

mqtt.ssl.demo.ios Demo使用须知如果搭配使用云消息队列 MQTT 版和其他后端消息存储产品，如云消息队列 RocketMQ 版，您需理解消息结构和属性映射关系，详细信息，请参见 MQTT与RocketMQ的消息结构映射。说明各种开发语言的Demo程序...

Demo工程

mqtt.ssl.demo.ios Demo使用须知如果搭配使用云消息队列 MQTT 版和其他后端消息存储产品，如云消息队列 RocketMQ 版，您需理解消息结构和属性映射关系，详细信息，请参见 MQTT与RocketMQ的消息结构映射。说明各种开发语言的Demo程序...

配额与限制

云消息队列 RocketMQ 版对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用云消息队列 RocketMQ 版时不要超过对应的限制值，避免应用出现异常。参数限制以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...

顺序存储队列

新品推荐