如果消息消费出现异常,您可以在 云消息队列 RocketMQ 版 控制台查看指定Group ID的消费状态,包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等,帮助您快速定位异常原因。应用场景 消费者状态信息包括在线...
云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域,已成为大数据生态中不可或缺的部分。产品优势 云消息队列 ...
云消息队列 MQTT 版 支持基于X.509证书的双向认证,分别通过服务器证书和设备证书完成服务端和客户端的认证,本文介绍如何在 云消息队列 MQTT 版 控制台管理证书。注意事项 仅铂金版、专业版实例支持双向认证能力,基础版和Serverless版...
定义 生产者是 云消息队列 RocketMQ 版 系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中,将业务消息按照要求封装成 云消息队列 RocketMQ 版 的 消息(Message)并发送至服务端。在消息生产者中,可以定义如下...
阿里云 云消息队列 RocketMQ 版 提供类似X/Open XA的分布式事务功能,通过阿里云 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息,请参见 事务消息。前提条件 安装CPP动态...
针对该问题,阿里云 云消息队列 RocketMQ 版 推出了权益分发解决方案。本文将以电商场景为例说明权益分发解决方案的背景信息、方案架构、以及方案优势等内容。背景信息 在电商平台运营决定对特定用户进行营销活动时,会针对不同的用户群...
使用发送消息API从生产者发送消息至 云消息队列 RocketMQ 版 服务端。请求构造 请求行 POST/topics/TopicName/messages?ns=INSTANCE_ID HTTP/1.1 参数说明如下。参数 是否必选 说明 TopicName 是 将消息发送至的Topic名称。ns 否 实例ID,...
欠费影响 如果您购买的为包年包月实例,实例到期后,您账户下的 云消息队列 Kafka 版 服务会切换为 已过期 状态,即您将不能再继续使用 云消息队列 Kafka 版 服务。如果您购买的为按量计费实例 或弹性按量计费实例,当您的账户余额不足以...
云消息队列 RabbitMQ 版 会对单实例的TPS流量峰值进行限流,本文介绍 云消息队列 RabbitMQ 版 实例的限流规则、限流后的行为以及限流最佳实践等。限流后行为 当 云消息队列 RabbitMQ 版 实例的TPS流量峰值超过您所购买实例的TPS规格上限时...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务,将 云消息队列 RabbitMQ 版 中的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和...
借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力,云消息队列 Kafka 版 提供仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标,进而快速了解业务的运行状态。前提条件 开通ARMS Prometheus监控服务 ...
普通消息是指阿里云 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时消息、顺序消息和事务消息。本文提供使用TCP协议下的社区版C++ SDK收发普通消息的示例代码供您参考。前提条件 安装CPP动态库 获取阿里云访问密钥AccessKey ...
步骤一:开通消息服务MNS 登录 阿里云官网,选择 产品>中间件>云消息队列>消息服务 MNS。在产品页,单击 立即开通。请仔细阅读 消息服务MNS服务协议,选中 消息服务MNS服务协议,然后单击 立即开通。页面显示 恭喜,开通成功!步骤二:...
在调用SDK收发消息前,您需要提前创建 云消息队列 RocketMQ 版 的相关资源,包括创建 云消息队列 RocketMQ 版 实例、获取实例的接入点、创建Topic、创建ConsumerGroup。调用SDK时,需要将这些资源信息填写到SDK代码中。前提条件 创建专有...
迁移元数据上云是指将开源RabbitMQ集群的元数据导出,并将其导入到阿里云 云消息队列 RabbitMQ 版 实例。云消息队列 RabbitMQ 版 会根据成功导入的元数据在目标 云消息队列 RabbitMQ 版 实例中创建对应的Vhost、Queue、Exchange、Binding,...
消息收发费用 消息收发为 云消息队列 RocketMQ 版 的基础功能,您只要开通 云消息队列 RocketMQ 版 服务,则默认使用消息收发功能,标准版实例会计算相应费用。具体计费详情,请参见 消息收发定价详情。公网费用 云消息队列 RocketMQ 版 ...
使用 云消息队列 RocketMQ 版 服务的应用程序需要部署在阿里云ECS上。v2.x.x版本的C++ SDK暂时仅支持Linux操作系统,系统版本包含CentOS 6(RHEL 6)和CentOS 7(RHEL 7)系列。C++ SDK的下载链接,请参见 版本说明。下载完成后选择对应...
概念介绍 定时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端,但并不期望立马投递这条消息,而是推迟到在当前时间点之后的某一个时间投递到Consumer进行消费,该消息即定时消息。延时消息:Producer将消息发送到 云消息队列 ...
本文介绍如何在 云消息队列 Kafka 版 控制台创建迁移任务,将元数据迁移至 云消息队列 Kafka 版 已有实例。前提条件 下载JDK 8 购买并部署 云消息队列 Kafka 版 实例:购买并部署VPC实例 购买并部署公网/VPC实例 背景信息 Kafka集群元数据...
在分布式应用中,云消息队列 RocketMQ 版 作为全链路中异步解耦的关键服务,提供的消息轨迹数据可有效将业务上下游信息串联起来,帮助您更好地排查异常信息,定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数...
使用 云消息队列 RocketMQ 版 服务的应用程序需要部署在阿里云ECS上。v2.x.x及以上版本的C++ SDK暂时仅支持Linux操作系统,系统版本包含CentOS 6(RHEL 6)和CentOS 7(RHEL 7)系列。C++ SDK的下载链接,请参见 版本说明。下载完成后选择...
Token API 标题 API概述 QueryToken 校验Token的有效性 Token鉴权方式下,云消息队列 MQTT 版服务端会颁发Token(临时凭证)给客户端,客户端访问云消息队列 MQTT 版服务端时需要携带Token用于权限验证。Token为临时访问凭证具有一定的时效...
本文主要对 云消息队列 RabbitMQ 版 涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用 云消息队列 RabbitMQ 版。A Alternate Exchange 备份Exchange,简称AE,用于接收配置了备份Exchange的Exchange路由失败的消息。...
RAM用户默认没有 云消息队列 RocketMQ 版 资源的操作权限。如果您的账号为RAM用户,必须先为RAM用户进行授权,才能通过控制台或OpenAPI管理 云消息队列 RocketMQ 版 的资源。背景信息 本操作仅针对RAM用户,若您的账号为阿里云账号,则默认...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务,将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 Kafka 版 实例中。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买...
消息服务MNS 的消息过滤功能是指将一个主题的消息通过不同的标签推送到不同的订阅渠道。本文介绍消息过滤的功能以及如何设置消息过滤标签。背景信息 通常情况下,在主题中创建订阅可以将消息推送至已订阅的推送目标。即消息没有设置消息...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务,将 云消息队列 RocketMQ 版 的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买Kafka实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和部署实例。您已...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务,将 云消息队列 Kafka 版 的数据导出至 云消息队列 RabbitMQ 版。前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且实例处于服务中状态。具体步骤,请参见 步骤二:购买和...
本文介绍 云消息队列 RocketMQ 版 中订阅关系(Subscription)的定义、模型关系、内部属性及使用建议。定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端...
和开源Apache RocketMQ相比,阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验,本文为您介绍开源RocketMQ集群迁移上云的方案...
和开源Apache RocketMQ相比,阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验。本文为您介绍如何使用 云消息队列 RocketMQ 版...
迁移前须知 云消息队列 RabbitMQ 版 是阿里云基于专有的分布式消息存储技术开发的高级消息队列服务。它严格遵循AMQP 0-9-1协议,但并不是开源RabbitMQ的简单托管版本。云消息队列 RabbitMQ 版 采用了独创的架构设计,有效避免了因消息积压...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务,将指定 云消息队列 Kafka 版 实例中的数据导出至其他的 云消息队列 Kafka 版。前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见...
SDK兼容性说明 云消息队列 RocketMQ 版 服务端版本和客户端SDK版本的兼容情况如下,为了获得更完善的产品功能和更高的性能,建议您使用5.x版本实例,并优先通过RocketMQ 5.x系列SDK接入服务端。服务端版本 客户端版本 兼容性 约束限制 5.x...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务,将指定 云消息队列 Kafka 版 实例中的数据快速导入至另外的 云消息队列 Kafka 版 实例中。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请...
如果您使用的是HTTP协议公网接入点访问 云消息队列 RocketMQ 版 服务端,生产和消费消息过程中会产生公网流量。云消息队列 RocketMQ 版 将在2021年12月15日0点开始按量收取公网流量费用,特此通知。公网下行流量费收费详情,请参见 公网...
云消息队列 RocketMQ 版 支持消息重试功能,即Consumer消费某条消息失败或消费超时,云消息队列 RocketMQ 版 会根据消息重试机制重新投递消息。本文介绍 云消息队列 RocketMQ 版 分别在HTTP协议和TCP协议下的消息重试策略。注意事项 一条...
问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时,报QueueHasDiffField类型错误。例如QueueHasDiffField[OAutoDelete=false&NAutoDelete=true;说明 报错中O开头的参数的属性值为要调用的Queue的参数的已...
云消息队列 Kafka 版 服务端支持收发压缩消息。如需使用压缩消息,您需要在 云消息队列 Kafka 版 的客户端进行设置。在 云消息队列 Kafka 版 客户端进行消息压缩的说明如下:压缩格式:支持Snappy、LZ4、GZIP等压缩格式。其中,GZIP对CPU的...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务,将 云消息队列 Kafka 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已...