音视频通信解决方案（MQTT）
收发消息参数设计 由于移动App可能存在应用切入后台被杀死（Kill）导致移动App不在线的情况，需对终端App做以下配置，以确保终端App离线重连后可以收到之前的消息：cleanSession 参数设置为“false”QoS 设置成“1”终端App应该对收到的...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Node.js SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示...
云消息队列 RocketMQ 版5.x系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
产品优势
云消息队列 Kafka 版 100%兼容开源，支持0.10.x~2.6.x的开源版本，无需代码改造无缝迁移上云，体验全托管、免运维的分布式消息队列服务。开箱即用 云消息队列 Kafka 版 100%兼容开源，使您无缝迁移上云。兼容开源：云消息队列 Kafka 版 100...
云消息队列 RocketMQ 版自定义权限策略
什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您来维护。创建自定义权限策略后，需为RAM用户、用户组或RAM角色绑定权限...
SDK FAQ
如果您需追踪和识别消息，可以在 云消息队列 RabbitMQ 版 的Producer客户端设置Message ID属性，为每条消息设置唯一标识符。在 云消息队列 RabbitMQ 版 的Producer客户端设置 Basic.Properties 的 message-id 属性。示例代码如下：Java ...
收发定时消息
Message Tag，可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤"TagA",/Message Body，不能为空，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反...
按量计费转包年包月
转换后费用可预见，可以节省成本、避免意外费用。转变实例的付费类型只会影响实例的计费，不会影响实例的使用，您无需对客户端代码做任何修改。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例运行状态处于 服务中 或 未部署。...
常见问题
产品功能常见问题 消息队列RocketMQ版5.x系列相比4.x系列实例有什么优势？消息队列RocketMQ版5.x系列实例兼容哪些版本客户端？消息队列RocketMQ版支持哪些语言客户端？消息队列RocketMQ版如何开通公网访问？顺序消息和普通消息的区别是什么...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Go SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Go SDK。更多信息，请参见 准备环境。...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Go SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C#SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装C#SDK。更多信息，请参见 准备环境。...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
客户端连接常见问题
根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，使用 云消息队列 MQTT 版 前，需先在控制台创建该父级Topic，可以在 云消息队列 MQTT 版 控制台创建，或者直接在 云消息队列 RocketMQ 版 的控制台创建。子级Topic（Subtopic）...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C++ SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装C++ SDK。更多信息，请参见 准备环境...
签名鉴权模式
如果您需使用 云消息队列 MQTT 版 的签名鉴权模式，可根据本文提供的签名计算方式获取签名，再使用控制台来验证计算得出的签名是否正确。签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，...
收发定时消息和延时消息
实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。instanceId:="${INSTANCE_ID}"client:=mq_http_sdk.NewAliyunMQClient(endpoint,accessKey,secretKey,"")mqProducer:=client.GetProducer(instanceId,topic)/循环发送4条...
准备工作
RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续仅做功能维护，建议仅存量业务使用。操作步骤 通过下面两种方式可以引入依赖（任选一种）：使用Maven方式引入依赖。groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
SendMessage-向云消息队列 MQTT 版发送单条消息
从服务端应用向云消息队列 MQTT 版发送单条消息。接口说明 SendMessage 接口为服务端应用调用，与 MQTT 客户端发送消息互补。服务端和客户端的使用场景区别，请参见 开发指南使用指引。调用 SendMessage 接口前，请确认您的云消息队列 MQTT...
准备工作
RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续仅做功能维护，建议仅存量业务使用。操作步骤 通过下面两种方式可以引入依赖（任选一种）：使用Maven方式引入依赖。groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Java SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Java SDK。更多信息，请参见 准备...
主题（Topic）
定义数据的身份和权限 云消息队列 RocketMQ 版 的消息本身是匿名无身份的，同一分类的消息使用相同的主题来做身份识别和权限管理。模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中，主题所处的流程和位置如下：主题是 云消息队列 ...
收发定时消息和延时消息
实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。private const string_instanceId="${INSTANCE_ID};private static MQClient_client=new Aliyun.MQ.MQClient(_accessKeyId,_secretAccessKey,_endpoint);static ...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的C#SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的...
收发定时消息和延时消息
实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。string instanceId="${INSTANCE_ID};MQProducerPtr producer;if(instanceId=""){ producer=mqClient.getProducerRef(topic);} else { producer=mqClient.getProducerRef...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Java SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
迁移数据上云
本文介绍如何使用MirrorMaker将自建Kafka集群的数据迁移到 云消息队列 Kafka 版 集群。前提条件 您已完成以下操作：下载迁移工具MirrorMaker 迁移Topic上云 背景信息 Kafka的镜像特性可实现Kafka集群的数据备份。实现这一特性的工具就是...
消息（Message）
本文介绍 云消息队列 RocketMQ 版 中消息（Message）的定义、模型关系、内部属性、行为约束及使用建议。定义 消息是 云消息队列 RocketMQ 版 中的最小数据传输单元。生产者将业务数据的负载和拓展属性包装成消息发送到 云消息队列 RocketMQ...
收发定时消息和延时消息
实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。final String instanceId="${INSTANCE_ID};获取Topic的生产者。MQProducer producer;if(instanceId!null&instanceId!{ producer=mqClient.getProducer(instanceId,...
应用场景
本文为您介绍 云消息队列 RocketMQ 版 的应用场景，以便您更好地判断如何在业务中使用 云消息队列 RocketMQ 版。例如，针对一家互联网电商企业，其业务涉及广泛，如注册、订单、库存、物流等；同时，也会涉及许多业务峰值时刻，如秒杀活动...
消息收发常见问题
本文介绍使用 云消息队列 MQTT 版 进行消息收发时的常见问题。为什么会出现一条消息同一时间重试多次？为什么消息会一直重试？消息发送时提示GroupID没有权限。使用RocketMQ数据流入MQTT功能时，为什么子级Topic后会多了一个“/”?消息发送...
新零售电子价签解决方案（MQTT）
新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...
查看订阅关系
什么是订阅关系 云消息队列 RocketMQ 版 里的一个Group ID代表一个Consumer实例群组。对于大多数分布式应用来说，一个Group ID下通常会挂载多个Consumer实例。云消息队列 RocketMQ 版 的订阅关系主要由Topic+Tag共同组成，即一个Group ID下...
应用场景
通过 云消息队列 Kafka 版 的发布/订阅模型，您可以实时收集网站活动数据（例如注册、登录、充值、支付、购买），根据业务数据类型将消息发布到不同的Topic，然后利用订阅消息的实时投递，将消息流用于实时处理、实时监控或者加载到Hadoop...
功能使用相关问题
本文汇总了 云消息队列 MQTT 版 功能使用相关的常见问题。离线消息最多能保留多久？3天。仅当 QoS=1且 cleanSession=false时，云消息队列 MQTT 版 才会保留离线消息，最多保留3天，超过时间将自动滚动删除。铂金版实例可支持定制。如需定制...
权限策略
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。本文介绍 云...
准备环境
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容.NET 1.x/2.x SDK客户端接入，您可以使用1.x/2.x版本的SDK接入5.x实例进行消息收发。本文为您介绍1.x/2.x版本下的.NET SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列...
- 产品推荐
- 这些文档可能帮助您