队列实现-队列实现文档介绍内容-阿里云

延时消息

方案对比云消息队列 RabbitMQ 版无需进行代码改造，即可实现开源RabbitMQ的所有延时消息方案，详情请参见下表：项目开源RabbitMQ 云消息队列 RabbitMQ 版死信Exchange+Queue的消息存活时间支持支持死信Exchange+消息的消息存活时间 ...

怎样让Consumer不立即消费消息并使消息重入队列？

使用basicReject方法否定应答单条消息并使消息重入队列您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下：deliveryTag：Channel的消息投递的唯一标识符。requeue：被否定应答的消息...

怎样让Consumer不立即消费消息并使消息重入队列？

使用basicReject方法否定应答单条消息并使消息重入队列您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下：deliveryTag：Channel的消息投递的唯一标识符。requeue：被否定应答的消息...

接口和参数说明

云消息队列 RocketMQ 版提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从云消息队列 RocketMQ 版获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息云消息队列 RocketMQ 版支持以下两种消息获取方式：Push...

功能发布列表

优化 TCP Java SDK版本说明 2023-05-11 实例系列功能名称功能描述变更类型相关文档 4.x系列实例 5.x系列实例 Topic导入/导出功能支持将实例下的Topic资源列表导出并导入至其他的云消息队列 RocketMQ 版实例中，实现跨实例Topic源...

消费进度管理

说明消费位点的保存和恢复是基于云消息队列 RocketMQ 版服务端的存储实现，和任何消费者无关。因此云消息队列 RocketMQ 版支持跨消费者的消费进度恢复。队列中消息位点MinOffset、MaxOffset和每个消费者分组的消费位点ConsumerOffset...

RAM主子账号授权

仅限有权限的RAM用户在云消息队列 RocketMQ 版的控制台上管理资源，以及通过SDK/API发布与订阅消息。应用场景企业A购买了云消息队列 RocketMQ 版...更多信息通过RAM角色实现跨云账号授权云消息队列 RocketMQ 版自定义权限策略什么是RAM

参数说明

云消息队列 RocketMQ 版提供.NET SDK实现消息发送与订阅，您可通过本文了解消息发送和订阅相关接口的参数说明。参数名参数说明 NAMESRV_ADDR 设置TCP协议接入点，从云消息队列 RocketMQ 版控制台的实例详情页面获取。AccessKey ...

基于Flink的资讯场景实时数仓

解决的问题通过云消息队列 Kafka 版和实时计算Flink实现实时数据处理和数据流。通过云消息队列 Kafka 版和实时计算Flink实现实时数据分析。通过云消息队列 Kafka 版和实时计算Flink实现事件触发。部署架构图选用的产品云消息队列 ...

MQTT客户端上下线事件数据流出

此场景中，MQTT客户端产生上下线等状态变更，云消息队列 MQTT 版会根据您配置的客户端状态通知规则，将状态变更封装后转发到云消息队列 RocketMQ 版消息的方式来实现客户端状态数据的聚合和统计。说明针对其他场景，推荐您使用同步查询...

CreateInstance-创建实例

云消息队列 RocketMQ 版的消息存储完全实现 Serverless 弹性，按照实际存储空间收取费用，您可以通过调整消息保存时长来控制消息的存储容量。更多信息，请参见存储费用。72 chargeType string 否计费模式。参数取值如下：provisioned：...

UpdateInstance-更新实例

云消息队列 RocketMQ 版的消息存储完全实现 Serverless 弹性，按照实际存储空间收取费用，您可以通过调整消息保存时长来控制消息的存储容量。更多信息，请参见存储费用。72 traceOn boolean 否是否开启消息轨迹功能。true：开启消息轨迹...

获取MQTT客户端在线状态

实现方式同步查询同步查询方式可以通过调用以下API接口获取客户端状态：QuerySessionByClientId BatchQuerySessionByClientIds 异步上下线事件通知异步上下线事件通知方式下，云端服务可通过调用云消息队列 MQTT 版提供的云端SDK获取...

收发定时消息和延时消息

重要社区版的Apache RocketMQ和阿里云云消息队列 RocketMQ 版配置方式不同，实现效果也有所差异。社区版的Apache RocketMQ支持延时消息，但不支持定时消息，因此没有专门的定时消息接口。阿里云云消息队列 RocketMQ 版不仅同时支持...

收发定时和延时消息

重要社区版的Apache RocketMQ和阿里云云消息队列 RocketMQ 版配置方式不同，实现效果也有所差异。社区版的Apache RocketMQ支持延时消息，但不支持定时消息，因此没有专门的定时消息接口。阿里云云消息队列 RocketMQ 版不仅同时支持...

新零售电子价签解决方案（MQTT）

新零售电子价签解决方案由阿里云云消息队列 MQTT 版推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...

收发事务消息

云消息队列 RocketMQ 版发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求，因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...

消费者分类

云消息队列 RocketMQ 版支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息云消息队列 RocketMQ 版面向不同的业务场景提供了不同...

收发事务消息

云消息队列 RocketMQ 版发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求，因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...

配额与限制

您可以基于阿里云环境自行部署，或使用云消息队列 RocketMQ 版提供的消息集成功能实现轻量级的数据集成及计算。Apache RocketMQ MQTT组件云消息队列 RocketMQ 版暂不支持提供托管的Apache RocketMQ MQTT组件服务。建议您使用阿里云提供...

概述

请按需参见以下文档实现社区版SDK访问阿里云云消息队列 RocketMQ 版：社区版TCP协议Java SDK接入说明社区版TCP协议C++ SDK接入说明暂不支持通过社区版TCP协议的Go SDK和Python SDK访问阿里云云消息队列 RocketMQ 版，推荐您使用商业版...

收发事务消息

云消息队列 RocketMQ 版发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...

收发事务消息

云消息队列 RocketMQ 版发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...

事务消息

分布式事务消息的优势云消息队列 RocketMQ 版分布式事务消息不仅可以实现应用之间的解耦，又能保证数据的最终一致性。同时，传统的大事务可以被拆分为小事务，不仅能提升效率，还不会因为某一个关联应用的不可用导致整体回滚，从而最大...

参数说明

云消息队列 RocketMQ 版提供C/C++ SDK实现消息发送与订阅，您可通过本文了解消息发送和订阅相关接口的参数说明。参数名参数说明 NAMESRV_ADDR 设置TCP协议接入点，从云消息队列 RocketMQ 版控制台的实例详情页面获取。AccessKey ...

分账规则及最佳实践

分账原理：云消息队列 RocketMQ 版的分账基于标签管理实现。您需要给实例绑定相关标签，然后在查看费用账单时，可通过绑定的实例标签筛选出不同维度的明细账单。分账最佳实践应用场景某公司使用一个阿里云账号，该账号下拥有很多云消息...

MQTT与RocketMQ的消息结构映射

云消息队列 MQTT 版是一款面向移动端的网关产品，可通过数据互通规则实现与其他阿里云产品，例如云消息队列 RocketMQ 版的交互。规则的详细信息，请参见规则管理。如果单独使用云消息队列 MQTT 版，则无需关注本文提供的映射关系，...

分账规则及最佳实践

分账原理：云消息队列 RocketMQ 版的分账基于标签管理实现。您需要给实例绑定相关标签，然后在查看费用账单时，可通过绑定的实例标签筛选出不同维度的明细账单。分账最佳实践应用场景某公司使用一个阿里云账号，该账号下拥有很多云消息...

发布者最佳实践

云消息队列 Kafka 版 Producer允许通过设置Partitioner的实现类来选择适合自己业务的分区。在消息指定Key的情况下，云消息队列 Kafka 版 Producer的默认策略是对消息的Key进行哈希，然后根据哈希结果选择分区，保证相同Key的消息会发送到同...

快速入门概述

消息服务MNS 支持使用队列模型和主题模型收发消息，实现一对一或者一对多的消费模式，本文以简单明了的方式让您快速上手消息服务MNS。背景信息消息服务MNS 提供队列模型和主题模型。队列模型：支持一对一的消费模式。队列模型队列模型...

VPC接入

借助云消息队列 Kafka 版 ACL功能，您可以按需为SASL用户赋予向云消息队列 Kafka 版收发消息的权限，从而实现权限分割。当实例规格类型为专业版时需要配置该参数。禁用云盘加密选择是否需要开启实例加密。启用云盘密钥 ID 同地域的云...

公网和VPC接入

借助云消息队列 Kafka 版 ACL功能，您可以按需为SASL用户赋予向云消息队列 Kafka 版收发消息的权限，从而实现权限分割。禁用自定义用户名密码选择是否需要自定义用户名和密码。选择否则使用系统为每个实例分配的默认用户名和密码。...

迁移自建Kafka集群至新实例

您可以将自建Kafka集群元数据导出，然后导入云消息队列 Kafka 版实例，云消息队列 Kafka 版会根据成功导入的元数据在目标云消息队列 Kafka 版实例中创建对应的Topic和Group，实现自建Kafka集群元数据迁移上云。导出元数据使用元数据...

开通消息队列服务并授权

为了实现更细粒度的授权需求，云消息队列 RocketMQ 版还提供了更多的自定义权限策略，可针对某一类资源进行授权，例如只授予用户通过控制台管理Topic的权限。更多自定义权限策略信息，请参见权限策略和示例。后续步骤您可单击管理控制...

开通消息队列服务并授权

为了实现更细粒度的授权需求，云消息队列 RocketMQ 版还提供了更多的自定义权限策略，可针对某一类资源进行授权，例如只授予用户通过控制台管理Topic的权限。更多自定义权限策略信息，请参见权限策略和示例。后续步骤您可单击管理控制...

云消息队列 RocketMQ 版

本文介绍如何在云消息队列 RocketMQ 版控制台创建消息流入任务，实现将其他数据源中的数据快速导入云消息队列 RocketMQ 版。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。创建...

发送普通消息（三种方式）

云消息队列 RocketMQ 版的异步发送，需要您实现异步发送回调接口（SendCallback）。消息发送方在发送了一条消息后，不需要等待服务端响应即可发送第二条消息。发送方通过回调接口接收服务端响应，并处理响应结果。应用场景异步发送一般...

消费者负载均衡

重要队列粒度负载均衡策略保证同一个队列仅被一个消费者处理，该策略的实现依赖消费者和服务端的信息协商机制，云消息队列 RocketMQ 版并不能保证协商结果完全强一致。因此，在消费者数量、队列数量发生变化时，可能会出现短暂的队列分配...

消息服务MNS

本文介绍如何在云消息队列 RocketMQ 版控制台创建消息流入任务，实现将消息服务MNS 的数据快速导入至云消息队列 RocketMQ 版。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您...

消息服务MNS

本文介绍如何在云消息队列 RocketMQ 版控制台创建消息流入任务，实现将消息服务MNS 中的数据快速导入至云消息队列 RocketMQ 版。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。...

队列实现

新品推荐