基本概念
消息堆积 生产者已经将消息发送到 云消息队列 RocketMQ 版 的服务端，但由于消费者的消费能力有限，未能在短时间内将所有消息正确消费掉，此时在 云消息队列 RocketMQ 版 的服务端保存着未被消费的消息，该状态即消息堆积。事务消息 事务...
SendChatappMessage-发送ChatApp消息
video，视频消息。audio，音频消息。document，文档消息。interactive，交互消息。contacts，联系人消息。location，位置消息。sticker，贴纸消息。reaction，心情消息。Viber 消息类型：text，文本消息。image，图片消息。video，视频消息...
如何保证我的消息队列中的消息是安全的？
本文介绍阿里云如何保证消息队列中的消息是安全的。消息服务MNS 提供了安全可靠的身份验证机制，确保您的队列受到保护，防止遭到未经授权的访问。只有阿里云账户拥有者才能访问其创建的队列。
消息队列RocketMQ版是否能保证消息不重复？
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意，云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用，例如，您创建的普通消息...
延时消息
如果您希望消息被投递后延迟一段时间被消费者消费，您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...
功能与特性概述
消息类型对比 消息类型 是否支持可靠同步发送 是否支持可靠异步发送 是否支持Oneway发送 是否支持多线程发送 性能 普通消息 是 是 是 是 最高 事务消息 定时和延时消息 分区顺序消息 是 否 否 否 高 全局顺序消息 一般 消息特性 消息重试：...
API错误码
InvalidParameter.LinkNotEmpty 发送媒体消息链接不能为空。InvalidParameter.TemplateCodeNotEmpty 发送模板消息时模板编码不能为空。InvalidParameter.LanguageNotEmpty 发送模板消息时语言不能为空。InvalidParameter.SendSmsNotSupport...
死信消息
消息消费异常时会自动进行消费重试，达到最大重试次数后还未成功，则消息会转为死信状态。云消息队列 RocketMQ 版 支持将这些死信消息保存至指定Topic，方便后续进行业务恢复或回溯。本文介绍死信消息的应用场景、死信策略、使用限制、配置...
云消息队列 Kafka 版自定义权限策略参考
否 DeleteTopic 删除Topic 否 ListGroup 查看 Group 是 CreateGroup 创建 Group 否 UpdateGroup 更新 Group 配置 否 DeleteGroup 删除 Group 否 QueryMessage 查询消息 是 SendMessage 发送消息 否 DownloadMessage 下载消息 是 ...
常见问题
如何配置MNS以支持更长的消息保留期 如何配置MNS以支持更大的消息大小 消息数、活跃消息数、延迟消息数分别表示哪些消息 消息服务消息批量操作注意事项 消息优先级为1，就一定优先吗 队列问题 不同地域中的同名队列是同一个队列吗 对于较长...
在Knative上实现Kafka消息推送
适用场景 在线短任务处理 AI音视频消息处理 监控告警 数据格式转换 操作流程 在Knative上实现 云消息队列 Kafka 版 消息推送的操作流程如下图所示。部署Kafka组件 登录 容器服务控制台。在左侧导航栏，单击 集群。在 集群列表 页面，单击要...
ModifyChatappTemplate-修改ChatApp模板
修改消息模板。只能修改未审核以及审核不通过的模板。接口说明 QPS 限制 本接口的单用户 QPS 限制为 50 ...NAVIGATE NavigateScreen string 否 跳转屏 在 FlowAction=NAVIGATE 时必填 DETAILS ThumbUrl string 否 Viber 带视频消息的缩略图。...
消息（Message）
消息持久化 云消息队列 RocketMQ 版 会默认对消息进行持久化，即将接收到的消息存储到 云消息队列 RocketMQ 版 服务端的存储文件中，保证消息的可回溯性和系统故障场景下的可恢复性。模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中...
CreateChatappTemplate-创建ChatApp模板
创建消息模板，模板审核通过后可以发送消息。接口说明 QPS 限制 本接口的单用户 QPS 限制为 50 次/秒。...NAVIGATE NavigateScreen string 否 跳转屏 在 FlowAction=NAVIGATE 时必填 DETAILS ThumbUrl string 否 Viber 带视频消息的缩略图。...
Queue
队列是消息存储的目的地，队列可以分成普通队列和延时队列。如果发送消息时不指定消息延时，被发送到普通队列的消息立刻可以被消费，而发送到延时队列需要经过设定的延时时间后才能被消费。QueueURL 格式：http://$AccountId.mns.<Region>....
普通消息
普通消息为 云消息队列 RocketMQ 版 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
查询消息轨迹
消息轨迹是指一条消息从生产者发送到消息队列服务端，再到消费者消费处理，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。本文介绍如何快速查询消息轨迹。前提条件 您的消息已从生产者发送。操作步骤 登录 SOFAStack...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用，例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...
使用云消息队列 Kafka 版时出现消息堆积
使用 云消息队列 Kafka 版 时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...
OnsDLQMessageResendById-重发指定的死信消息
重发指定Message ID的死信消息，使该消息能够被Consumer再次消费。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则...
概述
Kafka 版 快速入门操作流程 操作步骤 具体操作步骤如下：步骤一：获取访问授权 步骤二：购买和部署实例 VPC接入 公网和VPC接入 步骤三：创建资源 步骤四：使用SDK收发消息 默认接入点收发消息 SSL接入点PLAIN机制收发消息 视频教程 ...
点播开通常见问题
但视频点播在存储音视频的媒体文件之后，核心作用是提供视频的托管服务，满足在线点播视频的业务需求，并且通过媒资管理、视频在线编辑、视频审核发布、数据统计、短视频SDK、视频安全等能力，覆盖到视频点播业务的不同方面。视频点播的...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用TCP协议下的.NET SDK收发普通消息的示例代码。前提条件 您已完成以下操作：下载.NET SDK。更多信息，请参见 版本...
概述
概念介绍—消息流出（Sink）消息流出的主要能力是将消息产品的数据流出到各类数据目标，消息集成模块对消息产品的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理（Transform）数据处理是消息集成的重要功能...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
术语表
术语 全称 中文 说明 OSS Object Storage Service 阿里云对象存储 媒体处理服务对用户存储于OSS的媒体文件进行转码，并将转码输出文件保存在MediaBucket中或者OutputBucket中。Bucket OSS Bucket OSS Bucket 遵守OSS Bucket定义，只能包括...
概述
概念介绍—消息流出（Sink）消息流出的主要能力是将消息产品的数据流出到各类数据目标，消息集成模块对消息产品的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理（Transform）数据处理是消息集成的重要功能...
概述
概念介绍—消息流出（Sink）消息流出的主要能力是将消息产品的数据流出到各类数据目标，消息集成模块对消息产品的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理（Transform）数据处理是消息集成的重要功能...
GetChatappTemplateDetail-查询ChatApp模板详情
取值范围：NAVIGATE/DATA_EXCHANGE NAVIGATE NavigateScreen string 跳转屏 在 FlowAction=NAVIGATE 时必填 DETAILS ThumbUrl string Viber 带视频消息的缩略图。https://img.png Duration integer Viber 视频消息的视频时长，取值范围：0~...
顺序消息
如需保证消息生产的顺序性，则必须满足以下条件：同一消息组（MessageGroup）消息生产顺序性的范围为消息组，生产者发送消息时可以为每条消息设置消息组，只有同一消息组内的消息可以保证顺序性，不同消息组或未设置消息组的消息之间不保证...
实例限流最佳实践
云消息队列 RabbitMQ 版 会对单实例的TPS流量峰值进行限流，本文介绍 云消息队列 RabbitMQ 版 实例的限流规则、限流后的行为以及限流最佳实践等。限流后行为 当 云消息队列 RabbitMQ 版 实例的TPS流量峰值超过您所购买实例的TPS规格上限时...
预付费实例计费说明
延时消息是 云消息队列 RabbitMQ 版 的高级特性消息，收发延时消息时，调用API接口的次数需要在普通消息的基础上乘以5倍，因此延时消息的价格是普通消息的5倍。示例：1秒内发送2条延时消息，消费3条延时消息。则此时API调用TPS为：2×5+3×...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
主题（Topic）
单一消息主题混用 例如，创建主题时消息类型定义为普通消息，发送消息时同时发送普通消息和顺序消息到该主题中，则顺序消息的发送请求会被拒绝，并返回类型不匹配异常。版本兼容性 消息类型的强制校验，仅针对 云消息队列 RocketMQ 版 服务...
ChatAppInbound
您可以通过MNS消息队列接收 ChatApp 消息服务 的上行消息（ChatAppInbound）。前提条件 您已经注册阿里云账号并生成访问密钥（AccessKey），详情请参见 创建AccessKey。您已仔细阅读 回执消息简介与配置流程，了解回执消息模式、类型和配置...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Node.js SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Node.js SDK。更多信息，请参见 ...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Java SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Java SDK。更多信息，请参见 准备...
队列模型基本概念
本文对 消息服务MNS 的队列模型涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用队列模型。Account 用户的阿里云账号ID。队列（Queue）消息存储的目的地，分成普通队列和延时队列两类。消息包含数据和属性，可以分成...
- 产品推荐
- 这些文档可能帮助您