可观测性体系概述
指标 云消息队列 RocketMQ 版 中定义了详细的Metrics指标，这些指标覆盖生产者、消费者、服务端及消息收发关键接口和流程的统计数据，并支持从实例、Topic和Group等多个维度进行聚合展示，帮助您实时监控消息业务或 云消息队列 RocketMQ 版...
主题（Topic）
消息业务是否关联：如果业务没有直接关联，比如，淘宝交易消息和盒马物流消息没有业务交集，需要使用不同的消息主题；同样是淘宝交易消息，女装类订单和男装类订单可以使用同一个主题。当然，如果业务量较大或其他子模块应用处理业务时需要...
迁移上云操作
步骤五：迁移消息业务 迁移消息业务需要按照Topic粒度对每个Topic进行切流操作，将消息读写流量分阶段切换到目标集群上。注意事项 执行切流操作时，每切换一次Topic状态，请及时观察消息收发是否符合预期，若无异常再执行下一步切换操作，...
客户案例
阿里云CDN帮助众多客户解决了因分布、带宽、服务器性能...优酷 优酷的长视频、短视频、音频、图片等多媒体业务均由阿里云CDN提供访问加速服务，保证了PC端和手机端用户访问优酷内容时可以快速加载、稳定连接，极大地提升了用户的使用体验。
Topic与Tag最佳实践
在 消息队列RocketMQ版 中，Topic与Tag都是业务上用来归类的标识，区分在于Topic是一级分类，而Tag可以理解为是二级分类。您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下：Topic 消息主题，通过...
通用WebSocket接入指南
4.发送&接收业务消息 说明 业务消息指的是不同于建连、断开、心跳、心跳回执这类系统消息，是代表有业务意义的消息，如互动数字人的语音流消息，以及互动数字人返回的ASR文本消息。消息格式：业务消息协议：消息内容：5{"messageId":...
消费重试
了解 云消息队列 RocketMQ 版 的消息确认机制以及消费重试策略可以帮助您分析如下问题：如何保证业务完整处理消息：了解消费重试策略，可以在设计实现消费者逻辑时保证每条消息处理的完整性，避免部分消息出现异常时被忽略，导致业务状态不...
回执消息简介与配置流程
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 ChatApp消息服务控制台 启用MNS消息服务订阅指定的消息类型（MessageType）时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可使用此消息队列名称（QueueName）和...
迁移上云概述
您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验，本文为您介绍开源RocketMQ集群迁移上云的方案及原理。产品差异对比 和开源RocketMQ相比，阿里云 云消息队列 RocketMQ 版 在技术架构、弹性效率、运维复杂...
基本概念
主题（Topic）云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。更多信息，请参见 主题（Topic）。消息类型（MessageType）云消息队列 RocketMQ 版 中按照消息...
MQTT与RocketMQ的消息结构映射
云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的消息负载（Payload）均是您的业务消息的数据序列化结果，云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 不会对业务消息再做进一步的编解码处理。属性字段映射 目前，云消息队列 MQTT 版 ...
回执消息配置
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 短信服务控制台 启用MNS消息服务订阅指定的消息类型（MessageType）时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可使用此消息队列名称（QueueName）和消息类型...
回执消息简介与配置流程
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 语音服务控制台 启用MNS消息服务订阅指定的消息类型（MessageType）时，系统会自动生成该类型的独立消息队列及名称（QueueName）。用户可使用此消息队列名称（QueueName）和消息...
什么是消息队列RabbitMQ版？
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...
回执消息简介与配置流程
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 智能联络中心控制台 启用MNS消息服务订阅指定的消息类型时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可以使用此消息队列名称和消息类型，通过阿里云 获取...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
Topic 与 Tag
在 SOFAStack 消息队列中，Topic 与 Tag 都是业务上用来归类的标识，区分在于 Topic 是一级分类，而 Tag 可以理解为是二级分类。您可通过本文了解如何搭配使用 Topic 和 Tag 来实现消息过滤。背景信息 Topic 和 Tag 的定义如下：Topic：...
什么是云消息队列 RocketMQ 版？
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...
函数计算
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已开通函数计算服务，具体...
回执消息简介与配置流程
云通信的所有业务消息都用过MNS消息服务向外发送。用户在 号码隐私保护控制台 启用MNS消息服务订阅指定的消息类型时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可以使用此消息队列名称和消息类型，通过阿里云 AccessKey...
函数计算
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已开通函数计算服务，具体...
创建FC Sink Connector
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为函数计算的消息流出任务。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您已开通函数计算服务，...
生产者（Producer）
生产者通常被集成在业务系统中，将业务消息按照要求封装成 云消息队列 RocketMQ 版 的 消息（Message）并发送至服务端。在消息生产者中，可以定义如下传输行为：发送方式：生产者可通过API接口设置消息发送的方式。云消息队列 RocketMQ 版 ...
应用场景
物联网设备无时无刻不在产生海量的设备状态数据和业务消息数据，这些数据有助于进行设备监控、业务分析预测和故障诊断。背景信息 设备将原始数据通过 MQTT 协议发送到物联网平台，经由物联网平台将数据转发到消息服务系统，继而通过流计算...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，按照类型将消息分为订单消息和物流消息，其中给物流消息定义地域属性，按照地域分为杭州和上海：订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
SmsUp
您可以通过MNS消息队列拉取短信上行消息（SmsUp）。前提条件 您已经注册阿里云账号并生成访问密钥（AccessKey），详情请参见 创建AccessKey。确保您可以在本地成功Ping以下三个地址：dysmsapi.aliyuncs.com或mns.cn-hangzhou.aliyuncs.com...
元数据导入
本文介绍如何在 云消息队列 Kafka 版 控制台创建元数据导入任务，将元数据迁移至 云消息队列 Kafka 版 已有实例。前提条件 下载JDK 8 购买并部署云消息队列 Kafka 版实例：购买并部署VPC实例 购买并部署公网/VPC实例 说明 购买实例的规格可...
功能发布列表
本文介绍了 云消息队列 RocketMQ 版 每次发布涉及的新增功能、功能优化、重要问题修复及对应的文档，帮助您了解 云消息队列 RocketMQ 版 的发布动态。2023-10-24 实例系列 功能名称 功能描述 变更类型 相关文档 5.x系列实例 Serverless实例...
操作流程
业务链路 从任务视角对所有监控任务运行状态进行实时监控，同时支持告警信息的统一查看。具体操作，请参见 查看业务链路。监控概览 从全局角度，对监控内容进行分类统计展示，便于掌握整体的运行情况。具体操作，请参见 查看监控概览。
操作流程
业务链路 从任务视角对所有监控任务运行状态进行实时监控，同时支持告警信息的统一查看。具体操作，请参见 查看业务链路。监控概览 从全局角度，对监控内容进行分类统计展示，便于掌握整体的运行情况。具体操作，请参见 查看监控概览。
消息轨迹
在分布式应用中，云消息队列 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。指定一个...
收发事务消息
本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
收发定时消息
设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息并补发。注意：不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");try {/定时消息，单位毫秒（ms），在...
收发延时消息
背景信息 延时消息用于指定消息发送到 云消息队列 RocketMQ 版 的服务端后，延时一段时间才被投递到客户端进行消费（例如3秒后才被消费），适用于解决一些消息生产和消费有时间窗口要求的场景，或者通过消息触发延迟任务的场景，类似于延迟...
- 产品推荐
- 这些文档可能帮助您