概述
更多消息队列的详情，请参见 什么是消息队列。分布式链路跟踪 SOFAStack 分布式链路跟踪是面向分布式架构、微服务架构与云原生架构的应用可观察性（Observability）的金融级解决方案。通过分布式链路跟踪，运维人员、开发人员和架构师能看...
消息存活时间
什么是消息存活时间 在 云消息队列 RabbitMQ 版 中，消息存活时间用于限制消息在Queue中可以存在的时间，如果消息在Queue中存在的时间超过了设置的消息存活时间，消息将会被进行如下处理：若您未给Queue设置死信Exchange，消息将被Queue...
消费幂等
什么是消息幂等 当出现消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这个消费者的处理过程就是幂等的。例如，在支付场景下，消费者消费扣款消息，对一笔...
消息幂等
什么是消息幂等 在数学与计算机学中，幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域，幂等是指Consumer重复消费某条消息时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生...
消息幂等
什么是消息幂等 当出现消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这整个过程就实现了消息幂等。例如，在支付场景下，消费者消费扣款消息，对一笔订单...
消息队列RocketMQ版是否能保证消息不重复？
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
产品概述
本文介绍 云消息队列 Kafka 版 的产品动态、产品简介及产品计费。云消息队列 Kafka 版 动态与公告 产品简介 产品计费 云消息队列 Confluent 版 什么是云消息队列 Confluent 版？产品计费
常见问题
顺序消息和普通消息的区别是什么？连接服务端时的用户名和密码在哪里获取？消息队列RocketMQ版订阅的Tag数量有限制吗？消息队列RocketMQ版集群消费和广播消费的区别是什么？多个Group订阅同一个Topic消息如何消费？消息队列RocketMQ版的...
常见问题
顺序消息和普通消息的区别是什么？连接服务端时的用户名和密码在哪里获取？连接服务端时的接入点（endpoint）在哪里获取？云消息队列 RocketMQ 版订阅的Tag数量有限制吗？云消息队列 RocketMQ 版集群消费和广播消费的区别是什么？多个Group...
顺序消息
什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。顺序消息...
延时消息
什么是延时消息 延时消息是指在指定时间段之后才被消费者消费的消息。应用场景 延时消息适用于以下场景：对消息生产和消费有时间窗口要求的场景。例如，在电商交易中超时未支付关闭订单的场景，在订单创建时会发送一条延时消息。这条消息将...
MQTT与RocketMQ的消息结构映射
云消息队列 MQTT 版 的详细介绍，请参见 什么是微消息队列MQTT版 和 名词解释。消息结构映射 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 都是基于发布/订阅（Pub/Sub）模型的消息系统，两者概念上存在很多相似之处，下图列举了关键概念...
普通消息
功能原理 什么是普通消息 定义：普通消息是 云消息队列 RocketMQ 版 基本消息功能，支持生产者和消费者的异步解耦通信。普通消息生命周期 初始化 消息被生产者构建并完成初始化，待发送到服务端的状态。待消费 消息被发送到服务端，对消费...
全球消息路由
什么是全球消息路由 云消息队列 RocketMQ 版 的全球消息路由功能依托阿里云优质基础设施实现的高速通道专线（高速通道无需另行开通），高效地实现不同地域之间的消息同步复制。具体实现如下图所示。计费影响 全球消息路由为 云消息队列 ...
定时/延时消息
功能原理 什么是定时消息 定时消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，消息被发送至服务端后，在指定时间后才能被消费者消费。通过设置一定的定时时间可以实现分布式场景的延时调度触发效果。定时时间设置原则 云消息队列 ...
P2P消息收发模式（MQTT）
什么是P2P模式 P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即拥有一个或多个消息发送者和多个消息接收者的场景。在P2P模式中，发送者发送消息时...
P2P消息收发模式（MQTT）
什么是P2P模式 P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即拥有一个或多个消息发送者和多个消息接收者的场景。在P2P模式中，发送者发送消息时...
顺序消息
功能原理 什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持消费者按照发送消息的先后顺序获取消息，从而实现业务场景中的顺序处理。相比其他类型消息，顺序消息在发送、存储和投递的处理过程中，更多强调多...
事务消息
功能原理 什么是事务消息 事务消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持在分布式场景下保障消息生产和本地事务的最终一致性。事务消息处理流程 事务消息交互流程如下图所示。生产者将消息发送至 云消息队列 RocketMQ 版...
基本概念
更多信息，请参见 什么是云消息队列 Kafka 版？ZooKeeper 一款开源的分布式应用程序协调服务。在 云消息队列 Kafka 版 中，ZooKeeper主要用于集群管理、配置管理、Leader选举。ZooKeeper是 云消息队列 Kafka 版 的一部分，您无需感知...
将云消息队列 Kafka 版接入阿里云Elasticsearch
更多信息，请参见 什么是云消息队列 Kafka 版。阿里云Elasticsearch Elasticsearch简称ES，是一个基于Lucene的实时分布式的搜索与分析引擎，是遵从Apache开源条款的一款开源产品，是当前主流的企业级搜索引擎。它提供了一个分布式服务，...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
消息（Message）
系统默认的消息最大限制如下：普通和顺序消息：4 MB 事务和定时或延时消息：64 KB 使用建议 单条消息不建议传输超大负载 作为一款消息中间件产品，云消息队列 RocketMQ 版 一般传输的是都是业务事件数据。单个原子消息事件的数据大小需要...
SOFAMQ 常见问题
作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，可以保证消息不丢失，但是无法保证消息不重复。控制台显示的消息堆积量是否包含了 Topic 下所有 Tag 的消息？是。消息生产者将所有类型的 Tag 都发送至同一个 Topic 中，...
概述
SOFAStack 消息队列（SOFAStack MQ，简称 SOFAMQ）是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息...
ChatAppStatus
消息体格式 名称 类型 是否必填 描述 MessageId String 是 消息的ID。From String 是 消息发送方号码。To String 是 消息接收方号码。Timestamp Long 是 时间戳为Unix timestamp 毫秒。Status String 是 消息发送状态。取值：Sent：消息已...
集成概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 Connector生态集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据...
ChatAppInbound
消息体格式 名称 类型 是否必选 描述 MessageId String 是 消息的ID。From String 是 消息发送方号码。To String 是 消息接收方号码。Timestamp Long 是 时间戳为Unix timestamp 毫秒。DisplayName String 是 号码显示的名称。Type String ...
为什么发送给Topic的消息在分区中分布不均衡
分区中消息量可以在 Topic详情 页面的 分区状态 页签查看，位点数即是消息数。以下图为例，分区 2 消息比较多，其他分区消息少甚至没有，消息分布不均衡。可能原因 发送消息时指定了分区，导致未指定的分区没有消息。发送消息时指定了消息...
ChatAppStatus
2023038470553398*8","ConversationId":"72222201111*","ConversationType":"service"}]字段说明 名称 类型 是否必填 描述 MessageId String 是 消息的ID。From String 是 消息发送方号码。To String 是 消息接收方号码。Timestamp Long ...
基本概念
消息队列（MessageQueue）队列是 云消息队列 RocketMQ 版 中消息存储和传输的实际容器，也是消息的最小存储单元。云消息队列 RocketMQ 版 的所有主题都是由多个队列组成，以此实现队列数量的水平拆分和队列内部的流式存储。队列通过QueueId...
消息加密传输
解决方案 以下是 消息服务MNS 对消息进行加密传输的解决方案。在消息发送端先对消息进行加密，然后再发送。在消息接收端先对消息进行解密，然后再消费。示例代码：SecurityQueue.zip，其中：SeurityQueue.java 提供 putMessage、popMessage...
OnsMessagePush-向指定的消费者推送消息
30.5.121.*@24813#-1999745829#-1737591554#453111174894656 MsgId string 是 消息的标识，即 Message ID。0BC1669963053CF68F733BB70396*Topic string 是 消息推送至的目标 Topic。test-mq_topic InstanceId string 是 所需推送的消息所在...
QueryMqttTraceMessagePublish-查询消息发送轨迹
mqtt-cn-i7m26mf*MsgId string 是 消息 ID，即 Message ID。AC1EC0030EAB78308DB16A3EC773*BeginTime long 是 查询范围的起始时间戳。单位：毫秒。1618646400000 EndTime long 是 查询范围的终止时间戳。单位：毫秒。1621591200000 返回...
发送消息API
MessageBody 是 消息内容。Properties 否 消息属性。属性（Properties）的序列化，其中特殊用途的键值说明如下：格式：key1:value1|key2:value2|key3:value3 键值说明如下。参数 类型 说明 KEYS String 消息的Key。STARTDELIVERTIME Long ...
Queue
队列是消息存储的目的地，队列可以分成普通队列和延时队列。如果发送消息时不指定消息延时，被发送到普通队列的消息立刻可以被消费，而发送到延时队列需要经过设定的延时时间后才能被消费。QueueURL 格式：http://$AccountId.mns.<Region>....
Subscription
Region 是 消息服务MNS 部署的地域，您可以根据应用需要选择不同的地域，具体各地域的访问域名，请参见 地域和接入点。AccountId：主题所有者的账号ID。实际调用 消息服务MNS 的API时请替换成实际的账号ID。TopicName：主题的名称。实际...
Subscription
Region 是 消息服务MNS 部署的地域，您可以根据应用需要选择不同的地域，具体各地域的访问域名可以在控制台 获取Endpoint 查看。AccountId：主题所有者的账号ID。实际调用 消息服务MNS 的API时请替换成实际的账号ID。TopicName：主题的名称...
- 产品推荐
- 这些文档可能帮助您