死信消息
示例如下：messageBuilder.addProperty("originalTopic","testTopic")死信消息和主业务区分处理 死信消息是正常业务流程中消息重试仍然失败的消息，需要和主业务流程分开处理，避免影响正常业务。死信Topic和原消息发送Topic不能相同，避免...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
MQTT与RocketMQ的消息结构映射
云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的消息负载（Payload）均是您的业务消息的数据序列化结果，云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 不会对业务消息再做进一步的编解码处理。属性字段映射 目前，云消息队列 MQTT 版 ...
数据同步简介
增量有序 数据同步保证同一个通道内到达客户端的消息顺序一定是与业务服务器调用数据同步服务器的顺序一致，并且所有消息以增量方式同步至客户端。高实时性 当客户端连接的网络状况良好时，数据同步可以保证非常高的推送实时性，消息推送...
消息存储和清理机制
根据统一地存储时长管理消息，可以帮助消费者业务清晰地判断每条消息的生命周期。只要消息在有效期内可以随时被消费，或通过 重置消费位点 功能使消息可被消费多次。消息过期清理机制 开源的Apache RocketMQ中，消息保存时长并不能完整控制...
如何保证我的消息队列中的消息是安全的？
本文介绍阿里云如何保证消息队列中的消息是安全的。消息服务MNS 提供了安全可靠的身份验证机制，确保您的队列受到保护，防止遭到未经授权的访问。只有阿里云账户拥有者才能访问其创建的队列。
功能与特性概述
消息类型对比 消息类型 是否支持可靠同步发送 是否支持可靠异步发送 是否支持Oneway发送 是否支持多线程发送 性能 普通消息 是 是 是 是 最高 事务消息 定时和延时消息 分区顺序消息 是 否 否 否 高 全局顺序消息 一般 消息特性 消息重试：...
主题（Topic）
消息业务是否关联：如果业务没有直接关联，比如，淘宝交易消息和盒马物流消息没有业务交集，需要使用不同的消息主题；同样是淘宝交易消息，女装类订单和男装类订单可以使用同一个主题。当然，如果业务量较大或其他子模块应用处理业务时需要...
消息队列RocketMQ版是否能保证消息不重复？
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
云消息队列 Kafka 版自定义权限策略参考
否 DeleteTopic 删除Topic 否 ListGroup 查看 Group 是 CreateGroup 创建 Group 否 UpdateGroup 更新 Group 配置 否 DeleteGroup 删除 Group 否 QueryMessage 查询消息 是 SendMessage 发送消息 否 DownloadMessage 下载消息 是 ...
可观测性体系概述
指标 云消息队列 RocketMQ 版 中定义了详细的Metrics指标，这些指标覆盖生产者、消费者、服务端及消息收发关键接口和流程的统计数据，并支持从实例、Topic和Group等多个维度进行聚合展示，帮助您实时监控消息业务或 云消息队列 RocketMQ 版...
消费者分组（ConsumerGroup）
使用建议 按照业务合理拆分分组 云消息队列 RocketMQ 版 的消费者和主题是多对多的关系，对于消费者分组的拆分设计，建议遵循以下原则：消费者的投递顺序一致：同一消费者分组下所有消费者的消费投递顺序是相同的，统一都是顺序投递或并发...
延时消息
如果您希望消息被投递后延迟一段时间被消费者消费，您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...
Spring集成
云消息队列 RabbitMQ 版 支持Spring框架的SDK，本文介绍如何集成Spring框架的SDK客户端收发消息。前提条件 您已在 云消息队列 RabbitMQ 版控制台 创建实例、Vhost、Exchange、Queue等相关资源，具体操作，请参见 步骤二：创建资源。安装...
普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意，云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用，例如，您创建的普通消息...
产品简介
事件中心 统一的报警、事件、故障任务流转处理 事件中心是统一的任务流转中心，统一管理整个企业业务系统运行过程中的所有报警、事件、故障。管理系统历史的所有报警记录、报警消息及时通知订阅对象，帮助企业实时发现问题，规避风险；管理...
消息检索
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
创建手动任务
您可根据业务需求，将同类型业务统一放置在一个业务流程。具体步骤如下：创建业务流程。您可以使用如下两种方式创建：方式一：鼠标悬停至 图标，单击 新建业务流程。方式二：右键单击数据开发左侧目录树的 业务流程，选择 新建业务流程。...
队列模型基本概念
本文对 消息服务MNS 的队列模型涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用队列模型。Account 用户的阿里云账号ID。队列（Queue）消息存储的目的地，分成普通队列和延时队列两类。消息包含数据和属性，可以分成...
常见问题
如何配置MNS以支持更长的消息保留期 如何配置MNS以支持更大的消息大小 消息数、活跃消息数、延迟消息数分别表示哪些消息 消息服务消息批量操作注意事项 消息优先级为1，就一定优先吗 队列问题 不同地域中的同名队列是同一个队列吗 对于较长...
使用云消息队列 Kafka 版时出现消息堆积
使用 云消息队列 Kafka 版 时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...
回执消息简介与配置流程
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 智能联络中心控制台 启用MNS消息服务订阅指定的消息类型时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可以使用此消息队列名称和消息类型，通过阿里云 获取...
预付费实例计费说明
延时消息是 云消息队列 RabbitMQ 版 的高级特性消息，收发延时消息时，调用API接口的次数需要在普通消息的基础上乘以5倍，因此延时消息的价格是普通消息的5倍。示例：1秒内发送2条延时消息，消费3条延时消息。则此时API调用TPS为：2×5+3×...
ChatAppStatus
您可以通过MNS消息队列接收ChatApp消息发送状态报告（ChatAppStatus）。前提条件 您已经注册阿里云账号并生成访问密钥（AccessKey），详情请参见 创建AccessKey。您已仔细阅读 回执消息简介与配置流程，了解回执消息模式、类型和配置流程。...
Queue
队列是消息存储的目的地，队列可以分成普通队列和延时队列。如果发送消息时不指定消息延时，被发送到普通队列的消息立刻可以被消费，而发送到延时队列需要经过设定的延时时间后才能被消费。QueueURL 格式：http://$AccountId.mns.<Region>....
应用场景
本文为您介绍 SOFAStack 消息队列的适用场景，以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里，其业务涉及广泛，如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等；同时，也会涉及许多业务峰值时刻，如双 ...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用TCP协议下的.NET SDK收发普通消息的示例代码。前提条件 您已完成以下操作：下载.NET SDK。更多信息，请参见 版本...
OnsDLQMessageResendById-重发指定的死信消息
重发指定Message ID的死信消息，使该消息能够被Consumer再次消费。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则...
消息加密传输
本文介绍如何进一步提高您与 消息服务MNS 服务之间的网络链路上的安全性。背景信息 消息服务MNS 提供在公网HTTPS上进行消息加密传输的服务。对于包含敏感信息的消息，进一步提高您与阿里云服务之间的网络链路上的安全性，目前有以下两种...
通用WebSocket接入指南
请结合具体产品功能接入方案传递 } } 消息格式：Text类型的DataFrame（字符串，编码：UTF-8）说明 具体消息内容是5后面的文本，格式根据不同的产品能力会有不同的要求，具体请参考对应产品能力的接入文档获取，messageId是统一要求，必填，...
发送消息API
使用发送消息API从生产者发送消息至 云消息队列 RocketMQ 版 服务端。请求构造 请求行 POST/topics/TopicName/messages?ns=INSTANCE_ID HTTP/1.1 参数说明如下。参数 是否必选 说明 TopicName 是 将消息发送至的Topic名称。ns 否 实例ID，...
ChatAppInbound
您可以通过MNS消息队列接收 ChatApp 消息服务 的上行消息（ChatAppInbound）。前提条件 您已经注册阿里云账号并生成访问密钥（AccessKey），详情请参见 创建AccessKey。您已仔细阅读 回执消息简介与配置流程，了解回执消息模式、类型和配置...
消息（Message）
系统默认的消息最大限制如下：普通和顺序消息：4 MB 事务和定时或延时消息：64 KB 使用建议 单条消息不建议传输超大负载 作为一款消息中间件产品，云消息队列 RocketMQ 版 一般传输的是都是业务事件数据。单个原子消息事件的数据大小需要...
ChatAppStatus
取值：service：用户发起会话 utility：交易相关消息 marketing：营销类消息 authentication：身份验证消息 ConversationId String 否 会话ID。MsgFrameType String 是 消息类型。取值：message：任意格式的消息，时间限制为在收到用户最后...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Node.js SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Node.js SDK。更多信息，请参见 ...
队列使用手册
} 步骤四：接收和删除消息 队列里已经有了一条消息，现在可以尝试接收消息。NextVisibleTime是 消息服务MNS 的消息的一个重要属性。更多信息，请参见 QueueMessage。receiptHandle=NULL;try {/1.直接调用receiveMessage函数。...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Python SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Python SDK。更多信息，请参见 ...
队列使用手册
本文介绍如何使用C#SDK创建队列、发送消息、接收和删除消息、以及删除队列。步骤一：准备工作 下载最新版C#SDK，解压后将工程导入到VisualStudio。找到工程里四个项目中SDK所在的项目 AliyunSDK_MNS，单击鼠标右键，选择重新生成，在 bin ...
- 产品推荐
- 这些文档可能帮助您