消息发送重试和流控机制
消息流控 云消息队列 RocketMQ 版 的流控机制主要为您解答如下问题：系统在什么情况下会触发流控？触发流控时客户端行为是什么？应该如何避免触发流控，以及如何应对突发流控？消息发送重试机制 重试基本概念 云消息队列 RocketMQ 版 客户...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
基本概念
消息堆积 Producer已经将消息发送到 云消息队列 RocketMQ 版 的服务端，但由于Consumer消费能力有限，未能在短时间内将所有消息正确消费掉，此时在 云消息队列 RocketMQ 版 的服务端保存着未被消费的消息，该状态即消息堆积。消息堆积量=...
Exactly-Once投递语义
什么是Exactly-Once投递语义 Exactly-Once是指发送到消息系统的消息只能被消费端处理且仅处理一次，即使生产端重试消息发送导致某消息重复投递，该消息在消费端也只被消费一次。Exactly-Once语义是消息系统和流式计算系统中消息流转的最...
计费常见问题
本文汇总了 云消息队列 RocketMQ 版 计费的常见问题。每天扣除2元，这是什么费用？我昨天删除了Topic，为什么今天会收到账单并被扣费？我没有使用 云消息队列 RocketMQ 版 服务，为什么会扣费？我在控制台上看到没有开通 云消息队列 ...
收发事务消息
以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");发送消息，只要不抛出异常，就代表发送成功。try {/消息队列RocketMQ版不负责...
使用限制
在以下使用情况中出现的问题 云消息队列 MQTT 版 产品方概不负责：客户端不使用域名接入而是使用IP地址接入，产品方更新了域名解析导致原有IP地址失效。客户端网络对IP地址设置网络防火墙策略，产品方更新了域名解析后新IP地址被您的防火墙...
收发事务消息
当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...
服务关联角色
常见问题 为什么我的RAM用户无法自动创建消息队列RocketMQ版服务关联角色AliyunServiceRoleForOns？如果阿里云账号已经创建了服务关联角色，RAM用户就会继承该阿里云账号的服务关联角色。如果没有继承，请登录 RAM控制台 为其添加以下权限...
服务关联角色
常见问题 为什么我的RAM用户无法自动创建 云消息队列 RabbitMQ 版 服务关联角色AliyunServiceRoleForAmqpMonitoring或AliyunServiceRoleForAmqpLogDelivery？如果您的阿里云账号已经创建了服务关联角色，您的RAM用户就会继承该阿里云账号的...
服务关联角色
常见问题 为什么我的RAM用户无法自动创建 云消息队列 RocketMQ 版 服务关联角色AliyunServiceRoleForOns？如果阿里云账号已经创建了服务关联角色，RAM用户就会继承该阿里云账号的服务关联角色。如果没有继承，请登录 RAM控制台 为其添加...
什么是云消息队列 RocketMQ 版？
为什么选择云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 基于阿里云云原生优质的基础设施实现，兼容Apache RocketMQ的核心API和功能。相对于自建RocketMQ集群，云消息队列 RocketMQ 版 具有如下优势：架构先进性 全面采用存储和计算分离...
自动创建Topic
前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且该实例必须满足以下条件：项目 说明 状态 服务中 版本 大版本为2.2.0或以上版本，小版本为最新版本。说明 您可以在 云消息队列 Kafka 版 控制台的 实例详情 页面的 基础信息 区域查看...
服务关联角色
本文介绍 云消息队列 Kafka 版 服务关联角色的背景信息、策略内容、注意事项和常见问题。背景信息 服务关联角色是某个云服务在某些情况下，为了完成自身的某个功能，需要获取其他云服务的访问权限而提供的RAM角色。您在该云服务的控制台...
常见问题
产品功能常见问题 消息队列RocketMQ版5.x系列相比4.x系列实例有什么优势？消息队列RocketMQ版5.x系列实例兼容哪些版本客户端？消息队列RocketMQ版支持哪些语言客户端？消息队列RocketMQ版如何开通公网访问？顺序消息和普通消息的区别是什么...
集成概述
概念介绍—消息流出（Sink）消息流出的主要能力是将 云消息队列 Kafka 版 的数据流出到各类数据目标，Connector生态集成模块对 云消息队列 Kafka 版 的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
在以下使用情况中出现的问题 云消息队列 MQTT 版 产品方概不负责：客户端不使用域名接入而是使用IP地址接入，产品方更新了域名解析导致原有IP地址失效。客户端网络对IP地址设置网络防火墙策略，产品方更新了域名解析后新IP地址被您的防火墙...
常见问题
产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势？云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端？云消息队列 RocketMQ 版支持哪些语言客户端？云消息队列 RocketMQ 版如何开通公网访问？顺序消息和普通...
OnsInstanceCreate-创建实例
该接口一般在新业务发布需要创建新的服务资源的情况下使用。该接口只支持创建标准版实例，不支持创建铂金版实例。云消息队列 RocketMQ 版控制台同时支持创建标准版实例和铂金版实例，具体操作，请参见 实例管理。调试 您可以在OpenAPI ...
OnsGroupCreate-创建客户端Group ID
本接口一般是在发布新应用、业务逻辑实现等需要新的 Group 的情况下使用。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的...
MNS是否提供对消息的先入先出（FIFO）访问？
本文介绍 消息服务MNS 能否提供消息先入先出访问的问题。消息服务MNS 消费消息时尽量做到先进先出，正是因为分布式消息队列的一些特性并不能保证您能按照消息的发送顺序消费消息，如果您的业务必须先进先出，建议在消息中加入序号信息以便...
延时消息
如果您希望消息被投递后延迟一段时间被消费者消费，您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...
查看消费状态
常见问题 为什么Kafka分区消息堆积，下游消费却无异常？下游可能采用了 assign 消费模式，位点是您自己管理的。这种情况下虽然显示了堆积，实际上您可能已经消费了，但是没有提交位点。建议您及时手动提交位点解决消息堆积问题。消息消费...
使用云消息队列 Kafka 版时出现消息堆积
一般情况下，客户端消费流程大致如下：判断消息堆积是否属于正常情况 如果发现Group中出现消息堆积，请参见下列步骤，判断消息堆积是否属于正常情况：登录 云消息队列 Kafka 版控制台。在顶部菜单栏，选择地域。在左侧导航栏，单击 实例...
常见问题
MNS提供哪些可用的操作 主题订阅的使用限制 MNS是否支持长轮询 MNS是否提供对消息的先入先出（FIFO）访问 MNS是否可以与其他阿里云产品协作使用 MNS相对于自主研发、商用或开源的消息队列系统有什么优势 计费相关 删除队列后，是否继续计费...
消息堆积和延迟问题
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...
产品优势
云消息队列 Kafka 版 100%兼容开源，支持0.10.x~2.6.x的开源版本，无需代码改造无缝迁移上云，体验全托管、免运维的分布式消息队列服务。开箱即用 云消息队列 Kafka 版 100%兼容开源，使您无缝迁移上云。兼容开源：云消息队列 Kafka 版 100...
版本说明
ons-client-1.7.8.Final 更多历史版本 1.7.7.Final 发布时间 发布内容 下载 2018-04-25 问题修复 同一个进程内初始化多个Consumer或Producer实例的情况下，消息轨迹发送失败的问题，该问题在1.7.5.Final和1.7.6.Final版本中存在，建议进行...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
OnsConsumerAccumulate-查询消息消费堆积情况
查询指定Group ID的消息消费堆积情况，包括当前消息堆积数量和消费延迟时间等。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 Open...
版本说明
ons-client-1.7.8.Final 更多历史版本 1.7.7.Final 发布时间 发布内容 下载 2018-04-25 问题修复 同一个进程内初始化多个Consumer或Producer实例的情况下，消息轨迹发送失败的问题，该问题在1.7.5.Final和1.7.6.Final版本中存在，建议进行...
注意要点
本文介绍使用开源的客户端SDK接入 云消息队列 RabbitMQ 版 服务端时的注意事项。要点 说明 com.rabbitmq.client.ConnectionFactory 接口 设置 com.rabbitmq.client.ConnectionFactory 接口时，必须开启连接自动恢复功能，保证服务端升级时...
使用实例接入点收发消息
当使用应用程序与Kafka集群建立连接时，可通过实例接入点接入 云消息队列 Kafka 版 并收发消息。Kafka实例提供默认接入点、SSL接入点和SASL接入点，以满足您不同的连接和安全需求。默认接入点适用于在保密性较高的VPC环境收发消息；SASL接...
消息存储和清理机制
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...
云存储网关利用MQTT服务实现统一管控
建议Group ID按照CSG控制台所在的阿里云地域进行分类，例如 华东1（杭州）和 华东2（上海）采用不同的Group ID，方便定位出有问题的地域和消息队列。后缀Device ID：Device ID由应用生成。Device ID可以和每个CSG实例的ID进行一一映射，...
消息收发常见问题
本文介绍使用 云消息队列 MQTT 版 进行消息收发时的常见问题。为什么会出现一条消息同一时间重试多次？为什么消息会一直重试？消息发送时提示GroupID没有权限。使用RocketMQ数据流入MQTT功能时，为什么子级Topic后会多了一个“/”?消息发送...
- 产品推荐
- 这些文档可能帮助您