rocketmq集群-rocketmq集群文档介绍内容-阿里云

公共参数

Date 是请求的构造时间，目前只支持GMT格式，如果和云消息队列 RocketMQ 版的服务器时间前后差异超过15分钟将返回本次请求非法。Host 是即在控制台实例详情页面查看到的HTTP接入点。x-mq-version 是调用云消息队列 RocketMQ 版的...

操作指南

您可以在云消息队列 RocketMQ 版控制台管理实例、Topic、Group等资源，并进行消息轨迹查询、创建云监控等运维操作。云消息队列 RocketMQ 版5.x系列资源管理迁移上云版本管理消息轨迹监控报警其他更多操作，请参见 5.x系列操作指南...

云消息队列 RocketMQ 版5.x系统权限策略参考

本文描述云消息队列 RocketMQ 版5.x支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...

云消息队列 RocketMQ 版4.x系统权限策略参考

本文描述云消息队列 RocketMQ 版4.x支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...

版本说明

本文介绍HTTP协议下C++ SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的C++ SDK收发消息。...已支持集群消费模式，暂不支持广播消费模式。暂不支持查询消息轨迹。mq-http-cpp-sdk-1.0.0.zip

死信队列

对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...

出账与欠费说明

云消息队列 RocketMQ 版的计费出账和欠费释放根据支付方式有所不同，本文介绍标准版实例（按量付费）与企业铂金版实例（包年包月）的出账与欠费说明。标准版实例（按量付费）的出账与欠费说明说明以下说明同样适用于资源包。云消息队列 ...

使用限制

云消息队列 RocketMQ 版对某些具体指标进行了约束和规范，您在使用云消息队列 RocketMQ 版时注意不要超过相应的限制值，以免程序出现异常。限制项限制值说明 Topic名称长度 64个字符 Topic名称长度不得超过该限制，否则会导致无法发送...

版本说明

本文介绍HTTP协议下Python SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的Python SDK收发消息。...已支持集群消费模式，暂不支持广播消费模式。暂不支持查询消息轨迹。mq-http-python-sdk-1.0.0.zip

查看订阅关系

在云消息队列 RocketMQ 版控制台，您可实时查看Group ID和Topic之间的订阅关系，即某个Topic被哪些Group ID订阅了，以及某个Group ID订阅了哪些Topic。前提条件 Group ID处于在线状态。什么是订阅关系云消息队列 RocketMQ 版里的一个...

版本说明

本文介绍HTTP协议下Node.js SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的Node.js SDK收发消息。...已支持集群消费模式，暂不支持广播消费模式。暂不支持查询消息轨迹。mq-http-nodejs-sdk-1.0.0.zip

版本说明

本文介绍HTTP协议下Go SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的Go SDK收发消息。...已支持集群消费模式，暂不支持广播消费模式。暂不支持查询消息轨迹。mq-http-go-sdk-1.0.0.zip

开通消息队列服务并授权

在阿里云官方网站开通消息队列服务后方可开始使用云消息队列 RocketMQ 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的云消息队列 RocketMQ 版资源，并使用资源通过SDK收发消息。前提条件您已注册...

开通消息队列服务并授权

在阿里云官方网站开通消息队列服务后方可开始使用云消息队列 RocketMQ 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的云消息队列 RocketMQ 版资源，并使用资源通过SDK收发消息。前提条件您已注册...

收发定时消息和延时消息

背景信息定时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点之后的某一个时间投递到Consumer进行消费，该消息即定时消息。延时消息：Producer将消息发送到云消息队列 ...

RAM主子账号授权

仅限有权限的RAM用户可以通过云消息队列 RocketMQ 版控制台或API管理指定资源。应用场景企业A购买了云消息队列 RocketMQ 版服务，企业A的员工需要操作这些服务所涉及的资源，例如实例、Topic或Group资源，有的员工负责创建资源，有的...

4.x和5.x版本差异及兼容性说明

云消息队列 RocketMQ 版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云云消息队列 RocketMQ 版将为您提供更加稳定可靠的服务端5...

日志配置

客户端日志用于记录云消息队列 RocketMQ 版客户端运行过程中的异常，帮助您快速定位和修复问题。本文介绍如何为客户端开启日志打印功能、客户端日志的配置项说明以及如何自定义配置客户端日志。重要推荐您使用最新的RocketMQ 5.x系列SDK...

实例管理

实例是用于云消息队列 RocketMQ 版服务的虚拟机资源，会存储消息主题（Topic）和客户端ID（Group ID）信息。使用云消息队列 RocketMQ 版进行消息收发，必须先创建云消息队列 RocketMQ 版实例。本文介绍如何在云消息队列 RocketMQ 版...

签名机制

MQVersion：表示云消息队列 RocketMQ 版接口的版本号，当前版本即为2015-06-06。CanonicalizedResource：表示HTTP所请求资源的URI（统一资源标识符），如消费请求的URI/topics/abc/messages?consumer=GID_abc。说明用来签名的字符串为...

8 \-e canal.instance.tsdb.enable=true \-e canal.instance.gtidon=false \-e canal.serverMode=rocketMQ \-e canal.aliyun.accessKey=xxx \-e canal.aliyun.secretKey=xxx \-e canal.mq.accessChannel=cloud \-e rocketmq.namesrv.addr='...

收发顺序消息

顺序消息（FIFO消息）是云消息队列 RocketMQ 版提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的社区版Java SDK收发顺序消息的示例代码供您参考。背景信息顺序消息分为两类：全局顺序：对于指定的一个Topic，...

默认配置映射关系

同构消息映射关系当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流实现RocketMQ消息路由基于事件流实现Kafka消息路由基于事件流实现RabbitMQ消息路由基于事件流实现MNS消息路由异构消息映射关系当消息的...

Demo工程

本文以社区版Apache RocketMQ Client为例，提供操作示例帮助您从零开始搭建阿里云云消息队列 RocketMQ 版收发消息的测试工程。Demo工程包含普通消息、顺序消息、事务消息的测试代码。前提条件安装IDE。您可以使用IntelliJ IDEA或者...

收发普通消息（三种方式）

阿里云云消息队列 RocketMQ 版提供三种方式来发送普通消息：同步发送、异步发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、使用场景、示例代码，以及三种发送方式的对比；此外还提供了订阅普通消息的示例代码。前提条件您已...

RAM主子账号授权

仅限有权限的RAM用户在云消息队列 RocketMQ 版的控制台上管理资源，以及通过SDK/API发布与订阅消息。应用场景企业A购买了云消息队列 RocketMQ 版服务，企业A的员工需要操作这些服务所涉及的资源，例如实例、Topic或Group资源，有的...

版本说明

本文介绍HTTP协议下C#SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的C#SDK收发消息。...已支持集群消费模式，暂不支持广播消费模式。暂不支持查询消息轨迹。mq-http-csharp-sdk-1.0.0.zip

实例规格

云消息队列 RocketMQ 版实例按照规格分为企业铂金版和标准版，您可以参照以下版本对比信息，选择所需实例规格。企业铂金版和标准版对比如下表所示：项目企业铂金版标准版付费方式包年包月（预付费）按量付费（开通服务，默认后付费）...

权益分发

方案架构因为云消息队列 RocketMQ 版具有重试功能且能保证消息不丢失，所以推出此方案来确保DB和缓存数据的强一致性，即在DB和缓存间使用云消息队列 RocketMQ 版，架构如下图所示。方案优势云消息队列 RocketMQ 版有以下优势：巨大的...

开服地域

本文介绍云消息队列 RocketMQ 版支持的地域。公共云地区地域名称地域ID TCP协议接入 HTTP协议接入亚太华东1（杭州）cn-hangzhou 华东2（上海）cn-shanghai 华北1（青岛）cn-qingdao 华北2（北京）cn-beijing 华北3（张家口）...

示例代码

云消息队列 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...

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

8 \-e canal.instance.tsdb.enable=true \-e canal.instance.gtidon=false \-e canal.serverMode=rocketMQ \-e canal.aliyun.accessKey=xxx \-e canal.aliyun.secretKey=xxx \-e canal.mq.accessChannel=cloud \-e rocketmq.namesrv.addr='...

消息存储和清理机制

本文为您介绍云消息队列 RocketMQ 版中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息参考云消息队列 RocketMQ 版中队列的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...

消息轨迹

在分布式应用中，云消息队列 RocketMQ 版作为全链路中异步解耦的关键服务，提供的消息轨迹数据可有效将业务上下游信息串联起来，帮助您更好地排查异常信息，定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版定义的轨迹参数...

仪表盘

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

默认配置映射关系

同构消息映射关系当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流实现RocketMQ消息路由基于事件流实现Kafka消息路由基于事件流实现RabbitMQ消息路由基于事件流实现MNS消息路由异构消息映射关系当消息的...

领域模型概述

本文为您介绍云消息队列 RocketMQ 版的领域模型。产品定位云消息队列 RocketMQ 版是一款典型的分布式架构下的中间件产品，使用异步通信方式和发布订阅的消息传输模型。通信方式和传输模型的具体说明，请参见下文通信方式介绍和消息...

函数计算

本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为云消息队列 Kafka 版的消息流出任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已开通函数计算服务，具体...

参数说明

本文介绍您在使用社区版Java SDK接入阿里云云消息队列 RocketMQ 版时，需要配置的参数。通用参数参数名参数说明 NAMESRV_ADDR 设置TCP协议接入点，从云消息队列 RocketMQ 版控制台的实例详情页面获取。AccessKey AccessKey ID，...

重试和死信

本文介绍消息集成默认支持的重试和死信策略。重试策略重试策略即任务处理过程中出现失败时的重试方式，当前重试策略支持退避重试和指数衰减重试。...说明当前仅支持将死信发送至云消息队列 RocketMQ 版和消息服务MNS。

rocketmq集群

新品推荐