死信消息
使用限制 保存死信消息的Topic只支持普通消息和顺序消息类型的Topic，事务消息类型和定时消息类型的Topic不能作为死信Topic。不支持将生产原消息的Topic作为死信Topic（避免出现循环雪崩的问题）。在死信消息转存流程中，若系统发现死信...
集成概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 Connector生态集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据...
事务模式简介
适用的场景包括跨数据库事务、MQ 的消息事务、EDAS 的服务事务及多场景混合型事务方案。AT 模式下，DRDS 中接入分布式事务 与 DRDS版本集成使用时无需@TxcTransaction 注解，且无需引入 GTS 的 SDK，仅需要在用户的 SQL 语句中使用 select ...
依赖服务
jdbc Druid Hikari-CP MyBatis MyBatisPlus Jedis Lettuce Redisson MemCached MongoDB Java Driver Spring-MongoDB Elasticsearch Rest Client Elasticsearch Rest High Level Client Clickhouse JDBC Driver influxDB 消息中间件调用可...
OnsTopicCreate-创建Topic
取值说明如下：0：普通消息 1：分区顺序消息 2：全局顺序消息 4：事务消息 5：定时/延时消息 各类型消息的详细说明，请参见 消息类型列表。0 Remark string 否 需创建的 Topic 的描述信息。测试 InstanceId string 是 需创建的 Topic 所...
仪表盘
高级特性消息倍数：高级特性消息（顺序消息、定时/延时消息、事务消息）的API调用次数在普通消息的基础上以5倍倍率计算。指标项 说明 生产 TPS 峰值 统计消息生产TPS的最大值。该指标项可为估算实例计费项中的TPS峰值规格提供参考。单位：...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容4.x/3.x SDK客户端接入，您可以使用4.x/3.x版本的SDK接入5.x实例进行消息收发。本文为您介绍4.x/3.x版本下的C++ SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为...
SDK参考概述
普通消息 顺序消息 定时和延时消息 事务消息 PushConsumer PullConsumer 批量消费 广播消费 集群消费 消息重试 查询消息轨迹 死信队列 重置消费位点 SDK使用说明 HTTP协议和TCP协议的接入点不可混用。例如，您使用TCP协议的SDK收发消息，您...
云消息队列 RocketMQ 版
重要 鉴于 云消息队列 RocketMQ 版 4.x标准版当前最高可达每秒5千条消息的限速机制，使用该版作为实时计算Flink版对接的消息中间件，可能会导致Flink作业运行不稳定。因此，在选择消息中间件时，如果您正在或计划通过标准版RocketMQ与Flink...
DATASOURCE:ROCKETMQ:Topics
4：事务消息。5：定时/延时消息。CreateTime string 创建时间。无 IndependentNaming boolean Topic所在实例是否有命名空间。取值：true：拥有独立命名空间，资源命名确保实例内唯一，跨实例之间可重名。false：无独立命名空间，实例内或者...
使用Spring Cloud框架收发消息
spring.cloud.stream.bindings.MyOutput.destination=${kafka.output.topic.name} spring.cloud.stream.bindings.MyOutput.contentType=text/plain spring.cloud....MyInput.contentType=text/plain#Binder是Spring Cloud对消息中间件的封装模块...
订阅消息API
TransCheckT Long 表示第一次事务消息的回查时间，相对时间，单位：秒，取值范围：10～300。无消息可消费 响应行 HTTP/1.1 404 响应内容 响应内容的参数说明如下。参数 类型 说明 Code String 错误代码，其中 MessageNotExist 表示没有消息...
开源对比
事务消息 不支持。支持。顺序消息 不支持。支持。消息优先级 不支持。支持。消息重试机制 消息消费超过一定时间未响应会重新投递。超时时间和重试次数的详细解释，请参见 消息超时和重试机制。无消息重试机制。无法跳过有问题消息的消费...
ALIYUN:ROCKETMQ5:Topic
取值：TRANSACTION：事务消息。FIFO：顺序消息。DELAY：定时或延时消息。NORMAL：普通消息。说明 主题的类型和发送消息的类型必须一致。例如，您创建主题的类型为顺序消息，则该主题只能用于收发顺序消息，不能收发其他类型的消息。Remark ...
仪表盘
transaction表示事务消息；delay表示延时/定时消息。fifo_enable：消息消费时服务端是否按照顺序投递。true表示顺序投递；false表示并发投递。uid：您的阿里云主账号ID。client_id：云消息队列 RocketMQ 版 客户端的ID。invocation_status...
创建资源
您可创建不同的Topic来发送不同类型的消息，例如用Topic A发送普通消息，Topic B发送事务消息，Topic C发送定时和延时消息。在实例所在页面的左侧导航栏，单击 Topic 管理。在 Topic 管理 页面，单击 创建 Topic。在 创建 Topic 面板，输入...
消息发送重试和流控机制
说明 对于事务消息，只会进行 透明重试（transparent retries），网络超时或异常等场景不会进行重试。重试流程 生产者在初始化时设置消息发送最大重试次数，当出现上述触发条件的场景时，生产者客户端会按照设置的重试次数一直重试发送消息...
创建资源
您可创建不同的Topic来发送不同类型的消息，例如用Topic A发送普通消息，Topic B发送事务消息，Topic C发送定时和延时消息。在实例所在页面的左侧导航栏，单击 Topic 管理。在 Topic 管理 页面，单击 创建 Topic。在 创建 Topic 面板，输入...
消息堆积和延迟问题
消息类型 消费并发度 普通消息 单节点线程数*节点数量 定时和延时消息 事务消息 顺序消息 Min（单节点线程数*节点数量，分区数）客户端消费并发度由单节点线程数和节点数量共同决定，一般情况下需要优先调整单节点的线程数，若单机硬件资源...
ALIYUN:ROCKETMQ:Topic
4：事务消息。5：定时和延时消息。返回值 Fn:GetAtt InstanceId：Topic所在的实例ID。Topic：Topic的名称。MessageType：Topic的消息类型。示例 YAML 格式 ROSTemplateFormatVersion:'2015-09-01' Parameters:InstanceId:Type:String ...
消息重试
无序消息的重试 对于无序消息（普通、定时、延时、事务消息），当消费者消费消息失败时，您可以通过设置返回状态达到消息重试的结果。无序消息的重试只针对集群消费方式生效；广播方式不提供失败重试特性，即消费失败后，失败消息不再重试...
附录：SOFAStack 产品目录
消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件，为分布式应用提供异步解耦和削峰填谷的能力，支持多种消息类型，提供高可靠、高吞吐量、高可用、事务一致性的异步通讯能力。产品架构 产品优势 开箱即用 多种...
消息过滤
应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务集成场景。在实际业务场景中，同一个主题下的消息往往会被多个不同的下游业务方处理，各下游的处理逻辑不同，只关注自身逻辑需要的消息子集。使用 云...
OnsTopicList-获取Topic列表信息
取值说明如下：0：普通消息 1：分区顺序消息 2：全局顺序消息 4：事务消息 5：定时/延时消息 0 RelationName string 所有关系名称，例如持有者、可订阅、可发布和可发布订阅。授权发布/订阅 Owner string Topic 所有者编号，为阿里云的账号...
基于RocketMQ指标的容器水平伸缩
RocketMQ作为一种高性能、高可靠、高扩展性的分布式消息中间件，已经被广泛应用于企业级应用中。但在使用RocketMQ时，消息堆积是常见的问题，特别是在高负载情况下，消息堆积很容易导致系统负载过高，甚至服务崩溃。为了解决这个问题，您...
ListMqSofamqTopic
取值说明如下：0：普通消息 1：分区顺序消息 2：全局顺序消息 4：事务消息 5：定时/延时消息 Perm Long 6 设置该 Topic 的读写模式。取值说明如下：6：同时支持读写 4：禁写 2：禁读 Topic String TP_TEST Topic 名称 GmtCreate Long ...
版本说明
消息轨迹：新增定时和延时、事务消息及消费环节相关轨迹参数。顺序消息：最大重试次数变更为16次。广播消费：支持定制消费者启动时的消费位点。Push消费：支持消费速度限流；消费线程数异常场景逻辑优化。API接口变更。说明 具体变更内容，...
创建压测场景
如果发送的是事务消息且原始生产者在发送之后崩溃，则Broker服务器会联系同一生产者组的其他生产者实例以提交或回溯消费。Topic 表示一类消息的集合，每个主题包含若干条消息，每条消息只能属于一个主题，是RocketMQ进行消息订阅的基本单位...
基本概念
定时消息 Scheduled message，Producer 将消息发送到消息队列服务端，但并不期望这条消息立马投递，而是推迟到在当前时间点之后的某一个时间投递到 Consumer 进行消费，该消息即定时消息。详情请参见 消息类型>定时和延时消息。地址配置...
AT 模式接入
AT 模式接入适用的场景包括跨数据库事务、MQ 的消息事务、EDAS 的服务事务及多场景混合型事务方案。本文介绍如何基于@TxcTransaction 注解使用 GTS 服务。前提条件 在使用 AT 模式接入 GTS 前，请先完成以下工作：开通 GTS（创建事务分组）...
调用TCP协议的SDK收发普通消息
前提条件 创建资源 说明 本文以普通消息为例进行说明，因此您创建的普通消息的Topic不能用来收发其他类型的消息，包括定时、延时、顺序和事务消息。换言之，切勿混用不同消息类型的Topic。创建AccessKey 下载并安装TCP协议的SDK 说明 商业...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文以公网环境中的Java SDK为例说明...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
版本说明
2.8.35 2019-09-30 增强和简化MT模式和MQ消息事务的支持。2.8.34 2019-09-24 解决2.8.32版本引入的对Diamond低版本的兼容问题。2.8.33 2019-09-23 支持fastjson-1.2.60引入的对java.sql.Date类型解析的兼容性问题。2.8.32 2019-09-17 改进...
Java SDK版本说明
2016-05-26 SDK下载 sample下载 更新内容 增加事务消息队列TransactionQueue。增加一对多广播消息功能。新增JAVA SDK性能测试示例代码。使用帮助 下载sample并解压 aliyun-sdk-mns-samples-1.1.5.zip。用Eclipse导入Maven工程，选中 aliyun...
步骤二：初始化环境
消息类型：选择事务消息。描述：可选，对该 Topic 的备注内容。单击 确定。创建 GroupID 登录消息队列控制台，左侧导航栏选择 Group 管理，进入 Group ID 列表页面。单击列表左上方的 创建 Group ID 按钮，在新弹出的对话框中，输入或选择 ...
调用HTTP协议的SDK收发普通消息
前提条件 创建资源 说明 本文以普通消息为例进行说明，因此您创建的普通消息的Topic不能用来收发其他类型的消息，包括定时、延时、顺序和事务消息。换言之，切勿混用不同消息类型的Topic。创建AccessKey 下载并安装HTTP协议的SDK 云消息...
数据出口至消息队列MQ
物联网络管理平台支持数据出口至阿里云中间件消息队列MQ，本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组，单击一条节点分组对应 操作 栏下的...
顺序消息
顺序消息、定时消息、事务消息是不同的消息类型，三者是互斥关系，不能叠加在一起使用。顺序消息支持哪些地域（Region）？支持消息队列所有部署的地域。顺序消息的使用范围是什么？关于顺序消息的使用范围，包括适用场景和使用限制等，请...
- 产品推荐
- 这些文档可能帮助您