为了防止消息重复消费导致业务处理异常，云消息队列 RocketMQ 版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的...
全球消息路由的功能和使用方式和开源Shovel插件保持一致，支持不同实例和Vhost间的Queue到Queue、Queue到Exchange的消息转发。在此基础上，除了可以本地域间消息转发，也可以支持跨地域消息转发，以便您按需同步消息，实现不同实例、不同...
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
生产者负载均衡策略 无序消息（普通消息、事务消息、定时和延时消息）：Producer将消息以轮询的方式发送至Queue，如下图所示：图中Msg1、Msg2代表第一条消息、第二条消息，生产者会把第一条消息发送至Queue 1，然后第二条消息发送至Queue 2...
消息服务MNS 支持把发布到主题的消息推送到队列。本文介绍如何将消息推送到队列。步骤一：创建主题 登录 消息服务MNS控制台。在左侧导航栏，单击 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，单击 创建主题。在 创建主题 面板，...
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
消息收发为 云消息队列 MQTT 版 最基本的功能，云消息队列 MQTT 版 支持终端和云端服务接入 云消息队列 MQTT 版 服务器，实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息 云消息队列 MQTT 版 ...
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...
云消息队列 RabbitMQ 版 的死信Exchange适用于处理被消费者否定应答或重试失败的消息。本文介绍死信Exchange的核心概念、路由流程、配置方式、注意事项和更多信息。核心概念 死信Exchange 用于路由死信消息的Exchange。死信Exchange会根据...
同构消息映射关系 当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流实现RocketMQ消息路由 基于事件流实现Kafka消息路由 基于事件流实现RabbitMQ消息路由 基于事件流实现MNS消息路由 异构消息映射关系 当消息的...
在创建并部署 云消息队列 Kafka 版 实例后，您可以使用 云消息队列 Kafka 版 控制台直接发送消息，快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
如何配置MNS以支持更长的消息保留期 如何配置MNS以支持更大的消息大小 消息数、活跃消息数、延迟消息数分别表示哪些消息 消息服务消息批量操作注意事项 消息优先级为1，就一定优先吗 队列问题 不同地域中的同名队列是同一个队列吗 对于较长...
针对初次接触 云消息队列 RocketMQ 版 的工程师，本文以TCP协议下的Java SDK为例，提供操作示例帮助您从零开始搭建 云消息队列 RocketMQ 版 测试工程。Demo工程包含普通消息、顺序消息、事务消息、定时和延时消息的测试代码，以及相关...
您可以使用 云消息队列 RabbitMQ 版 的日志管理功能将 云消息队列 RabbitMQ 版 实例的消息操作日志推送到日志服务。当消息的发送、消费、确认出现异常时，您可在日志服务查询并分析消息的操作日志，进行异常诊断。前提条件 创建 云消息队列...
JSON：消息体为JSON格式，包含消息正文和消息属性。XML：消息体为XML格式，包含消息正文和消息属性。步骤三：发布消息 登录 消息服务MNS控制台。在左侧导航栏，单击 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，找到目标主题，在...
注意事项 云消息队列 MQTT 版 需搭配后端消息存储队列一起使用，具体说明如下：云消息队列 MQTT 版 实例是一个无状态网关类型实例，用来完成IoT移动场景下的客户端连接维持和消息转发，本身并不提供消息数据持久化功能，具体的消息存储和...
说明 云消息队列 RocketMQ 版 有4种消息类型：普通消息、定时和延时消息、事务消息以及顺序消息，其中，定时和延时消息、事务消息以及顺序消息为高级特性消息。更多信息，请参见 消息类型列表。Topic数上限：表示指定实例下可创建的最大...
本文为您介绍如何使用发送消息。前提条件 已开通 ChatApp 消息服务。已完成 注册阿里云账号 和 企业实名认证。创建的模板已审核通过。具体操作，请参见 创建模板。WABA账号绑定的手机号码已完成验证。具体操作，请参见 通道管理。操作步骤 ...
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 消息队列RocketMQ版5.x系列相比4.x系列实例有什么优势？消息队列RocketMQ版5.x系列实例兼容哪些版本客户端？消息队列RocketMQ版支持哪些语言客户端？消息队列...
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...
本文为您介绍 云消息队列 RocketMQ 版 的应用场景，以便您更好地判断如何在业务中使用 云消息队列 RocketMQ 版。例如，针对一家互联网电商企业，其业务涉及广泛，如注册、订单、库存、物流等；同时，也会涉及许多业务峰值时刻，如秒杀活动...
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势？云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端？云消息队列 RocketMQ 版支持哪些语言客户端？云...
说明 云消息队列 RocketMQ 版 有4种消息类型：普通消息、定时和延时消息、事务消息以及顺序消息，其中，定时和延时消息、事务消息以及顺序消息为高级特性消息。更多信息，请参见 消息类型列表。计费单价 阶梯单价 说明 按照阿里云主账号...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务，将 云消息队列 RabbitMQ 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源...
如果消息重复消费会影响您的业务处理，请对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 在数学与计算机学中，幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域，幂等是...
本文说明 云消息队列 Kafka 版 涉及的专有名词和术语，帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版...
云消息队列 MQTT 版 从V2.x.x升级至V3.x.x实现了自身数据存储的能力，同时还去除了对 云消息队列 RocketMQ 版 的消息依赖，因此，云消息队列 MQTT 版 的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明 云消息队列 MQTT 版 ...
用户发布消息到主题时，可以指定消息体、消息标签和消息额外属性。主题消息的最长保留时间为1天，超过这个时间，不论消息是否成功推送给用户都将被垃圾回收器回收。消息属性 MessageId 消息的编号。一个主题中每个消息都有唯一的MessageId...
消息队列RocketMQ版领域模型 如上图所示，云消息队列 RocketMQ 版 中消息的生命周期主要分为消息生产、消息存储、消息消费这三部分。生产者生产消息并发送至 云消息队列 RocketMQ 版 服务端，消息被存储在服务端的主题中，消费者通过订阅...
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
消息服务MNS 的日志管理功能将您的消息操作日志推送到指定LoggingBucket中。您在控制台上配置将日志推送到 日志服务 SLS（Simple Log Service），然后开启该地域队列或主题的日志管理功能，消息服务MNS 将自动推送该队列或主题消息的操作...
云消息队列 RocketMQ 版 于2021年10月18日发布新版本Java SDK和C++ SDK客户端，本次发布对客户端大版本进行了升级。本文介绍发布的SDK版本信息、支持升级的地域以及主要的功能差异。SDK版本信息 本次发布的SDK客户端版本信息如下：协议 ...
本文介绍如何进一步提高您与 消息服务MNS 服务之间的网络链路上的安全性。背景信息 消息服务MNS 提供在公网HTTPS上进行消息加密传输的服务。对于包含敏感信息的消息，进一步提高您与阿里云服务之间的网络链路上的安全性，目前有以下两种...
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
计费公式 消息收发费用＝消息收发次数累计值（次）×消息收发单价（元/次）消息收发次数计算规则 消息收发次数=接收消息次数+投递消息次数 接收消息次数：表示服务端收到生产者发送的消息条数，例如，某个Topic中收到5条消息，则计算为5次...
除了标准MQTT协议所支持的发布/订阅（Pub/Sub）消息收发模式外，云消息队列 MQTT 版 还支持点对点（Point to Point，简称P2P）模式。本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P，...