阿里云首页
消息队列RocketMQ版
相关技术圈
消息队列RocketMQ版
消息队列RocketMQ版(原名开放消息服务,简称ONS)是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。
产品更新
常见问题
立即购买
相关技术圈
学习路径
由浅入深,带您玩转消息队列RocketMQ版!
了解
产品简介
什么是消息队列RocketMQ版
服务端版本差异说明
基本概念
使用限制
产品计费
计费概述
实例规格
变更实例配置
上手
快速入门
快速入门概述
创建资源
调用SDK收发消息
使用
账号与权限
权限概述
RAM主子账号授权
通过RAM角色实现跨云账号授权
服务关联角色
权限策略和示例
实践
领域模型
领域模型概述
主题(Topic)
队列(MessageQueue)
消息(Message)
生产者(Producer)
消费者(Consumer)
消费者分组(ConsumerGroup)
订阅关系(Subscription)
功能行为
普通消息
顺序消息
定时/延时消息
事务消息
生产者负载均衡
消费者负载均衡
消费重试
消费者分类
消息过滤
消费进度管理
消息存储和清理机制
消息发送重试和流控机制
可观测性
可观测性体系概述
指标元数据定义
Dashboard
监控报警
消息轨迹
通过可观测性能力进行故障处理最佳实践
开发
SDK参考
SDK参考概述
快速入门
消息队列RocketMQ版
动态与公告
产品发布记录
新功能发布列表
产品更新日志
TCP协议客户端大版本发布
实例化支持
产品公告
关于新用户不再支持新建4.0系列实例的公告
关于公网地域不再支持新建实例的公告
关于HTTP公网收费通知
关于TCP内网接入点设置的公告
关于HTTP服务不再支持经典网络的公告
关于HTTP服务不再支持跨地域访问的公告
什么是消息队列RocketMQ版?
4.x和5.x版本实例差异说明
5.0系列实例文档
产品简介
基本概念
使用限制
产品选型
产品计费
计费概述
基础服务计费项
计算能力费用
存储费用
增值服务计费项
公网访问费用
变更实例配置
实例规格
欠费说明
续费说明
退款说明
快速入门
快速入门概述
步骤一:(可选)RAM用户授权
步骤二:创建资源
步骤三:调用SDK收发消息
使用教程
配置消息监控告警实现风险预警
使用Canal和RocketMQ实现数据库变更订阅处理
功能与特性
领域模型概述
主题(Topic)
队列(MessageQueue)
消息(Message)
生产者(Producer)
消费者(Consumer)
消费者分组(ConsumerGroup)
订阅关系(Subscription)
普通消息
顺序消息
定时/延时消息
事务消息
生产者负载均衡
消费者负载均衡
消费重试与死信
消费者分类
消息过滤
消费进度管理
消息存储和清理机制
消息发送重试和流控机制
权限管理
权限概述
RAM主子账号授权
通过RAM角色实现跨云账号授权
服务关联角色
权限策略和示例
SDK参考
SDK参考概述
RocketMQ 5.x系列 SDK(推荐)
Java SDK
版本说明
环境准备
示例代码
C++ SDK
版本说明
环境准备
示例代码
Go SDK
版本说明
环境准备
示例代码
RocketMQ 4.x/3.x系列 SDK(兼容)
Java SDK
概述
准备工作
示例代码
C++ SDK
概述
安装CPP动态库
示例代码
RocketMQ ONS 1.x SDK(兼容)
Java SDK
版本说明
准备环境
日志配置
示例代码
C/C++ SDK
版本说明
环境准备(v2.0.0)
环境准备(v1.x.x)
示例代码
.NET SDK
版本说明
环境准备
示例代码
日志配置
API参考
API概览
服务接入点
授权信息
API目录
实例
CreateInstance - 创建实例
UpdateInstance - 更新实例
DeleteInstance - 删除实例
ListInstances - 查询实例列表
GetInstance - 获取指定实例的详情
主题
CreateTopic - 创建主题
UpdateTopic - 更新主题
DeleteTopic - 删除主题
ListTopics - 查询主题列表
GetTopic - 获取指定主题的详情
消费者分组
CreateConsumerGroup - 创建消费者分组
UpdateConsumerGroup - 更新消费者分组
DeleteConsumerGroup - 删除消费者分组
ListConsumerGroups - 查询消费者分组列表
GetConsumerGroup - 获取指定消费者分组详情
公共错误码
版本说明
可观测性
可观测性体系概述
指标元数据定义
Dashboard
监控报警
消息轨迹
通过可观测性能力进行故障处理最佳实践
4.0系列实例文档
产品简介
产品架构
应用场景
实例规格
开服地域
基本概念
客户案例
权益分发
使用限制
产品计费
计费概述
消息收发定价详情
公网流量定价详情
全球消息路由定价详情
异地双活定价详情
资源包说明
出账与欠费说明
免费说明
查看消费明细
升级标准版至企业铂金版
企业铂金版相关操作
退款规则及操作说明
计费常见问题
快速入门
快速入门概述
快速使用TCP协议的SDK收发普通消息
开通消息队列服务并授权
创建资源
调用TCP协议的SDK收发普通消息
快速使用HTTP协议的SDK收发普通消息
开通消息队列服务并授权
创建资源
调用HTTP协议的SDK收发普通消息
快速入门常见问题
权限管理
RAM主子账号授权
通过RAM角色实现跨云账号授权
服务关联角色
权限策略和示例
功能与特性
功能与特性概述
普通消息
定时和延时消息
顺序消息
消息重试
事务消息
消息过滤
集群消费和广播消费
批量消费
异地双活
控制台使用指南
实例管理
Topic管理
Group管理
标签管理
消息查询
查询消息轨迹
查看消费者状态
重置消费位点
死信队列
Dashboard
全球消息路由
监控报警
异地双活实例管理
查看订阅关系
SDK参考
SDK参考概述
商业版TCP协议SDK(推荐)
Java SDK
版本说明
Demo工程
接口和参数说明
准备环境
日志配置
Spring集成
发送普通消息(三种方式)
发送消息(多线程)
收发顺序消息
收发延时消息
收发定时消息
收发事务消息
订阅消息
C/C++ SDK
版本说明
参数说明
环境准备(v2.x.x)
收发普通消息
环境准备(v1.x.x)
收发顺序消息
收发定时消息
收发事务消息
订阅消息
.NET SDK
版本说明
参数说明
环境准备
收发普通消息
收发顺序消息
收发定时消息
收发事务消息
订阅消息
商业版HTTP协议SDK(多语言推荐)
使用须知
协议说明
公共参数
签名机制
发送消息API
订阅消息API
确认消息API
Java SDK
版本说明
准备环境
收发普通消息
收发顺序消息
收发定时消息和延时消息
收发事务消息
Go SDK
版本说明
准备环境
收发普通消息
收发顺序消息
收发定时消息和延时消息
收发事务消息
Python SDK
版本说明
准备环境
收发普通消息
收发顺序消息
收发定时消息和延时消息
收发事务消息
Node.js SDK
版本说明
准备环境
收发普通消息
收发顺序消息
收发定时消息和延时消息
收发事务消息
PHP SDK
版本说明
准备环境
收发普通消息
收发顺序消息
收发定时消息和延时消息
收发事务消息
C# SDK
版本说明
准备环境
收发普通消息
收发顺序消息
收发定时消息和延时消息
收发事务消息
C++ SDK
版本说明
准备环境
收发普通消息
收发顺序消息
收发定时消息和延时消息
收发事务消息
HTTP SDK错误码列表
社区版TCP协议SDK(仅供开源用户上云使用)
概述
社区版Java SDK接入说明
概述
参数说明
准备工作
Demo工程
收发普通消息(三种方式)
收发顺序消息
收发定时消息和延时消息
收发事务消息
社区版C++ SDK接入说明
概述
安装CPP动态库
参数说明
收发普通消息
收发顺序消息
收发事务消息
收发定时和延时消息
订阅消息常见问题
API参考指南
API概览
服务接入点
授权信息
流控信息
API目录
服务
OpenOnsService - 开通服务
消息
OnsMessageTrace - 查看消息消费结果
OnsMessageGetByMsgId - 通过MsgId查询消息
OnsMessageGetByKey - 根据Message Key查询消息
OnsMessagePageQueryByTopic - 查询Topic内所有消息
OnsMessageDetail - 查询消息详细信息
地域
OnsRegionList - 获取地域信息列表
实例
OnsInstanceInServiceList - 查询指定地域下实例列表
OnsInstanceCreate - 创建实例
OnsInstanceBaseInfo - 查询实例基本信息和收发消息的接入点
OnsInstanceUpdate - 更新实例名称和描述
OnsInstanceDelete - 删除实例
Topic
OnsTopicCreate - 创建Topic
OnsTopicDelete - 删除Topic
OnsTopicStatus - 查询Topic状态
OnsTopicList - 获取Topic列表信息
OnsTopicSubDetail - 查看Topic的订阅信息
OnsTopicUpdate - 配置Topic的读写模式
Group
OnsGroupCreate - 创建客户端Group ID
OnsGroupDelete - 删除Group
OnsGroupList - 获取Group ID列表信息
OnsGroupSubDetail - 查看Group ID的订阅信息
OnsGroupConsumerUpdate - 配置消费集群的消息读取权限
标签
ListTagResources - 查询资源绑定的标签列表
TagResources - 为资源绑定标签
UntagResources - 为资源解绑并删除标签
消费
OnsConsumerAccumulate - 查询消息消费堆积情况
OnsConsumerStatus - 查询Group ID消费状态
OnsConsumerGetConnection - 查询Group ID客户端连接情况
OnsConsumerResetOffset - 重置Group ID消费位点
OnsConsumerTimeSpan - 查询Topic可重置时间范围
OnsMessagePush - 向指定的消费者推送消息
消息收发数据统计
OnsTrendTopicInputTps - 统计消息生产数据
OnsTrendGroupOutputTps - 统计消息消费数据
轨迹
OnsTraceQueryByMsgId - 根据MsgId创建轨迹查询任务
OnsTraceGetResult - 获取轨迹查询结果
OnsTraceQueryByMsgKey - 根据Message Key创建轨迹查询任务
死信
OnsDLQMessageGetById - 根据Message ID查询死信消息
OnsDLQMessagePageQueryByGroupId - 查询Group ID内所有死信消息
OnsDLQMessageResendById - 重发指定的死信消息
版本说明
最佳实践
Topic与Tag最佳实践
消费幂等
订阅关系一致
在线教育视频直播
消息堆积和延迟问题
配置消息监控告警实现风险预警
最佳实践常见问题
开源RocketMQ迁移上云
开源RocketMQ迁移上云概述
步骤一:创建迁移任务
步骤二:迁移评估
步骤三:迁移元数据
步骤四:迁移消息服务
使用Canal和RocketMQ实现数据库变更订阅处理
视频专区
如何快速使用消息队列RocketMQ版的TCP Java SDK收发消息?
常见问题
相关协议
阿里云产品服务协议(通用)
消息队列服务等级协议
消息队列RabbitMQ版
应用配置管理 ACM(文档停止维护)
全局事务服务 GTS
企业级分布式应用服务 EDAS
分布式任务调度 SchedulerX
事件总线EventBridge
云原生应用交付平台ADP
微服务引擎MSE
容器镜像服务 ACR
消息服务MNS
首页
消息队列RocketMQ版