简介
API 应用程序编程接口 用户开放API，在API网关录入API，以提供接口的方式对外提供服务或者数据。Group API Group API分组 一组API。用户开放API，首先需要创建API分组 每个API分组拥有一个二级域名，两个Stage 用户需要将已经备案且解析至...
基础术语
中文 释义 API 应用程序编程接口，是一些预先定义的函数，或指软件系统不同组成部分衔接的约定。API 分组 用于将 API 进行逻辑的分组，同个分组下的 API 使用相同的分组标识做隔离。分组标识 是网关全局的唯一标识，用于定位在访问的 API。...
RESTful API概览
BatchSendMessage 批量发送消息 API调用 ReceiveMessage 消费消息 控制台、API调用 BatchReceiveMessage 批量消费消息 API调用 DeleteMessage 删除消息 控制台、API调用 BatchDeleteMessage 批量删除消息 API调用 PeekMessage 查看消息 API...
HTTP SDK错误码列表
正确的XML结构，请参见对应的API文档：发送消息API 订阅消息API 确认消息API InvalidArgument The value of Element②should between Low③ and High④ seconds/bytes.400 参数值非法，请根据提示调整。InvalidDigest The Content-MD5 you ...
MNS提供哪些可用的操作？
API调用 PeekMessage 查看消息 API调用 BatchPeekMessage 批量查看消息 API调用 ChangeMessageVisibility 修改消息下次可消费时间 API调用 消息服务MNS 主题模型支持的操作指令如下：接口 功能描述 支持方式 CreateTopic 创建主题 控制台、...
全球消息路由
消息延迟 当前同步到的位点和最新消息位点之间的时间差。消息堆积量 当前还没有来得及同步的消息数量。最新同步时间 最近一次消息同步发生的时间。编辑过滤规则 说明 编辑过滤规则，需先停止任务。在 基础信息 区域的 过滤规则 一栏，单击...
重置消费位点
重置消费位点是指改变订阅者当前的消费位置。当消费者出现故障或者消费错误数据时，您可通过重置消费位点将消费...相关文档 除了控制台，云消息队列 RocketMQ 版 还支持通过API接口重置消费位点。OnsConsumerResetOffset-重置Group ID消费位点
OnsConsumerResetOffset-重置Group ID消费位点
该 Group ID 在消费该 Topic 下的消息时会跳过当前堆积（未被消费）的所有消息，从这之后发送的最新消息开始消费。对于程序返回"reconsumeLater"，即走重试流程的这部分消息来说，清除无效。1：清理到指定时间。请指定一个时间点，这个时间...
ResetConsumeOffset-重置消费位点
Group ID 消费指定 Topic 中的消息时，会跳过当前堆积（未被消费）的所有消息，从重置操作时间后发送的最新消息开始消费。SPECIFIED_TIME：从指定时间的位点开始消费。消费者将从重置时间对应的消费位点之后的消息进行消费，不管这些消息...
仪表盘
每天 API 调用次数 按一天维度累计的生产消息API和消费消息API的调用次数之和。单位：次。查看仪表盘 登录 云消息队列 RocketMQ 版 控制台，在左侧导航栏单击 实例列表。在顶部菜单栏选择地域，如 华东1（杭州），然后在实例列表中，单击...
查看消费状态
说明客户端一直在拉取最新消息，没有消息堆积，属于正常情况。堆积量逐步扩大，并且消息位点一直不变。客户端的消费线程因为某些原因卡住，没有继续消费，也没有继续向服务端提交位点，属于异常情况，即消息的确堆积了。堆积量逐步扩大，...
API概览
消息 API 标题 API概述 OnsMessageTrace 查看消息消费结果 调用OnsMessageTrace根据Message ID来判断目标消息是否曾被消费过。OnsMessageGetByMsgId 通过MsgId查询消息 通过传入 Message ID 查询指定消息的信息以及判断该指定的消息是否曾...
基本概念
ZooKeeper 一款开源的分布式应用程序协调服务。在 云消息队列 Kafka 版 中，ZooKeeper主要用于集群管理、配置管理、Leader选举。ZooKeeper是 云消息队列 Kafka 版 的一部分，您无需感知ZooKeeper。Broker 一个 云消息队列 Kafka 版 服务端...
确认消息API
使用确认消息API确认消息消费状态。请求构造 请求行 DELETE/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID HTTP/1.1 参数说明如下。参数 是否必选 说明 TopicName 是 将消息发送至的Topic名称。ns 否 实例ID，针对有命名空间的...
API分组同步
本功能主要是帮助您在不同API分组之间实现API定义的快速同步。在开始同步前，建议先了解同步范围，以及需要做的一些工作。1.API分组同步范围 API分组同步功能的 同步范围包括：API分组下所选API的配置信息。API分组无法同步的数据包括：API...
发送消息API
使用发送消息API从生产者发送消息至 云消息队列 RocketMQ 版 服务端。请求构造 请求行 POST/topics/TopicName/messages?ns=INSTANCE_ID HTTP/1.1 参数说明如下。参数 是否必选 说明 TopicName 是 将消息发送至的Topic名称。ns 否 实例ID，...
订阅消息API
订阅者可通过调用订阅消息API来消费 云消息队列 RocketMQ 版 服务端中的消息。请求构造 请求行 GET/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID&tag=taga&numOfMessages=3&waitseconds=3 HTTP/1.1 重要 请求行总长度不能超过...
API概览
消息 API 标题 API概述 SendMessage 向云消息队列 MQTT 版发送单条消息 从服务端应用向云消息队列 MQTT 版发送单条消息。客户端 API 标题 API概述 QuerySessionByClientId 查询客户端在线状态*QuerySessionByClientId*接口一般用于线上追踪...
功能与特性概述
开发人员应将其应用程序设计为多次处理一条消息不会产生任何错误或不一致性。消息幂等最佳实践请参见 消费幂等。消息过滤：云消息队列 RocketMQ 版 支持设置消息属性给消息进行分类，云消息队列 RocketMQ 版 服务端会根据您订阅消息时设置...
Subscription
订阅者通过Subscribe接口创建订阅，消息服务MNS 根据订阅的描述给用户端推送消息，推送的起点是订阅时Topic中最新的消息。订阅创建成功后，消息服务MNS 会向指定的Endpoint推送消息。如果Endpoint不可用，消息服务MNS 会按照指定的重试策略...
Subscription
订阅者通过Subscribe接口创建订阅，消息服务MNS 根据订阅的描述给用户端推送消息，推送的起点是订阅时Topic中最新的消息。订阅创建成功后，消息服务MNS 会向指定的Endpoint推送消息。如果Endpoint不可用，消息服务MNS 会按照指定的重试策略...
步骤三：创建资源
重要 Topic需要在应用程序所在的地域（即所部署的ECS的所在地域）进行创建。Topic不能跨地域使用。例如Topic创建在华北2（北京）这个地域，那么消息生产端和消费端也必须运行在华北2（北京）的ECS。在 实例列表 页面，单击目标实例名称。在...
更新记录
本文为您介绍ChatApp消息服务文档更新的最新动态，基于此您可以及时了解ChatApp消息服务的新增特性及功能变更。2023年11月更新记录 时间 特性 内容描述 2023.11.21 新增 控制台-目录管理，增加商品目录授权按钮用于授权Meta商品目录。控制...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
如何快速测试云消息队列 Kafka 版服务端是否正常？
重要 Topic需要在应用程序所在的地域（即所部署的ECS的所在地域）进行创建。Topic不能跨地域使用。例如Topic创建在华北2（北京）这个地域，那么消息生产端和消费端也必须运行在华北2（北京）的ECS。在 实例列表 页面，单击目标实例名称。在...
OnsTopicStatus-查询Topic状态
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。本接口一般用于判断 Topic 资源的使用率...
OnsConsumerTimeSpan-查询Topic可重置时间范围
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。使用本接口可以查询某个 Topic 在当前...
API 概览
消息队列提供以下相关 API 接口。Topic 管理 API 描述 CreateMqSofamqTopic 创建 Topic DeleteMqSofamqTopic 删除 Topic ListMqSofamqTopic 查询 Topic 列表 UpdateMqSofamqTopic 更新 Topic 的读写权限 UpdateMqSofamqTopicRemark 修改 ...
消费进度管理
OpenAPI接口：ResetConsumeOffset-重置消费位点 使用限制 重置消费位点后消费者将直接从重置后的位点开始消费，对于回溯重置类场景，重置后的历史消息大多属于存储冷数据，可能会造成系统压力上升，一般称为冷读现象。因此，需要谨慎评估...
RESTful API概览
本文列举了消息服务MNS主题模式提供的API。主题管理 API 说明 CreateTopic 创建主题 SetTopicAttributes 修改主题属性 GetTopicAttributes 获取主题属性 DeleteTopic 删除主题 ListTopic 获取主题列表 订阅管理 API 说明 Subscribe 创建...
Webhook订阅API变更消息
在OpenAPI门户顶部菜单栏，单击 最新变更，进入 最新变更 页面查看阿里云产品API接口变更信息。在 最新变更 页面，单击 订阅变更，在 订阅变更 面板，选择订阅参数，通知类型选择 Webhook，并将Webhook地址粘贴到联系方式输入框中，单击 ...
自由使用Group
打开自由使用Group的开关表示 云消息队列 Kafka 版 允许未在控制台创建的Group可以调用API进行消息消费和位点提交等操作，如果关闭自由使用Group功能，那么未在控制台创建的Group（即控制台上 自动创建 栏显示为 是 的Group）将无法进行...
回执消息简介与配置流程
当您使用 ChatApp 消息服务 API接口发送消息后，可以通过MNS消息队列消费模式或HTTP批量推送模式来接收消息发送状态的结果和用户回复的消息内容。背景信息 如果出现网络异常、响应超时等情况，可能会导致回执消息推送重复、回执消息获取...
API概览
本产品（云消息队列 RocketMQ 5.0 版/2022-08-01）的OpenAPI采用 ROA 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能...
开发参考
OpenAPI是阿里云产品提供的开放应用程序接口，是除控制台之外，云消息队列 RocketMQ 版 管理资源的主要方式之一。API参考汇总了 云消息队列 RocketMQ 版 所有对外公开的API接口。云消息队列 RocketMQ 版5.x系列 5.x系列SDK参考 5.x系列API...
免费说明
云消息队列 RocketMQ 版 产品按量付费方式中，部分计费项提供一定的免费。以下项目暂时免费，正式收费前将以公告、短信、站内信等方式进行通知：说明 免费项目只针对按量付费，资源包与包年包月的付费方式不可享受以下项目。每个月免费拥有...
PublishMessage
调用PublishMessage接口向指定的主题发布消息，消息发布到主题后随即会被推送给Endpoint消费。请求头 该接口使用公共请求头，无特殊请求头。更多信息，请参见 公共参数。请求语法 POST/topics/$TopicName/messages HTTP/1.1 说明 当您调用...
重置消费位点
背景信息 云消息队列 Kafka 版 支持以下重置消费位点方式：从最新位点开始消费：不再消费Broker上堆积的消息，将消费位点重置到最新的位置。说明 堆积的消息本身并不会因此被删除，改变的只是消费位点。指定时间点开始消费：将消费位点重置...
SendMessage
调用SendMessage接口发送消息到指定的队列。授权信息 默认仅限阿里云账号使用本接口，RAM用户只有在被授予了相关API操作权限后方可使用。本接口的授权信息如下表所示。更多信息，请参见 授权策略和示例。Name Value API SendMessage RAM...
示例代码
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
- 产品推荐
- 这些文档可能帮助您