OnsDLQMessageResendById-重发指定的死信消息

当前消息队列 RocketMQ 不管理死信重发的状态,重发后消费成功的消息不会从死信队列中移除。需自行管理、判断消息是否需要重发。避免多次无意义地重发,从而造成重复消费。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算...

OnsMessageGetByMsgId-通过MsgId查询消息

通过传入 Message ID 查询指定消息的信息...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsMessageGetByMsgId 接口,您还可以通过消息队列 RocketMQ 控制台查看消息的详细信息。具体操作,请参见 消息查询。

OnsMessageGetByKey-根据Message Key查询消息

根据 Topic 和 Message Key 模糊查询消息...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsMessageGetByKey 接口,您还可以通过云消息队列 RocketMQ 控制台查看消息的详细信息。具体操作,请参见 消息查询。

OnsDLQMessageGetById-根据Message ID查询死信消息

通过传入Message ID查询指定的死信消息。...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsDLQMessageGetById 接口,您还可以通过云消息队列 RocketMQ 控制台查看死信消息。具体操作,请参见 死信队列。

查询Group ID内所有死信消息

通过传入Group ID和时间段,分页查询...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsDLQMessagePageQueryByGroupId 接口,您还可以通过云消息队列 RocketMQ 控制台查看死信消息。具体操作,请参见 死信队列。

OnsMessagePush-向指定的消费者推送消息

调用OnsMessagePush向指定的消费者推送消息。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能会导致链路产生...

OnsMessagePageQueryByTopic-查询Topic内所有消息

分页查询指定时间段内指定Topic内存在的所有消息。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能会导致链路...

OnsMessageTrace-查看消息消费结果

本接口的实现基于云消息队列 RocketMQ 的内部位点机制,在大部分场景下判断结果可信,但如果应用方进行过重置位点已经清除消息等操作,则判断结果可能有误。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行...

OnsTrendGroupOutputTps-统计消息消费数据

变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsTrendGroupOutputTps 接口,您还可以通过云消息队列 RocketMQ 控制台查看指定 Group ID 下的消费消息的统计数据。具体操作,请参见 仪表盘。

OnsMessageDetail-查询消息详细信息

请求参数 名称 类型 必填 描述 示例值 InstanceId string 是 云消息队列 RocketMQ 实例 ID。MQ_INST_184681981*_BXig0x6A Topic string 是 需查询的消息的 Topic 名称。test-mq_topic MsgId string 是 需查询的消息的 ID,即 Message ID...

OnsTrendTopicInputTps-统计消息生产数据

查询一段时间内指定的...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsTrendTopicInputTps 接口,您还可以通过云消息队列 RocketMQ 控制台查看指定 Topic 中生产消息的统计数据。具体操作,请参见 仪表盘。

OnsConsumerAccumulate-查询消息消费堆积情况

变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsConsumerAccumulate 接口,您还可以通过云消息队列 RocketMQ 控制台查看 Group ID 的消息消费堆积情况。具体操作,请参见 查看消费者状态。

OnsInstanceBaseInfo-查询实例基本信息和收发消息的接...

客户端需要通过接入点接入云消息队列 RocketMQ 完成消息的收发,可通过调用本接口查询实例接入点。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。调试 ...

消息队列RocketMQ版

目标端消息队列RocketMQ版参数配置 参数 说明 示例 实例ID 选择接收 云消息队列 RocketMQ 消息的目标实例。MQ_INST_115964845466*_BYEiGXc4 Topic 选择目标实例的Topic。test 在 数据处理 区域,设置消息的过滤、转换、重试和死信。消息...

消息队列RocketMQ版

RocketMQ 4.x 实例ID 选择接收 云消息队列 RocketMQ 消息的目标实例。MQ_INST_115964845466*_BYEiGXc4 Topic 选择目标实例的Topic。test 在 数据处理 区域,设置消息的过滤、转换、重试和死信。消息过滤 无需过滤:默认投递全部事件。...

OnsGroupConsumerUpdate-配置消费集群的消息读取权限

配置指定Group ID对应的消费集群的消息读取权限。本接口一般用于禁止特定Group ID读取消息的场景。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据...

消息队列RocketMQ版是否能保证消息不重复?

绝大多数情况下,消息是不重复的。作为一款分布式消息中间件,在网络抖动、应用处理超时等异常情况下,无法保证消息不重复,但是能保证消息不丢失。

消息轨迹

在分布式应用中,云消息队列 RocketMQ 作为全链路中异步解耦的关键服务,提供的消息轨迹数据可有效将业务上下游信息串联起来,帮助您更好地排查异常信息,定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 定义的轨迹参数...

普通消息

普通消息是指 云消息队列 RocketMQ 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意,云消息队列 RocketMQ 提供的四种消息类型所对应的Topic不能混用,例如,您创建的普通消息...

如何快速使用消息队列RocketMQ版的TCP Java SDK收发...

本文提供使用 消息队列RocketMQ版 的TCP Java SDK收发消息的快速入门视频。

事务消息

消息队列 RocketMQ 提供的分布式事务消息适用于所有对数据最终一致性有强需求的场景。本文介绍 云消息队列 RocketMQ 事务消息的概念、优势、典型场景、交互流程、使用规则以及示例代码。概念介绍 事务消息:云消息队列 RocketMQ ...

顺序消息

本文介绍 云消息队列 RocketMQ 顺序消息的概念、适用场景、实现原理以及使用过程中的注意事项。什么是顺序消息 顺序消息是 云消息队列 RocketMQ 提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic,消息严格按照...

普通消息

普通消息为 云消息队列 RocketMQ 中最基础的消息,区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...

订阅消息

本文介绍如何通过 云消息队列 RocketMQ 的Java SDK订阅消息。订阅方式 云消息队列 RocketMQ 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个...

顺序消息

顺序消息为 云消息队列 RocketMQ 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,...

消息查询

消息队列 RocketMQ 提供了三种消息查询的方式,分别是按Message ID、Message Key以及Topic查询。您可以通过消息查询验证消息是否发送成功、验证消息发送的内容是否正确、以及进一步查看消息的轨迹信息。查询方式说明 由于消息在 云...

订阅消息

消息队列 RocketMQ 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个Consumer实例,那么在集群消费模式下每个实例平均分摊,只消费其中的3条消息。...

事务消息

事务消息为 云消息队列 RocketMQ 中的高级特性消息,本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行,同时需要调用多个下游业务...

订阅消息

本文介绍如何通过 云消息队列 RocketMQ 的C/C++ SDK订阅消息。订阅方式 云消息队列 RocketMQ 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个...

死信消息

消息队列 RocketMQ 支持将这些死信消息保存至指定Topic,方便后续进行业务恢复或回溯。本文介绍死信消息的应用场景、死信策略、使用限制、配置方法和使用建议。应用场景 典型死信消息处理场景 消息重试失败后,您可以选择将死信消息...

消息过滤

消费者订阅了某个主题后,云消息队列 RocketMQ 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息,可通过设置过滤条件在 云消息队列 RocketMQ 服务端进行过滤,只获取到需要关注的消息子集,避免接收到大量无效的...

消息队列RocketMQ版客户端如何设置消费线程数?

消息队列 RocketMQ 所提供的TCP Java SDK支持多线程消费,且适用于所有消息类型,本文介绍如何设置消费线程数的方法。在启动Consumer时,设置一个ConsumeThreadNums属性即可。具体示例如下所示。public static void main(String[]args...

消息队列Kafka版

RocketMQ 4.x 实例ID 选择接收 云消息队列 RocketMQ 消息的目标实例。MQ_INST_115964845466*_BYEiGXc4 Topic 选择目标实例的Topic。test 在 数据处理 区域,设置消息的过滤、转换、重试和死信。消息过滤 无需过滤:默认投递全部事件。...

消息过滤

消费者订阅了某个Topic后,云消息队列 RocketMQ 会将该Topic中的所有消息投递给消费端进行消费。若消费者只需要关注部分消息,可通过设置过滤条件在 云消息队列 RocketMQ 服务端完成消息过滤,只消费需要关注的消息。本文介绍消息...

消息队列Kafka版

本文介绍如何在 云消息队列 RocketMQ 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买并部署 云消息队列 ...

收发事务消息

消息队列 RocketMQ 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 事务消息,能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息,请参见 事务消息。前提条件 您已完成以下操作:下载C...

收发普通消息

普通消息是指 云消息队列 RocketMQ 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用,例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...

收发顺序消息

顺序消息(FIFO消息)是 云消息队列 RocketMQ 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的Java SDK收发顺序消息的示例代码。前提条件 您已完成以下操作:下载1.2.7或以上版本的Java SDK。更多信息,请参见...

收发顺序消息

顺序消息FIFO(First In First Out)是 云消息队列 RocketMQ 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类:全局顺序:对于指定的一个Topic,...

收发普通消息

普通消息是指 云消息队列 RocketMQ 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用TCP协议下的.NET SDK收发普通消息的示例代码。前提条件 您已完成以下操作:下载.NET SDK。更多信息,请参见 版本...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 消息服务 云消息队列 RocketMQ 版 表格存储 智能对话机器人 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用