收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
消息服务MNS中删除消息时报“message not exist”的...
本文介绍了当MNS删除消息时返回“message not exist”的问题描述、问题原因和解决方案。问题描述 消息服务MNS中删除消息时报如下错误。...如果 VisibilityTimeout 设置得太大，当消息处理失败时，将不能在短时间内再次处理该条消息。
应用场景
相较于以日志为中心的系统，例如Scribe和Flume，云消息队列 Kafka 版 在具备高性能的同时，可以实现更强的数据持久化以及更短的端到端响应时间。云消息队列 Kafka 版 的这种特性决定它适合作为日志收集中心。云消息队列 Kafka 版 忽略掉...
CreateTopic
Name Value API CreateTopic RAM授权操作 mns:CreateTopic 资源 acs:mns:$region:$accountid:/topics/$topicName 使用限制 主题名称是一个不超过255个字符的字符串，必须以字母或数字为首字符，剩余部分可以包含字母、数字和短划线（-）。...
消费者分组（ConsumerGroup）
本文介绍 云消息队列 RocketMQ 版 中消费者分组（ConsumerGroup）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...
MNS是否支持长轮询？
本文介绍 消息服务MNS 是否支持长轮询的问题。消息服务MNS 支持长轮询。与传统的短轮询相比，长轮询只会在消息进入队列或长轮询超时时才返回响应。一旦消息可用，长轮询可立即以简单经济的方式从您的队列检索消息。详情请参见 长轮询。
快速使用MQTT的Java SDK收发消息（终端和终端消息收发...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端与终端消息的收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 云消息队列 MQTT ...
快速使用MQTT的Java SDK收发消息（终端和云端消息收发...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端和云端服务的消息收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 MQTT终端和...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
MQTT快速入门
注意事项 云消息队列 MQTT 版 需搭配后端消息存储队列一起使用，具体说明如下：云消息队列 MQTT 版 实例是一个无状态网关类型实例，用来完成IoT移动场景下的客户端连接维持和消息转发，本身并不提供消息数据持久化功能，具体的消息存储和...
使用限制
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。消息...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
云消息队列 RabbitMQ 版系统权限策略参考
在产品迭代过程中，云消息队列 RabbitMQ 版会向系统策略中添加新的权限，用来支持新的功能和能力。系统策略的更新将会影响所有授予了该策略的 RAM 身份，包括 RAM 用户、RAM 用户组和 RAM 角色。有关 RAM 权限策略的更多信息，请参阅 权限...
消息队列Kafka版系统权限策略参考
在产品迭代过程中，消息队列Kafka版会向系统策略中添加新的权限，用来支持新的功能和能力。系统策略的更新将会影响所有授予了该策略的 RAM 身份，包括 RAM 用户、RAM 用户组和 RAM 角色。有关 RAM 权限策略的更多信息，请参阅 权限策略概览...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
Topic管理
MQTT协议基于Pub/Sub模型，因此任何消息都属于一个Topic。根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，在使用 云消息队列 MQTT 版 前，需先创建该父级Topic资源。注意事项 Topic不能跨实例使用，例如不能使用实例B的接入点...
Group操作
在进行消息收发前，请先创建Group，本文介绍如何在 云消息队列 MQTT 版 控制台上创建、删除和查询Group。注意事项 同一实例下Group ID必须唯一，不同实例间的Group ID可以重复。Group ID必须以“GID_”或者“GID-”开头，长度限制为7~64个...
产品优势
本文主要介绍 云消息队列 RabbitMQ 版 相比于自建开源RabbitMQ所具备的优势，以便您更进一步了解 云消息队列 RabbitMQ 版。灵活易用 开箱即用 完全兼容 AMQP 0-9-1 标准协议，完全兼容RabbitMQ开源社区，快速迁移上云。全托管服务 一键开通...
订阅消息API
订阅者可通过调用订阅消息API来消费 云消息队列 RocketMQ 版 服务端中的消息。请求构造 请求行 GET/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID&tag=taga&numOfMessages=3&waitseconds=3 HTTP/1.1 重要 请求行总长度不能超过...
什么是云消息队列 RocketMQ 版？
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...
云消息队列 RocketMQ 版4.x系统权限策略参考
在产品迭代过程中，云消息队列 RocketMQ 版4.x会向系统策略中添加新的权限，用来支持新的功能和能力。系统策略的更新将会影响所有授予了该策略的 RAM 身份，包括 RAM 用户、RAM 用户组和 RAM 角色。有关 RAM 权限策略的更多信息，请参阅 ...
云消息队列 RocketMQ 版5.x系统权限策略参考
在产品迭代过程中，云消息队列 RocketMQ 版5.x会向系统策略中添加新的权限，用来支持新的功能和能力。系统策略的更新将会影响所有授予了该策略的 RAM 身份，包括 RAM 用户、RAM 用户组和 RAM 角色。有关 RAM 权限策略的更多信息，请参阅 ...
主题使用手册
} 步骤六：从队列接收和删除消息 消息从主题推送到队列后，从队列中取出并删除该条消息。try {/调用receiveMessage函数进行消息的拉取。waitSeconds非0表示这次receiveMessage是一次http long polling，如果queue内没有message，那么这次...
创建并管理业务实体
若您选择创建 普通对象、业务事件、业务流程 实体类型，您还需填写以下配置参数：实体类型 参数 普通对象 继承自实体、关联实体 业务事件 关联实体 业务流程 前序业务流程、关联实体、流程事件 参数说明：继承自实体：即选择当前业务对象的...
ChangeMessageVisibility
调用ChangeMessageVisibility接口，修改被消费过并且还处于Inactive状态的消息与其下次可被消费的时间间隔。授权信息 默认仅限阿里云账号使用本接口，RAM用户只有在被授予了相关API操作权限后方可使用。本接口的授权信息如下表所示。更多...
新零售电子价签解决方案（MQTT）
新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...
Subscribe
mns:Subscribe 资源 acs:mns:$region:$accountid:/topics/$topicName/subscriptions/$subscriptionName 使用说明 Subscription名称是一个不超过255个字符的字符串，必须以字母或者数字为首字符，剩余部分可以包含字母、数字和短划线（-）。...
Subscribe
Subscription名称是一个不超过255个字符的字符串，必须以字母或者数字为首字符，剩余部分可以包含字母、数字和短划线（-）。创建Subscription时，需要指定对应的Endpoint，否则不合法。Request 请求消息由以下几部分组成：请求行 PUT/...
开源对比
本文从稳定性、内核能力、治理能力以及使用习惯等方面，对比阿里云 云消息队列 Kafka 版 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka 版 Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...
Group导入/导出
云消息队列 RocketMQ 版 支持将指定实例的Group列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Group的跨实例迁移。你可以在更换实例或者克隆实例时，使用Group导入/导出功能快速批量创建出相同的Group。背景信息 您可以...
签名鉴权模式
如果您需使用 云消息队列 MQTT 版 的签名鉴权模式，可根据本文提供的签名计算方式获取签名，再使用控制台来验证计算得出的签名是否正确。签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，...
签名鉴权模式
如果您需使用 云消息队列 MQTT 版 的签名鉴权模式，可根据本文提供的签名计算方式获取签名，再使用控制台来验证计算得出的签名是否正确。签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，...
音视频通信解决方案（MQTT）
音视频通信解决方案是由阿里云 云消息队列 MQTT 版 和音视频通信RTC联合推出的有助于快速搭建各种实时通信场景产品，譬如在线音视频会议、1对1语音通话应用的解决方案。本文将详细描述该解决方案的系统架构、数据流设计以及相关注意事项。...
服务关联角色
本文介绍 云消息队列 RabbitMQ 版 服务关联角色的背景信息，权限策略、注意事项和常见问题。背景信息 服务关联角色是某个云服务在某些情况下，为了完成自身的某个功能，需要获取其他云服务的访问权限而提供的RAM角色。您在该云服务的控制台...
授权信息
操作（Action）下表是 消息队列Kafka版（AliKafka）定义的操作，这些操作可以在RAM权限策略语句的 Action 元素中使用，用来授予执行该操作的权限。下面对表中的具体项提供说明：操作：是指具体的权限点。API：是指操作对应的API接口。访问...
CreateQueue
Name Value API CreateQueue RAM授权操作 mns:CreateQueue 资源 acs:mns:$region:$accountid:/queues/$queueName 使用说明 队列名称为不超过120个字符的字符串，必须以字母或数字为首字符，剩余部分可以包含字母、数字和短划线（-）。...
自由使用Group
前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且该实例必须满足以下条件：项目 说明 状态 服务中。版本 大版本为2.2.0，且小版本为最新版本。说明 您可以在 云消息队列 Kafka 版 控制台的 实例详情 页面的 基础信息 区域查看实例的...
使用限制
云消息队列 RabbitMQ 版 对集群、接口调用以及字符进行了限制，您在使用 云消息队列 RabbitMQ 版 时注意不要超过相应的限制值，以免程序出现异常。集群限制 限制项 Serverless版 专业版 企业版 铂金版 单实例的Vhost数量 200 单实例的Vhost...
服务关联角色
本文介绍 云消息队列 Kafka 版 服务关联角色的背景信息、策略内容、注意事项和常见问题。背景信息 服务关联角色是某个云服务在某些情况下，为了完成自身的某个功能，需要获取其他云服务的访问权限而提供的RAM角色。您在该云服务的控制台...
- 产品推荐
- 这些文档可能帮助您