海量并发访问 支持多个生产者和消费者并发访问同一队列，并能确保某条消息在取出之后的特定时间内，无法被其他消费者获得。您可以根据业务需求自由伸缩并发访问数。消息投递保障 在消息有效期内，确保消息至少能被成功消费一次。消息服务...
一个消费组只能创建一个消费者（consumer），并通过该消费者执行数据消费。若DTS增量数据采集模块或者客户端切换，则可能会导致数据重复。操作步骤 登录 数据传输控制台。在左侧导航栏，单击 数据订阅。在 数据订阅列表 页面上方，选择订阅...
本文介绍 云消息队列 RocketMQ 版 中生产者（Producer）的定义、模型关系、内部属性、版本兼容性及使用建议。定义 生产者是 云消息队列 RocketMQ 版 系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务...
服务层 消费者调用总QPM 消费者用户请求的次数/分钟，即QPM=（并发数/平均响应时间）×60。同城多活容灾 说明 仅限同城多活SpringCloud服务、同城多活Dubbo服务和同城多活EDAS服务。异地双活容灾 说明 仅限异地应用多活SpringCloud服务和...
此时服务消费者去调用服务提供者时，所有的访问请求都会通过限流模块进行计算，若服务消费者调用量在一定时间内超过了预设阈值，则会触发限流策略，进行限流处理。降级 在EDAS中，降级通常用于对下游出现超时的非核心服务提供者进行低优先...
查询指定实例下消费者分组的列表信息。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。...
广播消费：当使用广播消费模式时，消息队列会将每条消息推送给集群内（单 Zone 内）所有注册过的消费者，保证消息至少被每个消费者消费一次。集群消费模式 适用于消费端集群化部署，每条消息只需要被处理一次的场景。此外，由于消费进度在...
背景信息 定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意事项，请参见 定时和延时消息。说明 对于新手用户，建议在...
背景信息 主要包括以下三部分内容：普通消息生产者和 Spring 集成 事务消息生产者和 Spring 集成 消息消费者和 Spring 集成 请确保同一个 Group ID 下所有 Consumer 实例的订阅关系保持一致。详情请参见 订阅关系一致。SpringBoot 框架下...
生产者可以在消费者启动之前产生事件，消费者也可以在生产者启动之前监听事件。使用说明 如何使用Knative，请参见 部署Knative；关于如何管理Knative组件，请参见 管理Knative组件、升级组件。关于Knative的更多信息，请参见 Knative概述。...
在超时时间段内没有收到心跳，消费者将被删除。单位：秒。300 返回参数 名称 类型 描述 示例值 headers object Server string 服务器名称。nginx Content-Type string 响应内容类型。支持 application/json、application/x-protobuf 两种...
V4_3_6 ConsumeType string 消费者消费消息的模式。取值说明如下：PUSH：云消息队列 RocketMQ 版服务端主动向消费者推送消息。PULL：消费者主动向云消息队列 RocketMQ 版服务端拉取消息。PUSH ThreadCount integer 消费线程数。20 ...
使用 云消息队列 RocketMQ 版 进行消息收发，您需要创建Group ID用于标识同一类生产者实例或者同一类消费者实例。本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除和查询Group。使用限制 单实例下最多创建1000个Group，建议您...
创建完 Topic 后，您需要为消息的消费者（或生产者）创建客户端 ID，即 Group ID 作为标识。Group ID 和 Topic 的关系是 N：N，即一个消费者可以订阅多个 Topic，同一个 Topic 也可以被多个消费者订阅；一个生产者可以向多个 Topic 发送...
生产者发送消息到 云消息队列 RocketMQ 版 服务端时，云消息队列 RocketMQ 版 将根据生产者负载均衡策略将消息均匀的存储在多个队列中，避免产生热点队列和性能瓶颈。本文介绍 云消息队列 RocketMQ 版 生产者的负载均衡策略。背景信息 了解...
SOFAStack 消息队列的消费者和生产者客户端对象是线程安全的，可以在多个线程之间共享使用。您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高消息...
删除Group 警告 删除Group后，由该Group ID标识的生产者和消费者客户端将在客户端发生重新连接时认证失败，已连接生产者和消费者不受影响。进入 Group 管理 页面。在Group列表中，找到需要删除的目标Group，在其 操作 列中，选择 更多>删除...
创建Topic Topic是 云消息队列 RocketMQ 版 里对消息的一级归类，例如创建名称为Topic_Trade的Topic来识别交易类消息，消息生产者将消息发送到Topic_Trade，而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下：Topic不...
创建Topic Topic是 云消息队列 RocketMQ 版 里对消息的一级归类，例如创建名称为Topic_Trade的Topic来识别交易类消息，消息生产者将消息发送到Topic_Trade，而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下：Topic不...
ons-client客户端必须升级到最新版本：JAVA：版本说明 C++：版本说明.NET： 版本说明 资源申请流程优化 原 云消息队列 RocketMQ 版 的资源包括以下三个部分：消息主题（Topic）生产者（Producer ID）消费者（Consumer ID）三者之间都是多对...
如果消息消费出现异常，您可以在 云消息队列 RocketMQ 版 控制台查看指定Group ID的消费状态，包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等，帮助您快速定位异常原因。应用场景 消费者状态信息包括在线...
如果生产者发送一个消息不想立即被消费者消费（典型的使用场景为定期任务），生产者可以在发送消息时设置 DelaySeconds 参数。发送带 DelaySeconds 参数值大于0的消息初始状态为Delayed，此时消息不能被消费者消费，只有等 DelaySeconds ...
Topic 是 SOFAStack 消息队列里对消息的一级归类，消息生产者将消息...重要 Topic 删除之后，相关的生产者、消费者将会立即停止服务，且将在 10 分钟后完成所有相关资源的清理，请谨慎操作。后续操作 查看订阅关系 查看消费者状态 消息查询
背景信息 通过定时消息，在消息发送后，可以在当前时间点之后的某一个时间点，再投递到消费者进行消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。关于定时消息的更多信息，参见 消息类型>定时和延时消息。...
在断网或者是生产者应用重启的特殊情况下，若服务端未收到发送者提交的二次确认结果，或服务端收到的二次确认结果为Unknown未知状态，经过固定时间后，服务端将对消息生产者即生产者集群中任一生产者实例发起消息回查。说明 服务端回查的...
消息消费者 Consumer 消息消费者，也称为消息订阅者，负责接收并消费消息。Consumer 实例 Consumer instance Consumer 的一个对象实例，不同的 Consumer 实例可以运行在不同进程内或者不同机器上。一个 Consumer 实例内配置线程池消费消息...
如果是简单模式升级到标准模式，在数据开发界面需要查询生产环境数据，则需要先申请生产者角色权限，再使用 项目名.表名 进行访问。申请权限具体请参考 申请表权限 数据开发界面历史执行日志如何获取？您可以进入数据开发界面左侧边栏找到 ...
背景信息 云消息队列 RocketMQ 版 的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产。这两种场景下，消费者客户端启动后从哪里开始消费？如何标记已消费的消息？这些都是由 云消息队列 RocketMQ 版 ...
新增指标如下：生产者 消息生产调用耗时：统计Topic生产消息时的耗时。消息生产调用成功率：统计Topic消息生产的成功率。消费者 平均消费成功率：统计指定实例下所有消息的消费成功率。处理中消息量：统计在消费者客户端正在处理但客户端还...
在消息收发模型中，生产者将消息发送至主题，消费者通过订阅指定的主题来消费其中的消息。UpdateTopic 更新主题 更新主题的备注信息。DeleteTopic 删除主题 删除指定主题。ListTopics 查询主题列表 查询指定实例下的主题列表信息。GetTopic...
内部属性 消费者分组名称 定义：当前消费者关联的消费者分组名称，消费者必须关联到指定的消费者分组，通过消费者分组获取消费行为。更多信息，请参见 消费者分组（ConsumerGroup）。取值：消费者分组为 云消息队列 RocketMQ 版 的逻辑资源...
云消息队列 RocketMQ 版 的消费者和生产者客户端对象是线程安全的，可以在多个线程之间共享使用。您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高...
若堆积量较大，请检查消息消费速率和生产速率，若前者小于后者，建议您通过提升消费能力的方式来缓解。查看Topic被订阅的Group 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例...
功能原理 什么是普通消息 定义：普通消息是 云消息队列 RocketMQ 版 基本消息功能，支持生产者和消费者的异步解耦通信。普通消息生命周期 初始化 消息被生产者构建并完成初始化，待发送到服务端的状态。待消费 消息被发送到服务端，对消费...
消息轨迹数据 云消息队列 RocketMQ 版 系统中，一条消息的完整链路包含生产者、服务端、消费者三个角色，每个角色处理消息的过程中都会在轨迹链路中增加相关的信息，将这些信息汇聚即可获取任意消息当前的状态。使用说明 所有类型的消息...
消费者从 云消息队列 RocketMQ 版 获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
业务上下游配合：选择Topic后，需要通知所有使用该Topic的上下游业务应用（生产者、消费者应用）准备切换接入点。重要 请务必通知到所有迁移Topic涉及的上下游业务应用，如果业务应用切换实例接入点遗漏，可能会造成消息消费延迟等风险。...
receive 消费者接收消息的长轮询过程，与长轮询的生命周期保持一致。receive span默认不启用，若要启用，则需要在运行时增加-Dotel.instrumentation.messaging.experimental.receive-telemetry.enabled，并将参数值设置为 true。process ...
生产者生产消息并发送至 云消息队列 RocketMQ 版 服务端，消息被存储在服务端的主题中，消费者通过订阅主题消费消息。消息生产 生产者（Producer）：云消息队列 RocketMQ 版 中用于产生消息的运行实体，一般集成于业务调用链路的上游。生产...
创建 Group ID 创建完 Topic 后，您需要为消息的消费者（或生产者）创建客户端 ID，即 Group ID 作为标识。Group ID 和 Topic 的关系是 N：N，即一个消费者可以订阅多个 Topic，同一个 Topic 也可以被多个消费者订阅；一个生产者可以向多个...