MQTT与RocketMQ的消息结构映射
云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的消息负载（Payload）均是您的业务消息的数据序列化结果，云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 不会对业务消息再做进一步的编解码处理。属性字段映射 目前，云消息队列 MQTT 版 ...
消息轨迹
取值如下：成功 失败 消息基础信息 消息类型 普通消息 顺序消息 定时/延时消息 事务消息 消息ID 消息的全局唯一标识，由 云消息队列 RocketMQ 版 系统自动生成。Topic 消息所属的主题名称。消息Keys MessageKey，消息的业务标识，由消息...
基本概念
消息堆积 Producer已经将消息发送到 云消息队列 RocketMQ 版 的服务端，但由于Consumer消费能力有限，未能在短时间内将所有消息正确消费掉，此时在 云消息队列 RocketMQ 版 的服务端保存着未被消费的消息，该状态即消息堆积。消息堆积量=...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
消息（Message）
消息持久化 云消息队列 RocketMQ 版 会默认对消息进行持久化，即将接收到的消息存储到 云消息队列 RocketMQ 版 服务端的存储文件中，保证消息的可回溯性和系统故障场景下的可恢复性。模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，按照类型将消息分为订单消息和物流消息，其中给物流消息定义地域属性，按照地域分为杭州和上海：订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
收发事务消息
本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图...
收发事务消息
当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用，例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...
函数计算
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已开通函数计算服务，具体...
什么是消息队列RabbitMQ版？
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...
收发延时消息
背景信息 延时消息用于指定消息发送到 云消息队列 RocketMQ 版 的服务端后，延时一段时间才被投递到客户端进行消费（例如3秒后才被消费），适用于解决一些消息生产和消费有时间窗口要求的场景，或者通过消息触发延迟任务的场景，类似于延迟...
收发定时消息
本文提供使用TCP协议下的C/C++ SDK收发定时消息的示例代码供您参考。定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...
收发定时消息
本文提供使用TCP协议下的Java SDK收发定时消息的示例代码。背景信息 定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...
函数计算
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已开通函数计算服务，具体...
发送普通消息（三种方式）
云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步（Sync）发送、异步（Async）发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、应用场景、示例代码，以及三种发送方式的对比。前提条件 安装Java SDK。更多信息，请参见 ...
收发定时消息
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time，单位：ms。指定一个...
创建FC Sink Connector
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为函数计算的消息流出任务。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您已开通函数计算服务，...
批量消费
如需提高消息的处理效率，或降低下游资源的API调用频率，您可使用批量消费功能。本文介绍批量消费的定义、优势与场景、使用限制和示例代码等信息。什么是批量消费 定义 批量消费是 云消息队列 RocketMQ 版 通过Push消费者提供的、将消息分...
调用TCP协议的SDK收发普通消息
在控制台创建完所有资源之后，您可以调用 云消息队列 RocketMQ 版 的TCP协议的SDK收发普通消息。前提条件 创建资源 说明 本文以普通消息为例进行说明，因此您创建的普通消息的Topic不能用来收发其他类型的消息，包括定时、延时、顺序和事务...
功能发布列表
本文介绍了 云消息队列 RocketMQ 版 每次发布涉及的新增功能、功能优化、重要问题修复及对应的文档，帮助您了解 云消息队列 RocketMQ 版 的发布动态。2023-10-24 实例系列 功能名称 功能描述 变更类型 相关文档 5.x系列实例 Serverless实例...
消息过滤
功能描述 消息过滤功能指消息生产者向Topic中发送消息时，设置消息属性对消息进行分类，消费者订阅Topic时，根据消息属性设置过滤条件对消息进行过滤，只有符合过滤条件的消息才会被投递到消费端进行消费。消费者订阅Topic时若未设置过滤...
消息重试
云消息队列 RocketMQ 版 支持消息重试功能，即Consumer消费某条消息失败或消费超时，云消息队列 RocketMQ 版 会根据消息重试机制重新投递消息。本文介绍 云消息队列 RocketMQ 版 分别在HTTP协议和TCP协议下的消息重试策略。注意事项 一条...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
API概览
主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。在消息收发模型中，生产者将消息发送至主题，消费者通过订阅指定的主题来消费其中的消息。UpdateTopic 更新主题 更新主题的备注信息。DeleteTopic...
消息 Mesh
作为蚂蚁集团向下一代云原生架构演进的核心基础设施，Service Mesh 在 2019 年得到了大规模的应用与落地。...赋予更多开箱即用的消息流量管控和治理能力，并进一步结合 Knative 探索消息精细化流量调度在 Serverless 下的应用场景。
解决方案介绍
背景信息 阿里云Web应用防火墙混合云解决方案（混合云WAF），支持为部署在阿里云公共云+线下IDC机房的业务、部署在阿里云公共云+第三方云厂商环境的业务提供统一的Web应用防护和管理方案，对无法上云的业务流量提供防护，打造共享和独享相...
API 统一网关
API 网关是金融分布式架构 SOFAStack 下的一个 API ...支持多种自定义参数配置模型，包括参数映射、数据模型、外部授权 API 等，满足不同业务场景的统一网关需求。关于 API 网关详细的功能介绍和使用指南，请参见 SOFAStack API 统一网关。
产品优势
多种客户端接入支持 同一个 API 发布后，既...灵活的插件自定义能力 支持多种插件能力，包括参数映射、数据模型、外部授权 API 等多种自定义参数配置模型，满足不同业务场景的统一网关需求，可用于多部门协同时可通过网关实现统一规范场景。
主题（Topic）
消息业务是否关联：如果业务没有直接关联，比如，淘宝交易消息和盒马物流消息没有业务交集，需要使用不同的消息主题；同样是淘宝交易消息，女装类订单和男装类订单可以使用同一个主题。当然，如果业务量较大或其他子模块应用处理业务时需要...
什么是云消息队列 RocketMQ 版？
应用场景 云消息队列 RocketMQ 版 基于统一消息存储和轻量计算层，主要应用于微服务异步解耦、流式数据处理、事件驱动等场景。业务消息 异步解耦、削峰填谷 云消息队列 RocketMQ 版 初始于阿里巴巴双十一核心链路，广泛应用于物流、购物车...
Topic与Tag最佳实践
在 消息队列RocketMQ版 中，Topic与Tag都是业务上用来归类的标识，区分在于Topic是一级分类，而Tag可以理解为是二级分类。您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下：Topic 消息主题，通过...
回执消息简介与配置流程
云通信的所有业务消息都用过MNS消息服务向外发送。用户在 号码隐私保护控制台 启用MNS消息服务订阅指定的消息类型时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可以使用此消息队列名称和消息类型，通过阿里云 AccessKey...
全场景解决方案
单机房>同城双活>异地多活>混合云 金融级应用 PaaS，安全生产支撑 异构 IaaS 适配/多集群/应用管理/可观测性/应急容灾 Mesh 异构集成，存量应用平滑上云 基础架构和业务解耦/多语言/多协议/多平台 客户案例 建议产品 统一应用运维 方案架构...
定时/延时消息
因此，下文统一用定时消息描述。在分布式定时调度触发、任务超时处理等场景，需要实现精准、可靠的定时事件触发。使用 云消息队列 RocketMQ 版 的定时消息可以简化定时调度任务的开发逻辑，实现高性能、可扩展、高可靠的定时触发能力。典型...
云存储网关利用MQTT服务实现统一管控
通过 云消息队列 MQTT 版 所提供的服务，可采用统一的框架，即云控制台，来管理不同部署模式的云存储网关CSG（Cloud Storage Gateway），并实现安全合规的公网和私网穿透，以此提供一致的用户体验。名词解释 MQTT 一种物联网和移动互联网...
消费者分组（ConsumerGroup）
使用建议 按照业务合理拆分分组 云消息队列 RocketMQ 版 的消费者和主题是多对多的关系，对于消费者分组的拆分设计，建议遵循以下原则：消费者的投递顺序一致：同一消费者分组下所有消费者的消费投递顺序是相同的，统一都是顺序投递或并发...
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容C++ 1.x/2.x SDK客户端接入，您可以使用1.x/2.x版本的SDK接入5.x实例进行消息收发。本文为您介绍1.x/2.x版本下的C++ SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK...
闲鱼
客户介绍 闲鱼是依托阿里电商体系的前台型业务，有非常独特的业务特点和用户诉求，在底层依托阿里系统的同时，在表现层和业务层需要探索适合闲鱼的、并且更加快速灵活的研发体系。从2018年开始，闲鱼架构负责人带领闲鱼技术团队布局...
- 产品推荐
- 这些文档可能帮助您