Group ID 消费指定 Topic 中的消息时,会跳过当前堆积(未被消费)的所有消息,从重置操作时间后发送的最新消息开始消费。SPECIFIED_TIME:从指定时间的位点开始消费。消费者将从重置时间对应的消费位点之后的消息进行消费,不管这些消息...
调用CreateSaslUser创建SASL用户。...true 示例 正常返回示例 JSON 格式 {"Code":200,"Message":"operation success.","RequestId":"C5CA600C-7D5A-45B5-B6DB-44FAC2C*","Success":true } 错误码 访问 错误中心 查看更多错误码。
修改消息二维码。接口说明 本接口的单用户 QPS 限制为 5 次/秒。超过限制,API 调用会被限流,这可能会影响您的业务,请合理调用。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer...
创建消息二维码。接口说明 本接口的单用户 QPS 限制为 5 次/秒。超过限制,API 调用会被限流,这可能会影响您的业务,请合理调用。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer...
实例部署后,允许修改实例是否开启ACL、SSL、消息保留时长及最大消息大小,本文介绍如何调用UpdateInstanceConfig修改实例配置。接口说明 权限说明 RAM 用户需要先获取授权,才能调用 UpdateInstanceConfig 接口。授权的详细信息,请参见 ...
该参数需与 Parameter.N.Value 一起使用,云消息队列 RabbitMQ 版 实例支持的变更配置包括:变更公网TPS流量峰值:您需设置 Parameter.N.Code 为 MaxEipTps,对应 Parameter.N.Value 参数,请根据 云消息队列 RabbitMQ 版 控制台 购买页所...
参数取值如下:TRANSACTION:事务消息 FIFO:顺序消息 DELAY:定时/延时消息 NORMAL:普通消息 NORMAL 返回参数 名称 类型 描述 示例值 object Result<MyPage >requestId string 请求 ID,每个请求的 ID 都是唯一的,可用于排查和定位问题。...
批量发送ChatApp消息。接口说明 本接口的单用户 QPS 限制为 10 次/秒。超过限制,API 调用会被限流,这可能会影响您的业务,请合理调用。单次请求支持最多 1,000 个号码。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的...
创建云消息队列 RabbitMQ 版实例。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String 是 ...
调用OnsRegionList获取云消息队列 RocketMQ 版目前开放服务的地域(Region)信息列表。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖...
删除消息二维码。接口说明 本接口的单用户 QPS 限制为 5 次/秒。超过限制,API 调用会被限流,这可能会影响您的业务,请合理调用。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer...
查询消息二维码列表数据。接口说明 本接口的单用户 QPS 限制为 5 次/秒。超过限制,API 调用会被限流,这可能会影响您的业务,请合理调用。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI ...
true:开启消息轨迹功能 false:关闭消息轨迹功能 该参数仅对 Serverless 类型的实例生效,若开启消息轨迹功能,会产生相关的消息轨迹费用,具体计费信息,请参见 Serverless 计费说明。对于按量付费和包年包月实例,该参数不生效,即不管...
创建云消息队列 RocketMQ 版的消费者分组(ConsumerGroup)。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定消费者分组订阅相关的主题来实现消息订阅。接口说明 注意 阿里云...
Topic创建后,允许修改Topic的消息保留时长以及最大消息大小,本文介绍如何调用接口来修改Topic的配置。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。...
消息堆积量=处理中消息量+已就绪消息量,具体的指标含义,可参考以下说明:上图表示指定主题的某一队列中各消息的状态,云消息队列 RocketMQ 版 将处于不同处理阶段的消息数量和耗时进行统计,这些指标可直接反映队列中消息的处理速率和...
顺序消息可以保证消息的消费顺序和发送的顺序一致,即先发送的先消费,后发送的后消费,常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
消息堆积 生产者已经将消息发送到 云消息队列 RocketMQ 版 的服务端,但由于消费者的消费能力有限,未能在短时间内将所有消息正确消费掉,此时在 云消息队列 RocketMQ 版 的服务端保存着未被消费的消息,该状态即消息堆积。事务消息 事务...
如需保证消息生产的顺序性,则必须满足以下条件:同一消息组(MessageGroup)消息生产顺序性的范围为消息组,生产者发送消息时可以为每条消息设置消息组,只有同一消息组内的消息可以保证顺序性,不同消息组或未设置消息组的消息之间不保证...
概念介绍 定时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端,但并不期望立马投递这条消息,而是推迟到在当前时间点之后的某一个时间投递到Consumer进行消费,该消息即定时消息。延时消息:Producer将消息发送到 云消息队列 ...
消息轨迹是指一条消息从生产者发送到 云消息队列 RabbitMQ 版 服务端,再到消费者消费,整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。如果消息收发不符合预期,您可以通过查询消息轨迹,快速分析和定位问题,及时...
对于消费失败且重试后依然失败的消息,云消息队列 RocketMQ 版 不会立丢弃,而是将消息转发至指定的队列中,即死信队列,这些消息即为死信消息。当消费失败的原因排查并解决后,您可以重发这些死信消息,让消费者重新消费;若您暂时无法...
消息持久化 云消息队列 RocketMQ 版 会默认对消息进行持久化,即将接收到的消息存储到 云消息队列 RocketMQ 版 服务端的存储文件中,保证消息的可回溯性和系统故障场景下的可恢复性。模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中...
多媒体短信包括 卡片短信 和 数字短信,多媒体短信支持图片、音频、视频等多媒体发送和交互化菜单的短信产品形态。卡片短信 描述 优势 应用场景 卡片短信是文本短信的发送能力和终端厂商的解析能力的结合,在终端侧给用户呈现出多媒体卡片+...
消息类型对比 消息类型 是否支持可靠同步发送 是否支持可靠异步发送 是否支持Oneway发送 是否支持多线程发送 性能 普通消息 是 是 是 是 最高 事务消息 定时和延时消息 分区顺序消息 是 否 否 否 高 全局顺序消息 一般 消息特性 消息重试:...
在使用Kafka的过程中遇到无法正确消费消息、消息丢失、消息延迟等消费问题时,您可通过消息查询功能查看指定消息的详细内容和相关属性,帮助您排查异常原因。若确定消息所在Topic的分区ID以及消息位点,可采用按位点查询消息;若不确定消息...
当您使用 ChatApp 消息服务 API接口发送消息后,可以通过MNS消息队列消费模式或HTTP批量推送模式来接收消息发送状态的结果和用户回复的消息内容。背景信息 如果出现网络异常、响应超时等情况,可能会导致回执消息推送重复、回执消息获取...
取值如下:成功 失败 消息基础信息 消息类型 普通消息 顺序消息 定时/延时消息 事务消息 消息ID 消息的全局唯一标识,由 云消息队列 RocketMQ 版 系统自动生成。Topic 消息所属的主题名称。消息Keys MessageKey,消息的业务标识,由消息...
消息消费异常时会自动进行消费重试,达到最大重试次数后还未成功,则消息会转为死信状态。云消息队列 RocketMQ 版 支持将这些死信消息保存至指定Topic,方便后续进行业务恢复或回溯。本文介绍死信消息的应用场景、死信策略、使用限制、配置...
处理中消息量+已就绪消息量 消息耗时指标 已就绪消息的就绪时间(ready time)普通消息、顺序消息:消息存储到服务端的时间。定时/延时消息:消息定时或延时结束的时间。事务消息:事务提交的时间。不涉及 已就绪消息的排队时间(ready ...
单一消息主题混用 例如,创建主题时消息类型定义为普通消息,发送消息时同时发送普通消息和顺序消息到该主题中,则顺序消息的发送请求会被拒绝,并返回类型不匹配异常。版本兼容性 消息类型的强制校验,仅针对 云消息队列 RocketMQ 版 服务...
消息服务MNS 的消息过滤功能是指将一个主题的消息通过不同的标签推送到不同的订阅渠道。本文介绍消息过滤的功能以及如何设置消息过滤标签。背景信息 通常情况下,在主题中创建订阅可以将消息推送至已订阅的推送目标。即消息没有设置消息...
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数,例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等,并支持可视化查询。当消息收发结果不符合预期...
半事务消息:暂不能投递的消息,生产者已经成功地将消息发送到了 云消息队列 RocketMQ 版 服务端,但是 云消息队列 RocketMQ 版 服务端未收到生产者对该消息的二次确认,此时该消息被标记成“暂不能投递”状态,处于该种状态下的消息即半...
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制,包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义,消息按照达到服务器的先后顺序被存储到队列中,理论上每个队列都支持无限...
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时,您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
云消息队列 MQTT 版 V2.x.x版本强依赖 云消息队列 RocketMQ 版 作为消息存储,因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通,创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信...
如需实现消息幂等,即如果消息重试多次,消费端对该重复消息消费多次与消费一次的结果是相同的,并且多次消费没有对系统产生副作用,在为每条消息设置唯一Message ID的基础上,您还需要在 云消息队列 RabbitMQ 版 的Consumer客户端对消息...
场景示例 以下图电商交易场景为例,从客户下单到收到商品这一过程会生产一系列消息,按照类型将消息分为订单消息和物流消息,其中给物流消息定义地域属性,按照地域分为杭州和上海:订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
本文对 消息服务MNS 的队列模型涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用队列模型。Account 用户的阿里云账号ID。队列(Queue)消息存储的目的地,分成普通队列和延时队列两类。消息包含数据和属性,可以分成...