订阅关系一致
订阅关系一致指的是同一个消费者分组Group ID下，所有Consumer实例所订阅的Topic和Tag必须完全一致。如果订阅关系不一致，可能导致消息消费逻辑混乱，消息被重复消费或遗漏。什么是订阅关系一致？云消息队列 RocketMQ 版 里的一个消费者...
订阅关系一致
订阅关系一致指的是同一个消费者 Group ID 下所有消费者实例所订阅的 Topic、Tag 以及对消息的处理逻辑必须完全一致。一旦订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。本文提供订阅关系不一致的示例代码，帮助您顺畅地订阅...
查看消费者状态
如果消息消费出现异常，您可以在 云消息队列 RocketMQ 版 控制台查看指定Group ID的消费状态，包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等，帮助您快速定位异常原因。应用场景 消费者状态信息包括在线...
查看订阅关系
同一个Group ID下所有的Consumer实例需保持订阅关系一致，否则，消息消费的逻辑就会混乱，甚至导致消息丢失。更多信息，请参见 订阅关系一致。查看Topic被哪些Group ID订阅 登录 云消息队列 RocketMQ 版 控制台，在左侧导航栏单击 实例列表...
订阅关系（Subscription）
行为约束 订阅关系一致 云消息队列 RocketMQ 版 是按照消费者分组粒度管理订阅关系，因此，同一消费者分组内的消费者在消费逻辑上必须保持一致，否则会出现消费冲突，导致部分消息消费异常。正确示例/Consumer c1 Consumer c1=...
集群消费和广播消费
详情请参见 订阅关系一致。集群消费：当使用集群消费模式时，消息队列认为任意一条消息只需要被集群内（单 Zone 内）的任意一个消费者处理即可。广播消费：当使用广播消费模式时，消息队列会将每条消息推送给集群内（单 Zone 内）所有注册...
订阅消息
说明 请确保同一个 Group ID 下所有 Consumer 实例的订阅关系保持一致，详情请参见 订阅关系一致。两种不同的订阅方式有着不同的功能限制，例如，广播模式不支持顺序消息、不维护消费进度、不支持重置消费位点等，详情请参见 集群消费和...
订阅消息
更多信息，请参见 订阅关系一致。云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个Consumer实例，那么在集群消费模式下每个实例...
状态不一致
同时订阅关系一致栏显示 是。消息不合法 可能的原因：消息属性、消息内容不合法，有以下 4 种情况：消息为空。消息内容为空。消息内容长度为 0。消息内容超过限定长度。解决方案：请确认消息没有以上不合法情况，并根据异常提示进行解决。...
Topic与Tag最佳实践
在 消息队列RocketMQ版 中，Topic与Tag都是业务上用来归类的标识，区分在于Topic是一级分类，而Tag可以理解为是二级分类。您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下：...更多信息 订阅关系一致。
订阅消息
说明 请确保同一个Group ID下所有Consumer实例的订阅关系保持一致，更多信息，请参见 订阅关系一致。两种不同的订阅方式有着不同的功能限制，例如，广播模式不支持顺序消息、不维护消费进度、不支持重置消费位点等，更多信息，请参见 集群...
消息过滤
本文描述 SOFAStack 消息队列的消费者如何根据 Tag 在...更多信息 同一个 Group ID 下的消费者实例与 Topic 的订阅关系需保持一致，详情请参见 订阅关系一致。合理使用 Topic 和 Tag 来过滤消息可以让业务更清晰，详情请参见 Topic 与 Tag。
消息过滤
订阅关系一致性 过滤表达式属于订阅关系的一部分，云消息队列 RocketMQ 版 的领域模型规定，同一消费者分组内的多个消费者的订阅关系包括过滤表达式，必须保持一致，否则可能会导致部分消息消费不到。更多信息，请参见 订阅关系...
集群消费和广播消费
更多信息，请参见 订阅关系一致。集群消费 基本概念 集群消费模式下，同一Group下的多个消费者消费指定Topic中的消息时，云消息队列 RocketMQ 版 会将多条消息投递给不同的消费者处理，同一条消息只会被一个消费者消费到。适用场景 消息...
订阅消息
说明 请确保同一个Group ID下所有Consumer实例的订阅关系保持一致，更多信息，请参见 订阅关系一致。两种不同的订阅方式有着不同的功能限制，例如，广播模式不支持顺序消息、不维护消费进度、不支持重置消费位点等，更多信息，请参见 集群...
操作链路概述
本文将引导您快速体验 SOFAStack 消息队列，从创建资源、配置接入点到使用 SDK 收发消息。具体操作步骤如下：创建资源 创建工作空间 创建 Topic 创建 Group...如果 是否在线 显示为 在线，且订阅关系一致，则说明订阅成功。否则说明订阅失败。
消息过滤
消费者订阅了某个Topic后，云消息队列 ...更多信息 同一个Group ID下的消费者实例与Topic的订阅关系需保持一致，更多信息，请参见 订阅关系一致。合理使用Topic和Tag来过滤消息可以让业务更清晰，更多信息，请参见 Topic与Tag最佳实践。
调用TCP协议的SDK收发普通消息
订阅另外一个Topic，如需取消订阅该Topic，请删除该部分的订阅代码，重新启动消费端即可。consumer.subscribe("TopicTestMQ-Other","*",new MessageListener(){/订阅全部Tag。public Action consume(Message message,ConsumeContext ...
OnsConsumerStatus-查询Group ID消费状态
可以根据返回结果判断出指定 Group ID 的订阅关系是否一致、负载均衡是否正常以及获取在线客户端的 Jstack 信息等。使用本接口需要调用大量后端接口以完成数据聚合，因此查询速度慢，不建议频繁调用。调试 您可以在OpenAPI Explorer中直接...
常见问题
订阅关系不一致如何处理？如何处理消息堆积？消费者消费不到消息如何处理？若某个消费组下的机器宕机，机器重启期间，消息会不会丢失？订阅消息时消息Tag是否可以为空？创建新的消费分组订阅旧的Topic，如何设置消费起始位置？
常见问题
订阅关系不一致如何处理？如何处理消息堆积？消费者消费不到消息如何处理？若某个消费组下的机器宕机，机器重启期间，消息会不会丢失？订阅消息时消息Tag是否可以为空？创建新的消费分组订阅旧的Topic，如何设置消费起始位置？
订阅者最佳实践
本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅...订阅关系 同一个 Group 内，各个消费实例订阅的Topic最好保持一致，避免给排查问题带来干扰。
订阅关系清理
背景信息 订阅关系清理功能的相关背景信息和计费说明如下：某个Topic配置了订阅关系清理功能后，当订阅者的客户端离线并超过指定时间后，云消息队列 MQTT 版 会删除订阅者与该Topic的订阅关系。若不清理订阅关系，订阅者客户端离线期间订阅...
基础版/铂金版实例计费
月 消息TPS上限 订阅关系数上限 实例的计费公式如下：实例费用=（连接数上限单价+消息TPS上限单价+订阅关系数上限单价）×购买时长（月）连接数上限 计费项说明 连接数指任一时刻，在指定实例上存在的客户端TCP连接的数量。连接数是瞬态值...
Serverless版实例计费
计费单价 在线连接数单价 同时在线连接数（个）价格（元）[0,500]500×0.003>500 同时在线连接数×0.003 订阅关系数单价 订阅关系数（个）价格（元）[0,5000]5000×0.0002>5000 订阅关系数×0.0002 消息收发量单价 消息收发量（万条）价格...
为什么Group的状态一直处于“删除中”？
可能原因 Group中存在活跃的订阅关系。Group上有消费线程在提交新的消费位点。解决方案 登录 云消息队列 Kafka 版 控制台，查看Group的订阅关系。详细步骤，请参见 查看消费状态。若查询到Group订阅了Topic或者有消费线程在提交新的消费...
为什么在控制台看不到消费者的客户端信息？
问题现象 在 云消息队列 Kafka 版 控制台 的 Topic 详情 页面的 订阅关系 页签，或者在 Group 详情 页面的 消费状态 页签，查看 消费详情 中的 客户端 信息为 n/a。可能原因 订阅该Topic分区的消费线程已经离线。Group触发Rebalance机制。...
订阅告警
配置告警信息 打开 订阅告警 界面可以添加订阅关系，添加订阅关系需要指定订阅人、订阅的告警等级、以及是否开启通知降频。设置订阅人、告警等级、通知降频开关。新增订阅人：选择对应的订阅人。当前仅支持订阅给告警联系人。如需新建告警...
专业版实例计费
若您的某些客户端不再使用且订阅关系不需要保留，请及时清除订阅关系，节约系统资源。具体操作，请参见 订阅关系清理。计费规则 项目 说明 计费项 根据实际购买的计算规格大小进行计费。计费方式 包年包月 根据选择的规格和时长计算账单，...
实例类型
✗ 功能特性 单设备订阅关系限制（规则）最多30个 最多30个 理论上无限制 可定制单设备订阅关系限制（规则）。最多30个 消息保留时间 最多3天 最多3天 最多7天 可定制消息保留时间。最多3天 协议类型 MQTT MQTT MQTT 可定制协议。MQTT 证书...
查看订阅关系
在 SOFAStack 消息队列控制台，您可实时查看 Group ID 和 Topic 之间的订阅关系。本文介绍如何在消息队列控制台查看订阅关系。从 Topic 视角，查看即个 Topic 被哪些 Group ID 订阅了。从 Group 视角，查看某个 Group ID 订阅了哪些 Topic...
控制台使用相关问题
订阅关系在订阅消息的SDK代码中设置，控制台只能查询。为什么控制台查询不到离线消息的消费轨迹？若您未设置离线消息功能，客户端离线时服务端不会推送消息，且客户端再次上线后，也接收不到离线期间产生的消息。若需要支持离线消息，请将 ...
设备状态查询
当设备异常或消息收发不符合预期时，您可以使用设备状态查询功能查询指定设备的在线状态、订阅关系及设备轨迹和该设备的消息列表，获取MQTT客户端的状态信息，帮助您快速定位异常原因。操作步骤 登录 云消息队列 MQTT 版 控制台，并在左侧...
为什么在控制台看不到Group的订阅关系？
问题现象 您已启动某个Group的消费线程，但在 云消息队列 Kafka 版 控制台 的 Topic 详情 页面的 订阅关系 页签，查不到Topic被Group订阅的信息，或者在 Group 详情 页面的 消费状态 页签，查不到该Group订阅的Topic信息。可能原因 客户端...
OnsTopicSubDetail-查看Topic的订阅信息
该接口用于查询 Group 和 Topic 之间的订阅关系。如果 Group ID 对应的消费者实例不在线则查不到数据。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试...
管理AMQP消费组
订阅关系1：将产品1的消息转发到消费组1和消费组2。订阅关系2：将产品2的消息转发到消费组2。AMQP服务端订阅 只能流转同一产品所有设备的指定类型消息，如果需要更灵活的流转设备消息。例如转发 部分设备消息 到AMQP客户端进行消费，可以...
创建和管理 Group ID
创建完 Topic 后，您需要为消息的消费者（或生产者）创建客户端 ID，即 Group ID 作为标识。Group ID 和 Topic 的关系是 N：N，即一个消费者可以订阅多个 Topic，同一个 Topic 也可以被...相关链接 查看订阅关系 查看消费者状态 重置消费位点
查询消费者组订阅关系列表
查询指定消费者组的订阅关系。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action ...
会话过期
会话从创建到结束保持一致，不会丢失订阅关系和消息。状态无关的设备 对于广告屏设备，持续更新播放新的广告内容，不需要接收过期消息，适用于上图的情况1。不保留会话，可以避免收到无效过期的内容，也可以节约云端的资源消耗。
UpdateQualityFollower
调用UpdateQualityFollower更新订阅关系。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String 是 ...
- 产品推荐
- 这些文档可能帮助您