配置消息监控告警实现风险预警
背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格的实例都有明确的 SLA保障，您购买实例后即可保证消息收发TPS、消息存储等指标达到规格规定的能力。您无需担心实例性能问题，但实际生产环境中仍需要关注实际的业务...
音视频通信解决方案（MQTT）
收发消息参数设计 由于移动App可能存在应用切入后台被杀死（Kill）导致移动App不在线的情况，需对终端App做以下配置，以确保终端App离线重连后可以收到之前的消息：cleanSession 参数设置为“false”QoS 设置成“1”终端App应该对收到的...
消息服务MNS
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 的消息流出至 消息服务MNS。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已...
动态路由
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
QueryMqttTraceMessageSubscribe-查询消息消费轨迹
取值说明如下：true：按照消息的投递时间倒序显示，最后一条消费的消息显示在第一条，最早一条消费的消息显示在最后一条。false：按照消息的投递时间顺序显示，最早一条消费的消息显示在第一条，最后一条消费的消息显示在最后一条。若不...
计费常见问题
包年包月（预付费）实例的费用只限于 云消息队列 MQTT 版 所支持的协议，即 云消息队列 MQTT 版 的消息传输以及消息存储。若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信，云消息队列 RocketMQ ...
Subscription
订阅者通过Subscribe接口创建订阅，消息服务MNS 根据订阅的描述给用户端推送消息，推送的起点是订阅时Topic中最新的消息。订阅创建成功后，消息服务MNS 会向指定的Endpoint推送消息。如果Endpoint不可用，消息服务MNS 会按照指定的重试策略...
Subscription
订阅者通过Subscribe接口创建订阅，消息服务MNS 根据订阅的描述给用户端推送消息，推送的起点是订阅时Topic中最新的消息。订阅创建成功后，消息服务MNS 会向指定的Endpoint推送消息。如果Endpoint不可用，消息服务MNS 会按照指定的重试策略...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。...如需查看完整的消息内容，请下载相应的消息。下载的消息最大为10 MB。如果消息超过10 MB，则只下载10 MB的内容。
最佳实践概览
ChatApp 消息服务（ChatApp Message Service）是阿里云为全球企业打造的一款高效触达用户的消息引擎，通过与WhatsApp平台合作，使您轻松地使用WhatsApp平台的消息服务，触达全球10亿+用户，通过丰富的消息类型，提升您与客户的互动体验，...
队列模型快速入门
消息最大长度：发送到队列的消息体的最大长度。长轮询时间：当队列中没有消息时，该队列的ReceiveMessage请求的最大等待时长。消息可见性超时时间：消息从队列中取出后从Active状态变成Inactive状态后的持续时间。消息保存时长：消息在队列...
TCP协议客户端大版本发布
已就绪消息量：统计在 云消息队列 RocketMQ 版 服务端已就绪，可以被消费者消费的消息数量。指标反映还未被消费者开始处理的消息规模。已就绪消息排队时间：统计最早一条就绪消息的就绪时间和当前时间差。该指标反映了还未被处理的消息的...
查看消费明细
API调用次数：表示当前这个Topic 1天内接收的消息次数+投递的消息次数。重要 费用账单中的用量数据是消息收发条数×消息大小倍数×高级特性消息倍数的结果，具体计算规则，请参见 消息收发定价详情。公网流量费：表示当前这个Topic一天内...
怎样让Consumer不立即消费消息并使消息重入队列？
basicReject方法的参数说明如下：deliveryTag：Channel的消息投递的唯一标识符。requeue：被否定应答的消息是否重入队列。如果设置为true，则消息重入队列；如果设置为false，则消息被丢弃或发送到死信Exchange。更多信息，请参见 死信...
怎样让Consumer不立即消费消息并使消息重入队列？
basicReject方法的参数说明如下：deliveryTag：Channel的消息投递的唯一标识符。requeue：被否定应答的消息是否重入队列。如果设置为true，则消息重入队列；如果设置为false，则消息被丢弃或发送到死信Exchange。更多信息，请参见 死信...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Logstash。...如需查看完整的消息内容，请下载相应的消息。下载的消息最大为10 MB。如果消息超过10 MB，则只下载10 MB的内容。更多信息 更多参数设置，请参见 Kafka output plugin。
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
跨云产品的数据流出
该规则用于将MQTT客户端发送的消息导出到您配置的其他阿里云产品中，从而实现直接调用云产品的API读取MQTT客户端发送的消息。应用场景 设备数据上报 海量设备通过MQTT协议上报状态数据到 云消息队列 MQTT 版，配置数据流出规则将 云消息...
示例代码
本文介绍Apache RocketMQ Go SDK的消息收发示例代码。消息类型 发送消息示例代码 订阅消息示例代码（SimpleConsumer）普通消息 同步发送：ExampleProducerNormalMessage.go 异步发送：AsyncExampleProducerNormalMessage.go ...
示例代码
本文为您介绍RocketMQ 5.x系列C#SDK的消息收发示例代码。表 1.示例代码函数说明 消息类型 发送消息示例代码 订阅消息示例代码（SimpleConsumer）普通消息 ProducerNormalMessageExample.cs SimpleConsumerExample.cs 顺序消息 ...
Topic管理
重要 Topic的消息类型不能混用，例如您创建的Topic的消息类型为普通消息，则该Topic只能收发普通消息，不能用来收发顺序消息。更多信息，请参见 消息类型列表。删除Topic 警告 Topic删除后，相关的生产者、消费者将会立即停止服务，Topic...
OnsDLQMessageResendById-重发指定的死信消息
死信消息已达最大重试次数，若重发后再次消费失败，则死信队列中将增加一条 Message ID 相同的消息，可通过控制台死信队列的查询页面或者管控 API 查看该结果。您可通过同一 Message ID 的消息出现次数判断重发后依然消费失败的次数。由于...
消息队列RabbitMQ版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 RabbitMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已购买并部署 云消息队列 ...
消息队列Kafka版
动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割 服务 选择进行数据加工的服务。test_service 函数 选择进行数据加工的函数。test_function 版本和别名 选择版本和...
资源报表
生产者：查看某Topic在一个时间段内从消息生产者处接收到的消息的总量或者TPS。消费者：查看某Topic在一个时间段内投递给消费者的消息的总量或TPS。输入查询的筛选的条件，包括 父级Topic、子级Topic、QoS类型、消息类型 和 时间范围。单击...
死信队列
在左侧导航栏，选择 中间件>消息队列>死信队列。单击 按 Group ID 查询。在 Group ID 的输入框中，输入关键词搜索想要查找的 Group ID，然后选中，或直接在下拉列表中选择想要查找的 Group ID。单击时间选择框，选择想要查询的时间范围的...
名词解释
A Alternate Exchange 备份Exchange，简称AE，用于接收配置了备份Exchange的Exchange路由失败的消息。Arguments Queue的参数，可用于设置死信Exchange、消息过期时间、死信Routing key等。Auto Delete 自动删除属性，对于设置了自动删除的...
系统中如何标识消息？
本文介绍系统中如何标记消息的问题。...在队列模式下，当消息被取出时，消息服务MNS 会将消息的消息体、Message ID以及该次请求的临时句柄（ReceiptHandle）一齐返回给消费者。消费者在有效期内消费完毕之后，使用临时句柄删除消息。
快速入门概述
本文以收发普通消息为例进行说明，因此，您按照本文提供的步骤创建的普通消息的Topic，不能用于收发其他类型的消息。换言之，不同消息类型的Topic不能混用。使用流程 根据您选择的协议，使用流程如下。协议使用须知 由于 云消息队列 ...
使用限制
单实例的消息收发TPS 标准版：5000条/秒 企业铂金版：参见所购买的规格 若标准版实例的规格不满足您的需求，您可以选择以下方式升级实例规格：将标准版实例升级至4.x系列铂金版：实例升级为企业铂金版后，支持降回标准版，具体操作，请参见...
死信Exchange
云消息队列 RabbitMQ 版 的死信Exchange适用于处理被消费者否定应答或重试失败的消息。本文介绍死信Exchange的核心概念、路由流程、配置方式、注意事项和更多信息。核心概念 死信Exchange 用于路由死信消息的Exchange。死信Exchange会根据...
重置消费位点
您也可以将消费位置移动至最新位点，暂时不处理堆积的消息。前提条件 已停止所有Consumer客户端（云消息队列 Kafka 版 不支持在线重置消费位点）。重要 在停止Consumer客户端后，需要经过 ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG 配置的...
云消息队列 RocketMQ 版
动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割 服务 选择进行数据加工的服务。test_service 函数 选择进行数据加工的函数。test_function 版本和别名 选择版本和...
错误响应格式
错误响应的消息体例子：?xml version="1.0"encoding="UTF-8?Code>InvalidArgument</Code><Message>Authorization header is invalid or missing.</Message><RequestId>04bb60e3-28aa-4706-...
步骤三：创建资源
重要 Compact Topic一般只用在某些生态组件中，例如Kafka Connect或Confluent Schema Registry，其他情况的消息收发请勿为Topic设置该属性。具体信息，请参见 云消息队列 Kafka 版Demo库。Compact 标签 Topic的标签。demo 创建完成后，在 ...
直播互动解决方案
订阅了 云消息队列 RocketMQ 版 Topic的后端应用接收到该条指令消息后，进行必要检验处理并保存禁言名单用于后续过滤被禁言学生的消息。同时发送一条P2P消息（room/p2p/GID_student@002）给学生B的客户端，使学生B的客户端显示禁言效果。...
消息堆积和延迟问题
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...
普通消息
普通消息为 云消息队列 RocketMQ 版 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
ChatAppStatus
取值：message：任意格式的消息，时间限制为在收到用户最后一条消息后的24小时内可发送此类消息。template：在控制台已被审核通过的消息模板，可以在任意时间发送。Type String 否 消息内容中多媒体资源类型。取值：image：图片 video：...
云消息队列 Kafka 版
动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割 服务 选择进行数据加工的服务。当 消息体（body）选择 数据清洗 且选择 绑定现有函数 时，需要配置该参数。test_...
- 产品推荐
- 这些文档可能帮助您