本文介绍如何通过对API消费者进行授权管理，确保只有经过身份验证和权限校验的请求才能访问服务资源。授权消费者 登录 云原生API网关控制台。在左侧导航栏，选择 消费者，并在顶部菜单栏选择地域。在 消费者 页面，单击目标消费者进入详情...
不可见状态：当消费者接收了一条消息后，这条消息会进入不可见状态，意味着其他消费者在此期间无法接收到这条消息，以免消息被多个消费者同时处理。可见性超时时间：是指从消费者接收消息开始到允许其它消费者再次接收该消息的时间段。当...
消费者管理 API 标题 API概述 RemoveConsumerAuthorizationRule 删除消费者授权规则 删除消费者授权规则 QueryConsumerAuthorizationRules 查询消费者授权规则列表 查询消费者授权规则列表 CreateConsumerAuthorizationRules 创建消费者...
消费者管理 API 标题 API概述 RemoveConsumerAuthorizationRule 删除消费者授权规则 删除消费者授权规则 QueryConsumerAuthorizationRules 查询消费者授权规则列表 查询消费者授权规则列表 CreateConsumerAuthorizationRules 创建消费者...
消费进度：云消息队列 RocketMQ 版服务端默认提供订阅关系持久化的能力，即消费者分组在服务端注册订阅关系后，当消费者离线并再次上线后，可以获取离线前的消费进度并继续消费。Topic和ConsumerGroup的映射关系 一个Topic可以被多个...
为了防止消息重复消费导致业务处理异常，轻量消息队列（原 MNS）的消费者在接收到消息后，需要根据业务唯一标识对消息做幂等处理。本文介绍消费幂等的概念、适用场景以及处理方法。什么是消费幂等 在消息队列场景中，消费幂等处理是指即使...
密钥可被应用于消费者与插件，用于替代原有的明文凭证信息，防止凭证泄露。本文介绍如何在相关资源中引用密钥。前提条件 已创建密钥，如尚未创建密钥，参考 创建密钥。重要 支持在云原生API网关 2.1.10 及以上版本中引用密钥。在消费者中...
本文介绍 轻量消息队列（原 MNS）如何保证多个消费者访问同一消息队列，不会丢失消息或者重复消费消息的问题。轻量消息队列（原 MNS）中每个队列都具有可配置的不可见时间段属性（即队列的取出消息隐藏时长属性）。当队列中的某条消息被...
云原生网关支持为路由配置认证，并对指定的消费者进行鉴权，以允许对应消费者访问路由。本文介绍如何配置消费者鉴权。重要 本文适用于云原生网关 普通实例标准版、普通实例专业版。背景信息 相比全局认证鉴权适用于统一登录认证等ToC场景，...
订阅关系一致指的是同一个消费者 Group ID 下所有消费者实例所订阅的 Topic、Tag 以及对消息的处理逻辑必须完全一致。一旦订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。本文提供订阅关系不一致的示例代码，帮助您顺畅地订阅...
云消息队列 RocketMQ 版 的消息负载均衡策略针对生产者和消费者有所差异。对消费者而言，消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载...
反之，消费者的消息处理速度较慢，但QoS值设置较大，导致消费者无法及时处理完已经推送到消费者客户端的消息，消息会在消费超时时间之后重新入队等待再次推送。因此，请针对每个队列的消费耗时，酌情设置QoS值。详情请参见 消费消息时需要...
消费者分组（ConsumerGroup）消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者不同，消费者分组并不是运行实体，而是一个逻辑资源。在 云消息队列 RocketMQ 版 中，通过消费者分组内初始...
例如如下配置中，对于所有前缀为AI的消费者，任意防护维度的防护等级为中，精确匹配的AI-TEST消费者模型幻觉防护等级为高，此时由于AI-TEST消费者被两条规则命中，且任意防护维度防护等级为中的规则排在上方，则优先执行该规则，因任意防护...
如何解决和优化消息堆积 提升消费者吞吐能力：增加消费者实例：在同一个 Group 中增加消费者，前提是 Partition 数≥消费者数。增加Partition数：提高并行度。异步处理：将耗时操作异步化，加快poll循环。批量处理：一次处理多条消息。调整...
应用部署 在消费者主动拉取的消息队列中，由于消费者无法感知泳道相关的服务发现信息，为了确保消息被正确消费，需要确保在任意泳道中合法部署消费者和生产者，如下图：合法部署：在一条泳道中，消息队列的生产者和消费者要么同时存在，...
本文旨在为您介绍如何在云原生网关中设置网关IP黑白名单、配置消费者认证鉴权、以及管理网关实例级别的认证和鉴权。这将帮助您强化安全策略，确保 API 的安全性和访问控制的有效性。设置网关IP黑白名单 您可以通过配置黑名单和白名单，来...
本文旨在为您介绍如何在云原生API网关中设置网关IP黑白名单、配置消费者认证鉴权、以及管理网关实例级别的认证和鉴权。将帮助您强化安全策略，确保 API 的安全性和访问控制的有效性。设置网关IP黑白名单 您可以通过配置黑名单和白名单，来...
DATASOURCE:ROCKETMQ5:ConsumerGroups类型用于查询ROCKETMQ5.0系列的消费者分组。语法 {"Type":"DATASOURCE:ROCKETMQ5:ConsumerGroups","Properties":{"InstanceId":String,"RefreshOptions":String } } 属性 属性名称 类型 必须 允许更新 ...
为了防止消息重复消费导致业务处理异常，云消息队列 RocketMQ 版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的...
新建和管理领域事件消费者 新建领域事件消费者 在 领域事件 页面的 监听的事件 页签，单击 新建领域事件消费者。在 新建领域事件消费者 面板的 关联领域事件 配置向导页面，在 限界上下文 下拉列表中选中目标限界上下文后，选中目标版本。...
消费者分组下如果有多个消费者，只要有一个消费者在线则显订阅状态为在线。OFFLINE：离线。消费者分组下如果有多个消费者，所有消费者都处于离线时订阅状态才显示离线。ONLINE filterExpression string 过滤表达式。filterExpressionType ...
AI 网关支持全局认证和消费者鉴权，确保只有授权请求才能访问服务。本文介绍消费者在AI 网关中如何通过认证和鉴权确保安全访问资源。背景信息 相比全局认证鉴权适用于统一登录认证等ToC场景，API开启消费者认证，适用于授权API给合作伙伴等...
为了防止消息重复消费导致业务处理异常，SOFAStack 消息队列的消费者在接收到消息后，有必要根据业务上的唯一 Key 对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
创建完 Topic 后，您需要为消息的消费者（或生产者）创建客户端 ID，即 Group ID 作为标识。Group ID 和 Topic 的关系是 N：N，即一个消费者可以订阅多个 Topic，同一个 Topic 也可以被多个消费者订阅；一个生产者可以向多个 Topic 发送...
如果在超时时间段内，消费组没有收到心跳，消费者将被删除。使用 ConsumerGroupHeartBeat 接口向消费组发送心跳请求，确保消费者不被删除。前提条件 您已完成以下操作：开通日志服务。初始化日志服务Python SDK。参数说明 def heart_beat...
云原生网关支持为路由配置认证，本文介绍如何配置路由认证。操作步骤 登录 MSE网关管理控制台，并在顶部菜单栏选择地域。在左侧导航栏选择 云原生网关 网关列表。...相关文档 关于如何配置消费者鉴权，请参见 配置消费者鉴权。
创建云消息队列 RocketMQ 版的消费者分组（ConsumerGroup）。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定消费者分组订阅相关的主题来实现消息订阅。接口说明 重要 阿里云...
消费者分组下如果有多个消费者，只要有一个消费者在线则显订阅状态为在线。OFFLINE：离线。消费者分组下如果有多个消费者，所有消费者都处于离线时订阅状态才显示离线。ONLINE filterExpression string 过滤表达式*filterExpressionType ...
CreateConsumerGroup 创建消费者分组。DeleteTopic 删除主题。DeleteInstance 删除实例。DeleteConsumerGroup 删除消费者分组。UpdateTopic 更新主题。UpdateInstance 更新实例。UpdateConsumerGroup 更新消费者分组。ListTopics 查询主题...
消费者数量 分区数是消费者数量的整数倍 由于一个分区在一个消费者组内只能被一个消费者消费，当分区数是消费者的数量的整数倍，可以保证每个消费者负责消费的分区数量是一致的，避免出现Topic分区倾斜。设置 Topic 分区数 登录 云消息队列...
相关文档 Group的相关操作也可以通过调用API完成：CreateConsumerGroup-创建消费者分组 UpdateConsumerGroup-更新消费者分组 DeleteConsumerGroup-删除消费者分组 ListConsumerGroups-查询消费者分组列表 GetConsumerGroup-获取指定消费者...
如果开启了消费者认证，需要选择对应已授权消费者作为请求参数传入。单击 获取工具，选择您需要使用的工具，填入工具参数即可在线调试。如果所选消费者只授权了 MCP工具级别消费者认证，且仅授权某些工具的情况下，HTTP转MCP的场景中获取...
针对消费者应用 选择针对当前服务的消费者应用，星号（*）表示所有消费者应用。超时时间 设置调用的超时时间，超时时间应设置为大于0的整数，单位：ms。此配置优先级高于其他同级别配置。超时配置优先级关系参考：相较于其他配置优先级：...
确保消息处理的可靠性：如果一个消费者长时间无法处理某条消息，云消息队列 RabbitMQ 版 会将消息重新投递给其他消费者，确保消息能够被及时处理。最大投递次数 最大投递次数（Maximum Delivery Attempt）是指系统将一条消息尝试投递给消费...
密钥可被应用于消费者、AI 服务、Agent 服务、MCP 服务以及插件等多种资源，用于替代原有的明文凭证信息，防止凭证泄露。本文介绍如何在相关资源中引用密钥。前提条件 已创建密钥，如尚未创建密钥，参考 创建密钥。重要 支持在 AI 网关 2.1...
优化网络异常导致gRPC消费者消费延迟问题。功能修复 修复多级存储在少数情况下无法根据消息Key查询消息的问题。修复开源Remoting客户端轨迹上报概率丢失问题。修复RocksDB存储一些一致问题。5.0-rmq-20250102-2 变更类型 变更说明 功能修复...
获取某个指定消费者分组的详细信息。接口说明 重要 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。调试...
例如，资源A可以对大部分消费者可以每秒提供10个请求，但是对于消费者caller1是个例外，对caller1，每秒可以提供200个请求。需配置两条规则，说明如下：为消费者caller1配置一条 limitApp 为caller1的限流规则，这条规则每秒的最大请求量...
例如，资源 A 可以对大部分消费者可以每秒提供 10 个请求，但是对于消费者 caller1 是个例外，对 caller1，每秒可以提供 200 个请求。需配置两条规则，说明如下：为消费者 caller1 配置一条 limitApp 为 caller1 的限流规则，这条规则每秒...