Memcg全局最低水位线分级
当时延敏感型业务和资源消耗型任务共同部署时，资源消耗型任务时常会瞬间申请大量的内存，使得系统的空闲内存触及全局最低水位线（global wmark_min），引发系统所有任务进入直接内存回收的慢速路径，引发时延敏感型业务的性能抖动。...
如何计算和购买消息包
生活物联网平台提供辅助计算器，本文介绍如何使用辅助计算器，并合理购买消息包。背景介绍 消息通信收费方案全面更新升级，为方便开发者合理购买消息包，平台提供辅助计算器，计算建议购买消息包个数，该数据仅供参考。辅助计算器使用 在...
通用WebSocket接入指南
4.发送&接收业务消息 说明 业务消息指的是不同于建连、断开、心跳、心跳回执这类系统消息，是代表有业务意义的消息，如互动数字人的语音流消息，以及互动数字人返回的ASR文本消息。消息格式：业务消息协议：消息内容：5{"messageId":...
可观测性体系概述
作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版 被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍 云消息队列 ...
Topic与Tag最佳实践
在 消息队列RocketMQ版 中，Topic与Tag都是业务上用来归类的标识，区分在于Topic是一级分类，而Tag可以理解为是二级分类。您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下：Topic 消息主题，通过...
评估合适的云服务
例如，I/O密集型业务（中大型OLTP类核心数据库、中大型NoSQL数据库、实时日志分析、大型企业级商用软件等）应选择存储增强型实例，实现更好地存储性能与能力；网络密集型业务（NFV/SD-WAN、音视频、电信业务转发、缓存、大数据以及机器学习...
迁移上云操作
重要 开源Apache RocketMQ 4.x版本没有消息类型的概念，阿里云 云消息队列 RocketMQ 版 会对Topic的消息类型和Message的类型进行一致性校验，因此在元数据迁移时，您需要根据实际业务场景手动录入Topic的消息类型。如果消息类型选择错误，...
回执消息简介与配置流程
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 ChatApp消息服务控制台 启用MNS消息服务订阅指定的消息类型（MessageType）时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可使用此消息队列名称（QueueName）和...
MQTT与RocketMQ的消息结构映射
云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的消息负载（Payload）均是您的业务消息的数据序列化结果，云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 不会对业务消息再做进一步的编解码处理。属性字段映射 目前，云消息队列 MQTT 版 ...
消息（Message）
系统默认的消息最大限制如下：普通和顺序消息：4 MB 事务和定时或延时消息：64 KB 使用建议 单条消息不建议传输超大负载 作为一款消息中间件产品，云消息队列 RocketMQ 版 一般传输的是都是业务事件数据。单个原子消息事件的数据大小需要...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
什么是云消息队列 RocketMQ 版？
削峰填谷提高稳定性 传统消息中间件仅满足业务的异步化需求，而 云消息队列 RocketMQ 版 诞生于在线互联网和交易业务场景，除了满足异步能力，还将削峰填谷作为消息的基础能力。通过削峰填谷不仅能够提高系统稳定性，还能大幅降低业务成本...
回执消息配置
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 短信服务控制台 启用MNS消息服务订阅指定的消息类型（MessageType）时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可使用此消息队列名称（QueueName）和消息类型...
什么是消息队列RabbitMQ版？
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...
生产者（Producer）
生产者通常被集成在业务系统中，将业务消息按照要求封装成 云消息队列 RocketMQ 版 的 消息（Message）并发送至服务端。在消息生产者中，可以定义如下传输行为：发送方式：生产者可通过API接口设置消息发送的方式。云消息队列 RocketMQ 版 ...
回执消息简介与配置流程
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 语音服务控制台 启用MNS消息服务订阅指定的消息类型（MessageType）时，系统会自动生成该类型的独立消息队列及名称（QueueName）。用户可使用此消息队列名称（QueueName）和消息...
回执消息简介与配置流程
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 智能联络中心控制台 启用MNS消息服务订阅指定的消息类型时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可以使用此消息队列名称和消息类型，通过阿里云 获取...
Topic 与 Tag
在 SOFAStack 消息队列中，Topic 与 Tag 都是业务上用来归类的标识，区分在于 Topic 是一级分类，而 Tag 可以理解为是二级分类。您可通过本文了解如何搭配使用 Topic 和 Tag 来实现消息过滤。背景信息 Topic 和 Tag 的定义如下：Topic：...
功能发布列表
本文介绍了 云消息队列 RocketMQ 版 每次发布涉及的新增功能、功能优化、重要问题修复及对应的文档，帮助您了解 云消息队列 RocketMQ 版 的发布动态。2024-04-24 实例系列 功能名称 功能描述 变更类型 相关文档 5.x系列实例 Serverless公网...
基本概念
业务应用 业务方开发的前台业务型应用，用于实现特定领域或者业务范围的功能，可以调用中台应用提供的服务。与业务身份一起，构成一组中台能力使用的鉴权信息（调用中台能力时，需要明确是哪个业务身份、哪个业务应用在调用）。
购买和使用节省计划
如果业务资源用量在较长时间内稳定，希望获得尽可能大的折扣力度，建议在满足业务需求的前提下合理利用抵扣规则，例如购买3年期、全预付的ECS计算型。说明 如果您使用RAM用户操作，需要获得授权才能购买节省计划。具体操作，请参见 授权RAM...
消息轨迹
在分布式应用中，云消息队列 RocketMQ 版 作为全链路中异步解耦的关键服务，提供的消息轨迹数据可有效将业务上下游信息串联起来，帮助您更好地排查异常信息，定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数...
发送普通消息（三种方式）
云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步（Sync）发送、异步（Async）发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、应用场景、示例代码，以及三种发送方式的对比。前提条件 安装Java SDK。更多信息，请参见 ...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用，例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...
消息查询
云消息队列 RocketMQ 版 提供了三种消息查询的方式，分别是按Message ID、Message Key以及Topic查询。您可以通过消息查询验证消息是否发送成功、验证消息发送的内容是否正确、以及进一步查看消息的轨迹信息。查询方式说明 由于消息在 云...
收发定时消息
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time单位ms，指定一个时刻，...
收发定时消息
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time，单位：ms。指定一个...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
收发事务消息
本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图...
收发定时消息
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");try {/定时消息，单位毫秒（ms），在...
收发延时消息
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");try {/延时消息，在指定延迟时间（当前时间之后）进行...
示例代码
云消息队列 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...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
上下线通知规则管理
业务应用一般部署在阿里云的服务器上，业务应用通过向后端云产品订阅这条消息来获取所有客户端的上下线动作。流程说明 规则限制 限制项 限制值 说明 单实例规则数量 100 如果默认限制不满足，请联系 云消息队列 MQTT 版 技术支持，钉钉群号...
收发顺序消息
顺序消息FIFO（First In First Out）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
基本概念
消息堆积 Producer已经将消息发送到 云消息队列 RocketMQ 版 的服务端，但由于Consumer消费能力有限，未能在短时间内将所有消息正确消费掉，此时在 云消息队列 RocketMQ 版 的服务端保存着未被消费的消息，该状态即消息堆积。消息堆积量=...
一机一密概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的设备访问凭证相关的请求以及消息收发业务。计算方式 按照 鉴权概述 的描述，如果选择一机一密鉴权模式，MQTT客户端实际连接MQTT消息服务器时，connect ...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
收发事务消息
当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的Java SDK收发顺序消息的示例代码。前提条件 您已完成以下操作：下载1.2.7或以上版本的Java SDK。更多信息，请参见...
- 产品推荐
- 这些文档可能帮助您