查看消费者状态
就绪消息量 消息在 云消息队列 RocketMQ 版 服务端已就绪，对消费者可见可被消费的消息。排队时间 最早一条就绪消息的就绪时间和当前时刻的时间差。该时间反映消费者拉取消息的及时性。订阅关系 显示该Group ID下消费者实例群组的订阅关系...
消费进度管理
云消息队列 RocketMQ 版 重置消费位点功能只能重置对消费者可见的消息，不能重置定时中、重试等待中的消息。更多信息，请参见 定时/延时消息 和 消费重试。版本兼容性 关于消费者分组的消费位点初始值，不同的服务端版本中定义如下：服务端...
消息负载均衡策略
对消费者而言，消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载均衡策略可分为：负载均衡策略（客户端Java v2.x.x.Final和C++ v3.x.x）负载...
概述
应用场景 异步解耦消息队列的生产消费模型可以解耦上下游业务系统，并支持下游多个消费者对同一消息进行消费和处理。以金融场景为例，支付中心作为支付宝主站最核心的系统，每笔支付数据的产生会引起几百个下游业务系统的关注，包括账户...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
消费幂等
为了防止消息重复消费导致业务处理异常，消息队列RocketMQ版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
重置消费位点
重置消费位点功能只能重置对消费者可见的消息，不能重置定时中、重试等待中的消息。重试消费位点只能在消费者在线时进行操作。操作步骤 登录 云消息队列 RocketMQ 版 控制台，在左侧导航栏单击 实例列表。在顶部菜单栏选择地域，如 华东1...
消息幂等
为了防止消息重复消费导致业务处理异常，SOFAStack 消息队列的消费者在接收到消息后，有必要根据业务上的唯一 Key 对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
消息过滤
消费者订阅了某个主题后，云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...
普通消息
待消费 消息被发送到服务端，对消费者可见，等待消费者消费的状态。消费中 消息被消费者获取，并按照消费者本地的业务逻辑进行处理的过程。此时服务端会等待消费者完成消费并提交消费结果，如果一定时间后没有收到消费者的响应，云消息队列...
顺序消息
待消费 消息被发送到服务端，对消费者可见，等待消费者消费的状态。消费中 消息被消费者获取，并按照消费者本地的业务逻辑进行处理的过程。此时服务端会等待消费者完成消费并提交消费结果，如果一定时间后没有收到消费者的响应，云消息队列...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和...定时消息到达定时时间后才对消费者可见，并在控制台查询到消息轨迹。
仪表盘
最晚一条拉取消息的位点－最晚一条提交消息的位点 已就绪的消息（ready messages）消息在 云消息队列 RocketMQ 版 服务端已就绪，对消费者可见可被消费的消息。最大消息位点－最晚一条拉取消息的位点 消息堆积量（consumer lag）所有未处理...
仪表盘
最晚一条拉取消息的位点－最晚一条提交消息的位点 已就绪的消息（ready messages）消息在 云消息队列 RocketMQ 版 服务端已就绪，对消费者可见可被消费的消息。最大消息位点－最晚一条拉取消息的位点 消息堆积量（consumer lag）所有未处理...
消息（Message）
Delay：定时/延时消息，通过指定延时时间控制消息生产后不要立即投递，而是在延时间隔后才对消费者可见。Transaction：事务消息，云消息队列 RocketMQ 版 支持分布式事务消息，支持应用数据库更新和消息调用的事务一致性保障。消息队列 ...
阿里云日志服务Splunk Add-on
本文介绍如何通过阿里云日志服务Splunk Add-on将日志服务上的日志投递到Splunk。...对消费者监控仪表盘中的图表设置告警。更多信息，请参见 设置告警。如果您未开启服务日志功能，可通过日志服务控制台查看消费组状态。更...
消费者负载均衡
消费者从 云消息队列 RocketMQ 版 获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
基本概念
重置消费位点 以时间轴为坐标，在消息持久化存储的时间范围内，重新设置消费者分组对已订阅主题的消费进度，设置完成后消费者将接收设定时间点之后，由生产者发送到 云消息队列 RocketMQ 版 服务端的消息。更多信息，请参见 重置消费位点。...
2022/09/08 更新日志
四、Sample小程序新增售后流程、查看订单发货物流和确认收货的功能 4.1 售后流程 店铺消费者可以在微信小程序订单详情页对单个商品申请售后。店铺消费者可以申请三种类型的售后单：待发货状态下申请仅退款，待收货/已完成状态下申请仅退款...
什么是场景金融链接器
场景金融链接器是企业的金融助手、机构的场景伙伴，通过联合阿里巴巴消费与产业互联网场景及外部合作场景，提供面向消费者、企业的金融链接数智科技服务。提升金融机构的贷款、保险、银行卡户等产品服务体验和营销运营的效率，实现场景侧...
事务消息
提交待消费 第二阶段如果事务执行结果明确为提交，服务端会将半事务消息重新存储到普通存储系统中，此时消息对下游消费者可见，等待被消费者获取并消费。消费中 消息被消费者获取，并按照消费者本地的业务逻辑进行处理的过程。此时服务端会...
实例迁移的最佳实践
消费者对设备所属实例不感知，仍通过App使用共享服务平台提供的设备共享服务，应用系统查询设备信息在企业版实例中。此时，调用服务相关接口，必须传入实例ID，才可通过阿里云网关使用物联网平台服务，控制已迁移设备。说明 设备全量迁移...
智能导购企微版概述
智能导购企微版深度融合企业微信，赋能导购高效运营消费者，助力企业降本提效。在消费升级的背景下，消费者的消费场景发生了转移，尤其在新冠疫情影响之下，线下流量告急，线上流量经营引起众多泛零售企业的关注，如何利用私域流量获得业绩...
配置消费者鉴权
消费者说明 对消费者进行描述。认证方式 当前消费者支持的认证方式。密钥类型 对称密钥：生成一份默认的JWKS配置（每个消费者不同），包含加密或者解密Token时使用的密钥。非对称密钥：需要您自己填写完整的JWKS配置，使用私钥加密Token。...
用户洞察概述
用户分析：Quick Audience内置了强大的分析引擎，用户基于洞察分析功能可以实现对消费者的显著性特征识别，对各种画像标签进行分布观测，同时可以根据业务需要对自定义消费者运营模型（AIPL/RFM模型）进行分析，帮助企业快速了解企业当前的...
服务提供方或消费方流控
通过对消费方B设置限流规则（limitApp）来实现这个目的。对于默认框架例如Dubbo，AHAS会自动解析Dubbo消费方的 application name 作为调用方名称（origin），在进行资源保护的时候都会带上调用方名称。而对于非默认框架，只需要在Sentinel...
服务提供方或消费方流控
通过对消费方 B 设置限流规则（limitApp）来实现这个目的。对于默认框架例如 Dubbo，AHAS 会自动解析 Dubbo 消费方的 application name 作为调用方名称（origin），在进行资源保护的时候都会带上调用方名称。而对于非默认框架，只需要在 ...
技术发展趋势
产生、使用和管理对生活产生重要影响的数据信息，对于消费者、政府和企业的正常生活和运转必不可少。消费者和企业将持续在不同设备和云之间产生、分享和访问数据，增长速度也将超出此前的预期。生产处理实时化 从数据的3V特性（体积，速度...
消费者分组（ConsumerGroup）
使用建议 按照业务合理拆分分组 云消息队列 RocketMQ 版 的消费者和主题是多对多的关系，对于消费者分组的拆分设计，建议遵循以下原则：消费者的投递顺序一致：同一消费者分组下所有消费者的消费投递顺序是相同的，统一都是顺序投递或并发...
查看消费者状态
如果消息消费异常，您可以在 SOFAStack 消息队列控制台查看消费者状态，进行问题排查。本文介绍如何查看消费者状态。查看 Group ID 消费者状态 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列>Group 管理。单击目标 Group ID ...
队列服务订阅推送
在不同的消费者组间，数据会并列地推送给每一个存在的消费者，举例来看：如果您的多个消费者在同一个组内，您可以观察到数据会在这些消费者之间进行均衡地分发，消费者会收到不同的数据。如果您的多个消费者在多个不同的组内，您可以观察到...
订阅服务
服务发布后，订阅者使用消费凭证对发布的服务发起订购，发布者审批后订购生效，才能正常调用服务。前提条件 当订阅者不是服务发布者时，订阅者需要先申请服务所在实例的权限。具体操作，请参见 申请实例。订阅服务流程 在快速体验订阅服务...
API概览
消费者分组 API 标题 API概述 CreateConsumerGroup 创建消费者分组 创建云消息队列 RocketMQ 版的消费者分组（ConsumerGroup）。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定...
商品理解介绍
应用场景 商品理解应用场景如下：电子商务 可以为电子商务提供通过图像搜索商品等能力，消费者只需上传商品照片就可以在商品库中进行商品搜索与匹配，电子商务企业可结合具体商品情况为消费者提供商品销售和商品推荐，提升消费者购买体验。...
迁移消费者程序
若您创建消费者程序时使用Assign方式消费消息，请先在源集群停止旧消费者程序，旧消费者程序停止后，迁移组件也会停止同步旧消费者程序所用的消费组的消费位点，然后再在目标实例启动新消费者程序。若您无法确定消费者程序使用哪种消费方式...
为Dubbo服务配置服务降级
业务高峰期时，您可以通过服务降级功能，对部分的服务消费者进行降级操作，让不重要的业务方不进行真实地调用，直接返回降级的结果，将宝贵的下游服务提供者资源保留给重要的业务调用方使用，从而提升整体服务的稳定性。本文介绍如何创建并...
用户洞察概述
随着互联网技术的发展，企业通过各种途径积累了消费者资产，Quick Audience用户洞察模块旨在通过丰富的用户洞察模型和便捷的策略配置，帮助企业完成消费者多维洞察分析，为后续的消费者运营和触达奠定人群基础。功能简介 用户洞察模块提供...
基本概念
消费者 接收事件并对事件执行操作。消费者通过内容和数据执行某些逻辑生成新的事件。中间件 接收包含事件内容的消息，并将事件转发到下一个接收者。下一个接收者可能是消费者，也可能是另一个中间件。中间件的典型任务就是根据内容里的信息...
DATASOURCE:ROCKETMQ5:ConsumerGroups
DATASOURCE:ROCKETMQ5:ConsumerGroups类型用于查询ROCKETMQ5.0系列的消费者分组。语法 {"Type":"DATASOURCE:ROCKETMQ5:ConsumerGroups","Properties":{"InstanceId":String } } 属性 属性名称 类型 必须 允许更新 描述 约束 InstanceId ...
消费组监控与告警
背景信息 一个消费组包含多个消费者，每个消费者消费Logstore中的一部分Shard。同一个消费组下面的消费者共同消费一个Logstore中的日志数据，消费者之间不会重复消费数据。Shard数据模型可以简单理解为一个队列，新写入的数据被加到队尾，...
- 产品推荐
- 这些文档可能帮助您