收发顺序消息
顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息按照严格的...
从自建MySQL同步至云消息队列 Kafka 版
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至 云消息队列 Kafka 版，扩展消息处理能力。前提条件 您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
计费常见问题
本文汇总了 云消息队列 RocketMQ 版 计费的常见问题。每天扣除2元，这是什么费用？我昨天删除了Topic，为什么今天会收到账单并被扣费？我没有使用 云消息队列 RocketMQ 版 服务，为什么会扣费？我在控制台上看到没有开通 云消息队列 ...
实例管理
使用 云消息队列 RocketMQ 版 进行消息收发，必须先创建 云消息队列 RocketMQ 版 实例。本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除、更新和查看实例详情。背景信息 云消息队列 RocketMQ 版 实例按照规格分为标准版和企业...
API概览
本产品（微消息队列 MQTT/2020-04-20）的OpenAPI采用 RPC 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求...
使用Kafka Connect将SQL Server数据同步至云消息队列 ...
如果是公网接入，需先设置java.security.auth.login.config，如果是VPC接入，可以跳过这一步。export KAFKA_OPTS="-Djava.security.auth.login.config=kafka_client_jaas.conf"启动Kafka Connect。bin/connect-distributed.sh config/...
常见问题
产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势？云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端？云消息队列 RocketMQ 版支持哪些语言客户端？云消息队列 RocketMQ 版如何开通公网访问？顺序消息和普通...
名词解释
根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，使用 云消息队列 MQTT 版 前，需先在控制台创建该父级Topic，可以在 云消息队列 MQTT 版 控制台创建，或者直接在 云消息队列 RocketMQ 版 的控制台创建。子级Topic（Subtopic）...
JMS Pub/Sub（主账号与RAM账号）
在收发消息时，您需要为发布端和订阅端配置该接入点，通过接入点接入 云消息队列 RabbitMQ 版 实例。登录 云消息队列 RabbitMQ 版 控制台，然后在左侧导航栏选择 实例列表。在 实例列表 页面的顶部菜单栏选择地域，然后在实例列表中，单击...
JMS P2P（主账号与RAM账号场景）
在收发消息时，您需要为发布端和订阅端配置该接入点，通过接入点接入 云消息队列 RabbitMQ 版 实例。登录 云消息队列 RabbitMQ 版 控制台，然后在左侧导航栏选择 实例列表。在 实例列表 页面的顶部菜单栏选择地域，然后在实例列表中，单击...
基本概念
全局顺序消息 对于指定的一个Topic，所有消息按照严格的先入先出（FIFO）的顺序进行发布和消费。更多信息，请参见 顺序消息。分区顺序消息 对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息按照严格的FIFO...
直播互动解决方案
根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，使用 云消息队列 MQTT 版 前，需先在控制台创建该父级Topic，可以在 云消息队列 MQTT 版 控制台创建，或者直接在 云消息队列 RocketMQ 版 的控制台创建。子级Topic（Subtopic）...
计费常见问题
我已经购买了包年包月微消息队列MQTT版实例，为什么发消息后，还会继续扣钱呢？包年包月（预付费）实例的费用只限于 云消息队列 MQTT 版 所支持的协议，即 云消息队列 MQTT 版 的消息传输以及消息存储。若您使用 云消息队列 MQTT 版 的数据...
排他队列
什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，包括该连接下所有建立的Channel。其他连接无法声明相同名称的排他队列，且其他连接以及连接下的Channel都无法访问该排他队列。连接断开时排他性...
快速入门概述
使用说明 权限说明 若您的账号为RAM用户，则必须先为该RAM用户进行授权，才能访问 云消息队列 RocketMQ 版，并对 云消息队列 RocketMQ 版 的指定资源进行增删改查操作。更多信息，请参见 权限概述。接入点说明 调用SDK收发消息时，需要在...
计费FAQ
本文汇总了 云消息队列 RabbitMQ 版 计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...
计费FAQ
本文汇总了 云消息队列 RabbitMQ 版 计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...
开通消息队列服务并授权
如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 RocketMQ 版 资源，并使用资源通过SDK收发消息。前提条件 您已注册阿里云账号并完成实名认证。更多信息，请参见 阿里云账号注册流程。步骤一：...
开通消息队列服务并授权
如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 RocketMQ 版 资源，并使用资源通过SDK收发消息。前提条件 您已注册阿里云账号并完成实名认证。更多信息，请参见 阿里云账号注册流程。步骤一：...
常见问题
使用云消息队列 Kafka 版时客户端的报错及解决方案 无法ping通云消息队列 Kafka 版的接入点 客户端消费问题 订阅者最佳实践 客户端首次接入云消息队列 Kafka 版时出现异常的排查方法 使用云消息队列 Kafka 版时出现消息堆积 为什么消费客户...
消息轨迹
同一MessageGroup的消息将遵循先进先出的顺序关系进行处理。事务消息 Check回调时间 半事务消息检查事务状态的回调时间。提交时间 事务消息被服务端提交给消费者消费的时间。回滚时间 事务消息回滚的时间。定时消息 预设定时时间 定时消息...
仪表盘
如下图所示，SDK内置了一个长轮询线程，先将消息异步拉取到SDK内置的缓存队列中，再分别提交到消费线程中，触发监听器执行本地消费逻辑。具体原理，请参见 PushConsumer。在PushConsumer消费场景下，本地缓冲队列相关指标如下：本地缓冲...
计费概述
云消息队列 RabbitMQ 版 提供包年包月预付费和Serverless按量后付费计费方式，每种计费方式的计费项和计费规则都有所差异，您可以按照不同的使用场景和业务规模选择合适计费方式及实例类型，达到成本最优化的效果。实例类型和计费模式 说明...
定时/延时消息
基于 云消息队列 RocketMQ 版 的定时消息可以封装出多种类型的定时触发器。典型场景二：任务超时处理 以电商交易场景为例，订单下单后暂未支付，此时不可以直接关闭订单，而是需要等待一段时间后才能关闭订单。使用 云消息队列 RocketMQ 版...
降低实例配置
如果您的 云消息队列 Kafka 版 实例的公网流量消耗远小于购买的公网流量配置，或者分区的使用量远小于购买的分区数量，您可以降低公网流量和分区数量配置，从而节约成本。本文介绍如何在 云消息队列 Kafka 版 控制台降低实例的公网流量、...
创建前提
例如，创建Tablestore Sink Connector，请先开通表格存储（Tablestore）服务。说明 若目标服务为SLS Sink Connector，可不开通函数计算服务。权限策略 阿里云账号：在控制台创建Connector时，控制台会弹出详细授权策略，按照控制台提示确认...
数据传输服务DTS
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将数据传输服务DTS中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。在...
标签管理
例如，云消息队列 RocketMQ 版 实例先添加了 city:shanghai 标签，后续如需添加 city:shenzhen 标签，需先删除 city:shanghai 标签。您可以参见 标签最佳实践 了解设计标签键值的建议。使用限制 键（Key）的最大长度：64个Unicode字符，...
迁移消费者程序
本文介绍如何将自建Kafka集群上的消费者程序平滑地迁移到 云消息队列 Kafka 版。背景信息 云消息队列 Kafka 版 控制台提供迁移实例功能，您可以使用该功能将自建Kafka集群或其他云Kafka集群的元数据（Topic和Group配置信息）和消息数据同步...
使用AMQProxy解决PHP等客户端Connection复用问题
当您在客户端服务器部署AMQProxy后，客户端和 云消息队列 RabbitMQ 版 之间的请求都会先发送到AMQProxy，然后由AMQProxy转发到对方。AMQProxy处理客户端发起的Connection相关请求的逻辑如下：如果客户端发送开启Connection的请求，AMQProxy...
OnsDLQMessageResendById-重发指定的死信消息
由于死信消息是经过重试逻辑依然消费失败的消息，通常意味着消费逻辑可能存在问题，故请先查明多次消费失败的原因，再调用本接口重新发送。当前消息队列 RocketMQ 版不管理死信重发的状态，重发后消费成功的消息不会从死信队列中移除。需...
消息收发常见问题
本文介绍使用 云消息队列 MQTT 版 进行消息收发时的常见问题。为什么会出现一条消息同一时间重试多次？为什么消息会一直重试？消息发送时提示GroupID没有权限。使用RocketMQ数据流入MQTT功能时，为什么子级Topic后会多了一个“/”?消息发送...
消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
消息堆积和延迟问题
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...
如何处理不活跃的Topic
详细信息 请先判断Topic的活跃状况，对于不活跃的Topic，您可以考虑进行删除，具体步骤如下。判断Topic的活跃状况 判断Topic是否活跃主要依靠下列2个关键指标。当前服务器上消息总量（TotalCount）消息最后更新时间（LastTimeStamp）一般...
通过RAM角色实现跨云账号授权
STS Token配置示例 初始化 云消息队列 RocketMQ 版 的客户端时，您只需将获取到的AccessKey ID、AccessKey Secret和SecurityToken填入到以下属性中即可：Properties properties=new Properties();请确保环境变量ALIBABA_CLOUD_ACCESS_KEY_...
实例生命周期管理
预付费（包年包月）实例 预付费（包年包月）实例生命周期各阶段状态 部署实例（1→2）：当购买了 云消息队列 Kafka 版 实例后，实例处于 未部署 状态，若您需要使用该实例，请先在控制台上完成部署，部署成功后，实例状态切换为 服务中。...
将云消息队列 Kafka 版的数据迁移至MaxCompute
本文介绍如何使用DataWorks数据同步功能，将 云消息队列 Kafka 版 集群上的数据迁移至阿里云大数据计算服务MaxCompute，方便您对离线数据进行分析加工。前提条件 在开始本教程前，确保您在同一地域中已完成以下操作：云消息队列 Kafka 版 ...
Group操作
在进行消息收发前，请先创建Group，本文介绍如何在 云消息队列 MQTT 版 控制台上创建、删除和查询Group。注意事项 同一实例下Group ID必须唯一，不同实例间的Group ID可以重复。Group ID必须以“GID_”或者“GID-”开头，长度限制为7~64个...
收发事务消息
设置TCP接入域名，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看。factoryInfo.setFactoryProperty(ONSFactoryProperty:NAMESRV_ADDR,"XXX");您在消息队列RocketMQ版控制台创建的Topic。factoryInfo.setFactoryProperty...
- 产品推荐
- 这些文档可能帮助您