收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Go SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Go SDK。更多信息，请参见 准备环境。...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Java SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Java SDK。更多信息，请参见 准备...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C++ SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装C++ SDK。更多信息，请参见 准备环境...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的PHP SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装PHP SDK。更多信息，请参见 准备环境...
仪表盘
定时/延时消息：消息定时或延时结束的时间。事务消息：事务提交的时间。不涉及 已就绪消息的排队时间（ready message queue time）最早一条就绪消息的就绪时间和当前时刻的时间差。该时间反映消费者拉取消息的及时性。当前时间－最早一条...
Queue
如果发送消息时不指定消息延时，被发送到普通队列的消息立刻可以被消费，而发送到延时队列需要经过设定的延时时间后才能被消费。QueueURL 格式：http://$AccountId.mns.<Region>.aliyuncs.com/queues/$QueueName。mns.<Region>.aliyuncs....
Serverless实例计费说明
普通消息发送指的是生产者发送的 普通消息，高级消息发送指生产者发送的 定时/延时消息、顺序消息 或 事务消息。云消息队列 RocketMQ 版 中消息投递可分为并发投递和顺序投递，您可以在创建Group时选择投递方式，不同投递方式费用单价不同...
ALIYUN:MNS:Queue
如果发送消息时不指定消息延时参数，被发送到普通队列的消息可以立刻被消费，而发送到延时队列的消息需要经过设定的延时时间后才能被消费。语法 {"Type":"ALIYUN:MNS:Queue","Properties":{"PollingWaitSeconds":Integer,"LoggingEnabled":...
ListMqSofamqWarnHistory
INSTANCE_000001 实例 ID Topic String TP_TEST Topic 名称 WarnId Long 1 报警 ID WarnInfo String"Alert:消息积压:609 大于阈值:600,消息延时:23478710ms 大于阈值:10ms,"报警信息 PageNum Long 1 页码 PageSize Long 20 每页显示条数 ...
数据指标说明
规则引擎流转消息延时 以时间作为X轴，通过面积图样式展示指定时间段内，规则引擎消息延时的变化趋势。OTA指标 数据类 说明 实例下当日升级成功率 以时间作为X轴，通过面积图样式展示指定时间段内，实例下的当日升级成功率的变化趋势。该...
Exchange管理
x-delayed-message：通过声明该类Exchange，您可以自定义消息的Header属性 x-delay 来指定消息延时投递的时间段，单位为毫秒。消息将在 x-delay 中定义的时间段后，根据路由规则被投递到对应的Queue。路由规则取决于 x-delayed-type 中指定...
步骤二：创建资源
x-delayed-message：通过声明该类Exchange，您可以自定义消息的Header属性 x-delay 来指定消息延时投递的时间段，单位为毫秒。消息将在 x-delay 中定义的时间段后，根据路由规则被投递到对应的Queue。路由规则取决于 x-delayed-type 中指定...
配额与限制
若消息大小不满足限制要求，可以尝试分割消息或使用OSS存储，用消息传输URL。消息自定义属性 字符限制：所有可见字符。数量限制：每条消息最多可设置128个属性。长度限制：属性的Key和Value总长度不超过16 KB。系统保留属性：不允许使用...
概述
本文介绍使用社区版TCP协议的Java SDK访问阿里云 云消息队列 RocketMQ 版 来收发消息的流程。使用说明 社区版SDK仅在开源...使用社区版TCP协议的Java SDK收发消息 收发普通消息（三种方式）收发顺序消息 收发定时消息和延时消息 收发事务消息
准备环境
在运行收发消息的 Java 代码前，您需按照本文提供的步骤来准备环境。操作步骤 通过 Maven 方式引入依赖。Java SDK 的最新版本号，可参见 SDK ...发送普通消息（三种方式）发送消息（多线程）收发顺序消息 收发事务消息 收发延时消息 订阅消息
接口和参数说明
SOFAStack 消息队列提供 Java SDK 实现消息发送与订阅，您可通过本文了解消息发送和订阅相关接口的参数说明。通用参数 参数名 参数...更多信息 消息收发代码示例 发送普通消息（三种方式）收发顺序消息 收发延时消息 收发事务消息 订阅消息
Spring集成
背景信息 云消息队列 RocketMQ 版 支持以下消息类型的生产者和消费者与Spring集成：普通消息的生产者和消费者 事务消息的生产者和消费者 顺序消息的生产者和消费者 说明 云消息队列 RocketMQ 版 暂不支持Spring框架下定时消息和延时消息的...
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从...更多信息 消息收发示例代码的更多信息，请参见以下文档：发送普通消息（三种方式）收发顺序消息 收发定时消息 收发延时消息 收发事务消息 订阅消息
OnsTraceGetResult-获取轨迹查询结果
取值说明如下：SEND_SUCCESS：发送成功 SEND_FAILED：发送失败 SEND_ROLLBACK：事务消息回滚 SEND_UNKNOWN：事务消息未提交 SEND_DELAY：定时（延时）消息定时中 SEND_SUCCESS MsgKey string 消息的 Key，即 Message Key。ORDERID_100 ...
队列模型基本概念
普通队列 如果发送消息时不指定消息延时，消息发送到普通队列后可立即被消费。延时队列（Delayed Queue）如果发送消息时指定了消息延时，发送到延时队列的消息需要经过一定的时间后才能被取到。您可通过 CreateQueue 和 SetQueueAttributes...
消息队列 RocketMQ 客户端流控设计
限流方式有两种：针对消息订阅者的并发流控 针对消息订阅者的消费延时流控 针对消息订阅者的消费延时流控的基本原理是，每次消费时在客户端增加一个延时来控制消费速度，此时理论上消费并发最快速度为：MaxRate=1/ConsumInterval*...
创建资源
您可创建不同的Topic来发送不同类型的消息，例如用Topic A发送普通消息，Topic B发送事务消息，Topic C发送定时和延时消息。在实例所在页面的左侧导航栏，单击 Topic 管理。在 Topic 管理 页面，单击 创建 Topic。在 创建 Topic 面板，输入...
创建资源
您可创建不同的Topic来发送不同类型的消息，例如用Topic A发送普通消息，Topic B发送事务消息，Topic C发送定时和延时消息。在实例所在页面的左侧导航栏，单击 Topic 管理。在 Topic 管理 页面，单击 创建 Topic。在 创建 Topic 面板，输入...
产品优势
功能增强 延时消息 支持延时消息，实现秒级精准，无先入先出限制。简单易用，在代码上只需要设置一个参数即可完成，解决开源RabbitMQ无延时队列的痛点。高精度支持，最短可精确到秒级，最长可持续1天。高性能，性能与普通消息一致。多副本...
Topic 与 Tag
建议您从以下几个方面进行判断：消息类型是否一致：如普通消息、事务消息、定时或延时消息、顺序消息，不同的消息类型使用不同的 Topic。创建 Topic 时需要指定消息类型，无法通过 Tag 进行区分。业务是否相关联：没有直接关联的消息，如...
元数据导入
业务消息 RT 延时要求 生产消费RT延时要求。无特殊要求 输入以上参数后，单击 确定，会在 规格评估 面板上方显示推荐实例规格。步骤二：导出元数据 使用元数据导出工具导出自建Kafka集群的元数据文件。下载元数据导出工具，下载链接如下：...
消费重试
例如，消息不可见时间为30 ms，实际消息处理用了10 ms就返回失败响应，则距下次消息重试还需要20 ms，此时的消息重试间隔即为20 ms；若直到30 ms消息还未处理完成且未返回结果，则消息超时，立即重试，此时重试间隔即为0 ms。最大重试次数 ...
产品优势
开箱即用 云消息队列 Kafka 版 100%兼容开源，使您无缝迁移上云。兼容开源：云消息队列 Kafka 版 100%兼容开源Apache Kafka，您可以直接使用开源Apache Kafka客户端与 云消息队列 Kafka 版 通讯。云消息队列 Kafka 版 目前支持0.10.x~2.6.x...
功能特性
消息类型 普通消息：消息队列中无特性的消息，区别于有特性的定时/延时消息、顺序消息和事务消息。事务消息：实现类似 X/Open XA 的分布事务功能，以达到事务最终一致性状态。定时和延时消息：允许消息生产者对指定消息进行定时（延时）...
Topic与Tag最佳实践
建议您从以下几个方面进行判断：消息类型是否一致：如普通消息、事务消息、定时（延时）消息、顺序消息，不同的消息类型使用不同的Topic，无法通过Tag进行区分。业务是否相关联：没有直接关联的消息，如淘宝交易消息，京东物流消息使用不同...
功能与特性概述
消息类型列表 普通消息 消息队列RocketMQ版中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。定时和延时消息 允许消息生产者对指定消息进行定时（延时）投递，最长支持40天。顺序消息 允许消息消费者按照消息发送的顺序...
基本概念
定时/延时消息 定时/延时消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，消息被发送至服务端后，在指定时间后才能被消费者消费。通过设置一定的定时时间可以实现分布式场景的延时调度触发效果。顺序消息 顺序消息是 云消息队列 ...
GetTopic-获取指定主题的详情
DELAY：定时消息/延时消息。NORMAL：普通消息。NORMAL status string 主题的状态。参数取值如下：RUNNING：运行中 CREATING：创建中 RUNNING remark string 主题的备注信息。This is the remark for test.createTime string 主题的创建时间...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容4.x/3.x SDK客户端接入，您可以使用4.x/3.x版本的SDK接入5.x实例进行消息收发。本文为您介绍4.x/3.x版本下的Java SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK...
CreateTopic-创建主题
参数取值如下：TRANSACTION：事务消息 FIFO：顺序消息 DELAY：定时/延时消息 NORMAL：普通消息 注意 主题的类型和发送消息的类型必须一致。例如，您创建的主题的类型为顺序消息，则该主题只能用于收发顺序消息，不能收发其他类型的消息。...
示例代码
} } } 定时/延时消息收发示例 发送定时/延时消息 using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Runtime.InteropServices;using ons;namespace ons { class onscsharp { static void ...
OnsTopicCreate-创建Topic
取值说明如下：0：普通消息 1：分区顺序消息 2：全局顺序消息 4：事务消息 5：定时/延时消息 各类型消息的详细说明，请参见 消息类型列表。0 Remark string 否 需创建的 Topic 的描述信息。测试 InstanceId string 是 需创建的 Topic 所...
示例代码
} 定时/延时消息收发示例 发送定时/延时消息#include"ONSFactory.h"#include"ONSClientException.h"#include<windows.h>using namespace ons;int main(){/创建Producer，并配置发送消息所必需的信息。ONSFactoryProperty factoryInfo;设置...
示例代码
} 定时/延时消息收发示例 发送定时/延时消息#include<iostream>#include<chrono>#include<thread>#include"DefaultMQProducer.h"using namespace std;using namespace rocketmq;int main(){ std:cout;设置为您在消息队列RocketMQ版控制台...
开源对比
更多信息，请参见 延时消息。通过插件或使用消息存活时间过期转移方式实现。事务消息 不支持。支持。顺序消息 不支持。支持。消息优先级 不支持。支持。消息重试机制 消息消费超过一定时间未响应会重新投递。超时时间和重试次数的详细解释...
- 产品推荐
- 这些文档可能帮助您