查看消费者状态
就绪消息量 消息在 云消息队列 RocketMQ 版 服务端已就绪，对消费者可见可被消费的消息。排队时间 最早一条就绪消息的就绪时间和当前时刻的时间差。该时间反映消费者拉取消息的及时性。订阅关系 显示该Group ID下消费者实例群组的订阅关系...
消费进度管理
云消息队列 RocketMQ 版 重置消费位点功能只能重置对消费者可见的消息，不能重置定时中、重试等待中的消息。更多信息，请参见 定时/延时消息 和 消费重试。版本兼容性 关于消费者分组的消费位点初始值，不同的服务端版本中定义如下：服务端...
消息负载均衡策略
对消费者而言，消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载均衡策略可分为：负载均衡策略（客户端Java v2.x.x.Final和C++ v3.x.x）负载...
概述
应用场景 异步解耦消息队列的生产消费模型可以解耦上下游业务系统，并支持下游多个消费者对同一消息进行消费和处理。以金融场景为例，支付中心作为支付宝主站最核心的系统，每笔支付数据的产生会引起几百个下游业务系统的关注，包括账户...
消费幂等
为了防止消息重复消费导致业务处理异常，消息队列RocketMQ版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
重置消费位点
重置消费位点功能只能重置对消费者可见的消息，不能重置定时中、重试等待中的消息。重试消费位点只能在消费者在线时进行操作。操作步骤 登录 云消息队列 RocketMQ 版 控制台，在左侧导航栏单击 实例列表。在顶部菜单栏选择地域，如 华东1...
消息幂等
为了防止消息重复消费导致业务处理异常，SOFAStack 消息队列的消费者在接收到消息后，有必要根据业务上的唯一 Key 对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
顺序消息
待消费 消息被发送到服务端，对消费者可见，等待消费者消费的状态。消费中 消息被消费者获取，并按照消费者本地的业务逻辑进行处理的过程。此时服务端会等待消费者完成消费并提交消费结果，如果一定时间后没有收到消费者的响应，云消息队列...
普通消息
待消费 消息被发送到服务端，对消费者可见，等待消费者消费的状态。消费中 消息被消费者获取，并按照消费者本地的业务逻辑进行处理的过程。此时服务端会等待消费者完成消费并提交消费结果，如果一定时间后没有收到消费者的响应，云消息队列...
消息过滤
消费者订阅了某个主题后，云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...
仪表盘
最晚一条拉取消息的位点－最晚一条提交消息的位点 已就绪的消息（ready messages）消息在 云消息队列 RocketMQ 版 服务端已就绪，对消费者可见可被消费的消息。最大消息位点－最晚一条拉取消息的位点 消息堆积量（consumer lag）所有未处理...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和...定时消息到达定时时间后才对消费者可见，并在控制台查询到消息轨迹。
仪表盘
最晚一条拉取消息的位点－最晚一条提交消息的位点 已就绪的消息（ready messages）消息在 云消息队列 RocketMQ 版 服务端已就绪，对消费者可见可被消费的消息。最大消息位点－最晚一条拉取消息的位点 消息堆积量（consumer lag）所有未处理...
消息（Message）
Delay：定时/延时消息，通过指定延时时间控制消息生产后不要立即投递，而是在延时间隔后才对消费者可见。Transaction：事务消息，云消息队列 RocketMQ 版 支持分布式事务消息，支持应用数据库更新和消息调用的事务一致性保障。消息队列 ...
阿里云日志服务Splunk Add-on
本文介绍如何通过阿里云日志服务Splunk Add-on将日志服务上的日志投递到Splunk。...对消费者监控仪表盘中的图表设置告警。更多信息，请参见 设置告警。如果您未开启服务日志功能，可通过日志服务控制台查看消费组状态。更...
配置消费者鉴权
消费者说明 对消费者进行描述。认证方式 当前消费者支持的认证方式。密钥类型 对称密钥：生成一份默认的JWKS配置（每个消费者不同），包含加密或者解密Token时使用的密钥。非对称密钥：需要您自己填写完整的JWKS配置，使用私钥加密Token。...
消费者负载均衡
消费者从 云消息队列 RocketMQ 版 获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
基本概念
重置消费位点 以时间轴为坐标，在消息持久化存储的时间范围内，重新设置消费者分组对已订阅主题的消费进度，设置完成后消费者将接收设定时间点之后，由生产者发送到 云消息队列 RocketMQ 版 服务端的消息。更多信息，请参见 重置消费位点。...
2022/09/08 更新日志
四、Sample小程序新增售后流程、查看订单发货物流和确认收货的功能 4.1 售后流程 店铺消费者可以在微信小程序订单详情页对单个商品申请售后。店铺消费者可以申请三种类型的售后单：待发货状态下申请仅退款，待收货/已完成状态下申请仅退款...
查看消费者状态
如果消息消费异常，您可以在 SOFAStack 消息队列控制台查看消费者状态，进行问题排查。本文介绍如何查看消费者状态。查看 Group ID 消费者状态 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列>Group 管理。单击目标 Group ID ...
队列服务订阅推送
在不同的消费者组间，数据会并列地推送给每一个存在的消费者，举例来看：如果您的多个消费者在同一个组内，您可以观察到数据会在这些消费者之间进行均衡地分发，消费者会收到不同的数据。如果您的多个消费者在多个不同的组内，您可以观察到...
事务消息
提交待消费 第二阶段如果事务执行结果明确为提交，服务端会将半事务消息重新存储到普通存储系统中，此时消息对下游消费者可见，等待被消费者获取并消费。消费中 消息被消费者获取，并按照消费者本地的业务逻辑进行处理的过程。此时服务端会...
API概览
消费者分组 API 标题 API概述 CreateConsumerGroup 创建消费者分组 创建云消息队列 RocketMQ 版的消费者分组（ConsumerGroup）。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定...
迁移消费者程序
若您创建消费者程序时使用Assign方式消费消息，请先在源集群停止旧消费者程序，旧消费者程序停止后，迁移组件也会停止同步旧消费者程序所用的消费组的消费位点，然后再在目标实例启动新消费者程序。若您无法确定消费者程序使用哪种消费方式...
消费组监控与告警
背景信息 一个消费组包含多个消费者，每个消费者消费Logstore中的一部分Shard。同一个消费组下面的消费者共同消费一个Logstore中的日志数据，消费者之间不会重复消费数据。Shard数据模型可以简单理解为一个队列，新写入的数据被加到队尾，...
消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
ListConsumerGroupSubscriptions-查询消费者组订阅...
查询指定消费者组的订阅关系。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action ...
集群消费和广播消费
由于消费者应用一般是分布式系统，以集群方式部署，因此消息队列约定以下概念：集群：使用相同 Group ID 的消费者属于同一个集群。同一个集群下的消费者消费逻辑必须完全一致（包括 Tag 的使用）。详情请参见 订阅关系一致。集群消费：当...
DATASOURCE:ROCKETMQ5:ConsumerGroups
DATASOURCE:ROCKETMQ5:ConsumerGroups类型用于查询ROCKETMQ5.0系列的消费者分组。语法 {"Type":"DATASOURCE:ROCKETMQ5:ConsumerGroups","Properties":{"InstanceId":String } } 属性 属性名称 类型 必须 允许更新 描述 约束 InstanceId ...
消息轨迹
是否顺序投递 消费者所属的消费者分组是否开启顺序消费。投递时间 云消息队列 RocketMQ 版 服务端将消息投递给消费者的时间。应答时间 云消息队列 RocketMQ 版 收到消费者返回的消费结果的时间。invisibleDuration SimpleConsumer传入的...
为Dubbo服务动态配置超时时间
针对消费者应用 选择针对当前服务的消费者应用，星号（*）表示所有消费者应用。超时时间 设置调用的超时时间，超时时间应设置为大于0的整数，单位：ms。此配置优先级高于其他同级别配置。超时配置优先级关系参考：相较于其他配置优先级：...
准备RAM用户
例如，在使用Dataphin过程中，某企业规划不同的员工负责数据开发、数据运维、数据分析阶段的工作，并且企业管理者对员工间的权限控制和数据安全有要求。因此，您可以创建3个RAM用户，将RAM用户同步至Dataphin后，添加为项目空间的成员并...
CreateConsumerGroup-创建消费者分组
创建云消息队列 RocketMQ 版的消费者分组（ConsumerGroup）。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定消费者分组订阅相关的主题来实现消息订阅。接口说明 注意 阿里云...
智能导购企微版概述
智能导购企微版深度融合企业微信，赋能导购高效运营消费者，助力企业降本提效。在消费升级的背景下，消费者的消费场景发生了转移，尤其在新冠疫情影响之下，线下流量告急，线上流量经营引起众多泛零售企业的关注，如何利用私域流量获得业绩...
GetConsumerGroup-获取指定消费者分组详情
获取某个指定消费者分组的详细信息。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。调试...
服务提供方或消费方流控
通过对消费方B设置限流规则（limitApp）来实现这个目的。对于默认框架例如Dubbo，AHAS会自动解析Dubbo消费方的 application name 作为调用方名称（origin），在进行资源保护的时候都会带上调用方名称。而对于非默认框架，只需要在Sentinel...
ConsumerGroupHeartBeat
调用ConsumerGroupHeartBeat接口为指定消费者发送心跳到服务端。接口说明 Host由Project名称和日志服务Endpoint构成，您需要在Host中指定Project。消费者和服务端通过固定时间发送心跳建立连接。在固定时间段内没有收到心跳，消费者将被...
如何处理消息堆积
导航栏中选择 消息轨迹，单击 创建查询任务，选择 按 Message ID 查询，输入对应的信息，发现部分消息已发送至Broker节点，但未投递给下游消费者。可能原因 云消息队列 RocketMQ 版 的消息发送至Broker节点后，配置了Group ID的客户端根据...
混合部署应用（ECS和K8s环境）
当您需要分离不同形态的应用或者做应用架构迁移时，可以将服务的提供者与消费者分别部署到同一VPC的ECS环境和K8s环境，他们提供的服务也是可以相互发现和调用的。前提条件 请确保您混合部署应用的ECS集群和K8s集群属于同一个VPC，且在EDAS...
- 产品推荐
- 这些文档可能帮助您