- 综合排序
- 最热优先
- 最新优先
- 来自专栏码匠的流水账
聊聊rocketmq的订阅关系
序本文主要研究一下rocketmq的订阅关系报错org.apache.rocketmq.client.exception.MQClientException: The consumer group[demo-group consumer1的，时而是consumer2的，最终造成消息延时或者消息消费不到的问题小结rocketmq的订阅关系要求使用同一个consumer group的不同consumer它们对topic及tag 的订阅关系要一致，不然会造成消息未能如期消费等异常，其本质是broker端维护了key为group的ConsumerGroupInfo，而每次consumer的heartbeat则会在broker端变更同一个 group的ConsumerData信息，造成订阅关系不断被变更。 doc消费者分组（ConsumerGroup）订阅关系（Subscription）我擦，RocketMQ的tag还有这个“坑”！RocketMQ同一个消费者内消费者订阅不同Topic问题分析
57400编辑于 2023-05-08 - 来自专栏码匠的流水账
聊聊rocketmq的订阅关系
序 本文主要研究一下rocketmq的订阅关系 报错 org.apache.rocketmq.client.exception.MQClientException: The consumer group consumer1的，时而是consumer2的，最终造成消息延时或者消息消费不到的问题 小结 rocketmq的订阅关系要求使用同一个consumer group的不同consumer它们对topic 及tag的订阅关系要一致，不然会造成消息未能如期消费等异常，其本质是broker端维护了key为group的ConsumerGroupInfo，而每次consumer的heartbeat则会在broker 端变更同一个group的ConsumerData信息，造成订阅关系不断被变更。 doc 消费者分组（ConsumerGroup） 订阅关系（Subscription） 我擦，RocketMQ的tag还有这个“坑”！ RocketMQ同一个消费者内消费者订阅不同Topic问题分析
34531编辑于 2023-08-31 - 来自专栏code人生
web3.js：事件订阅
订阅智能合约事件 import { Web3 } from "web3"; // set a provider - MUST be a WebSocket(WSS) provider const web3 此外，还有一些以太坊节点提供额外的自定义订阅。如你在这个指南中所看到的，web3.js使你能够直接订阅标准事件。它还为你提供了订阅自定义订阅的能力，如你在自定义订阅[3]指南中所看到的。 重要提示 如果你是为用户提供自定义订阅的开发者。我们鼓励你在阅读下面的自定义订阅[4]部分后，开发一个web3.js插件。你可以在web3.js插件开发者指南[5]中找到如何开发插件的方法。 •on("error") - 当订阅中出现错误时触发。 •on("connected") - 在订阅成功连接后触发一次。返回订阅id。 [4] 自定义订阅: https://docs.web3js.org/guides/events_subscriptions/custom_subscriptions [5] web3.js插件开发者指南
52210编辑于 2024-05-17 - 来自专栏后端架构师
硬核 | Redis PubSub 发布订阅与宅男有什么关系？
进入订阅后的客户端可以收到 3 种类型的消息回复： subscribe：订阅成功的反馈消息，第二个值是订阅成功的频道名称，第三个是当前客户端订阅的频道数量。 (press Ctrl-C to quit) 1) "subscribe" // 订阅频道成功 2) "develop" // 频道 3) (integer) 1 // 当发布者发布消息，订阅者读取到的消息如下 .*"// 模式 3) (integer) 1 //订阅数 对应的反向取消模式订阅的指令是PUNSUBSCRIBE smile.girl.*。 " 2) "smile.girls.Tina" 3) "love u" 需要注意的是，如果一个客户端订阅了与模式匹配的模式和频道，那么客户端会收到多次消息。 订阅模式源码 所以模式实现的发布订阅也是通过字典来保存模式与客户端的关系，如下图所示： 基于模式实现的发布订阅原理 当使用 PUBLISH 发布消息的时候，除了发布到订阅channel的客户端以外，还会将该
1.2K10编辑于 2022-10-28 - 来自专栏code人生
web3.js：自定义订阅
你可以扩展Web3Subscription类来创建自定义订阅。这样，你就可以订阅由提供者发出的自定义事件。 注意 这个指南很可能是针对那些连接到提供额外自定义订阅的节点的高级用户。 然而，你可以在web3.js插件开发者指南[3]中找到如何开发插件的方法。即使你不是提供这种自定义订阅的开发者，我们也鼓励你为自定义订阅编写一个web3.js插件，并将其发布到npm包注册表。 实现订阅 扩展Web3Subscription 要创建一个自定义订阅，首先需要扩展Web3Subscription类。然而，Web3Subscription是泛型类型。 订阅使用 •通过在Web3构造函数选项中传递订阅来注册订阅。•使用subscriptionManager订阅/取消订阅。•监听订阅事件，如data，以获取新的结果。 结论 总的来说，web3.js订阅提供了一种灵活的方式来订阅自定义提供者事件。
40410编辑于 2024-05-17 - 来自专栏后端进阶
RocketMQ为什么要保证订阅关系的一致性？
朋友还跟我讲了他的消费集群中，每个消费者订阅了自己的 Topic，他的消费组中 有 c1 和 c2 消费者，c1 订阅了 topicA，而 c2 订阅了 topicB。 ，这也是为什么同一个消费组应该拥有完全一样的订阅关系的原因，而朋友在同一个消费组的每个消费者订阅关系都不一样，就出现了订阅信息相互覆盖的问题。 topicA，c2 订阅了 topicB，集群内有 broker1 和broker2，假设 topicA 有 8 个消息队列，broker_a（q0/q1/q2/q3） 和 broker_b（q0/q1 /q2/q3），前面我们知道 findConsumerIdList 方法会获取消费组内所有消费者客户端 ID，topicA 经过平均分配算法进行分配之后的消费情况如下： c1：broker_a（q0/q1 /q2/q3） c2：broker_b（q0/q1/q2/q3） 问题就出现在这里，c2 根本没有订阅 topicA，但根据分配算法，却要加上 c2 进行分配，这样就会导致这种情况有一半的消息被分配到
2.2K41发布于 2019-07-30 - 来自专栏腾讯云中间件的专栏
TDMQ RocketMQ 版订阅关系一致性原理与实践
订阅关系定义 订阅关系是 RocketMQ 系统中消费者获取消息、处理消息的规则和状态配置，订阅关系由消费者组动态注册到服务端，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。 错误示例三：订阅 Topic 和 Tag 都相同但 Tag 顺序不同 如图中 Group 3 的 Consumer1 订阅 TopicA 的 Tag1||Tag2，Consumer2 订阅 TopicA ，同一个消费组下订阅的同一个主题的订阅关系是直接使用最新上报的关系，那么不同客户端上报的订阅关系不一致时服务端报错的订阅关系就会一直被相互覆盖，只会以最新上报的订阅关系为准。 TDMQ RocketMQ 版控制台提供可视化检测能力，无需人工逐个排查日志或配置，通过控制台 3 步即可完成问题的发现、定位、修复，降低运维复杂度。 3、闭环验证 修订后实时同步订阅关系一致性状态，确保消费组订阅关系符合预期。 常见问题 哪些典型场景会出现订阅关系不一致？
46410编辑于 2025-04-30 - 来自专栏夕阳醉了
Redis从入门到放弃（3）：发布与订阅
发布订阅是一种消息传递模式，它允许消息的发布者（发布者）将消息发送给多个订阅者（订阅者）而不必知道订阅者的存在。这种模式在许多应用中都非常有用，例如实时通知、事件处理、聊天应用等。 2、如何使用发布订阅 2.1、订阅频道 要订阅一个频道，首先需要使用 SUBSCRIBE 命令。 (press Ctrl-C to quit) 1) "subscribe" 2) "notifications" 3) (integer) 1 # 返回值为当前已订阅的频道数量 当执行以上命令后 3、使用案例（伪代码） 消息通知： 在一个Web应用程序中，可以使用发布订阅功能来向所有在线用户发送实时通知，比如新消息、新订单等。 Redis的发布订阅是一种发布者-订阅者模式，其中一个消息可以广播给多个订阅者。
1.3K70编辑于 2023-10-16 - 来自专栏勇哥编程游记
两个实验让我彻底弄懂了「订阅关系一致」
这篇文章，笔者想聊聊 RocketMQ 最佳实践之一：保证订阅关系一致。 订阅关系一致指的是同一个消费者 Group ID 下所有 Consumer 实例所订阅的 Topic 、Tag 必须完全一致。 如果订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。 1 订阅关系演示 首先我们展示正确的订阅关系：多个 Group ID 订阅了多个 Topic，并且每个 Group ID 里的多个消费者的订阅关系保持了一致。 正确的订阅关系 接下来，我们展示错误的订阅关系。 错误的订阅关系 从上图中，单个 Group ID 订阅了多个 Topic，但是该 Group ID 里的多个消费者的订阅关系并没有保持一致。 3 订阅主题相同，标签不同 如图，C1 消费者和 C2 消费者订阅主题 TopicTest ，但两者的标签 TAG 并不相同。 启动消费者服务之后，从控制台观察，负载均衡的效果也如预期一般正常。
52030编辑于 2023-10-23 - 来自专栏RabbitMQ实战
AMQP-RabbitMQ3发布订阅模式
3. 发布订阅模式 Publish/Subscribe - 全集监听 fanout 一次向多个消费者发送消息 图示 ? 发布者将消息发送到Exchange，而不是Queue 在订阅者端，每个订阅者定义了自己的消息队列，并且将自己的消息队列与Exchange进行绑定。 (即：每个订阅者收到的消息都是一样的) 测试结果 >>> 订阅者1 [main] INFO mq.rabbit.ps.SubscriberOne - Waiting for message... 3],tag:[amq.ctag-Fc_B_CoCYUBoBhEcOlC7vw] [pool-1-thread-8] INFO mq.rabbit.ps.SubscriberOne - 收到消息:[ 3],tag:[amq.ctag-ip59jtcKJBQFC2KU9DperQ] [pool-1-thread-8] INFO mq.rabbit.ps.SubscriberTwo - 收到消息:[
85620发布于 2020-06-29 - 来自专栏腾讯云中间件的专栏
8月产品月报 | TDMQ RocketMQ 版支持手动取消订阅关系
关于腾讯云分布式消息队列 TDMQ TDMQ 是腾讯云自主研发的消息中间件产品系列，作为分布式系统中的关键组件，具备稳定可靠、高弹性、低成本的特性，提供异步通信的基础能力，通过应用解耦降低系统复杂度，提升系统可用性和可扩展性。 TDMQ 兼容开源主流协议，包含 CKafka、RocketMQ、RabbitMQ、Pulsar、MQTT 五大子产品。提供迁移方案支持，零业务代码修改，降低迁移成本。覆盖在线场景（电商交易、社交直播等）、离线场景（大数据实时计算、离线分析等）和设备端场景（物联网、车联网等），满足金融、政务、泛互联网、教育、零售、出行等不同行业和场景的需求。
22010编辑于 2025-09-11 - 来自专栏勇哥编程游记
两个实验让我彻底弄懂了「订阅关系一致」
这篇文章，笔者想聊聊 RocketMQ 最佳实践之一：保证订阅关系一致。订阅关系一致指的是同一个消费者 Group ID 下所有 Consumer 实例所订阅的 Topic 、Tag 必须完全一致。 如果订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。 1 订阅关系演示首先我们展示正确的订阅关系：多个 Group ID 订阅了多个 Topic，并且每个 Group ID 里的多个消费者的订阅关系保持了一致。图片接下来，我们展示错误的订阅关系。 图片从上图中，单个 Group ID 订阅了多个 Topic，但是该 Group ID 里的多个消费者的订阅关系并没有保持一致。 3 订阅主题相同，标签不同图片如图，C1 消费者和 C2 消费者订阅主题 TopicTest ，但两者的标签 TAG 并不相同。启动消费者服务之后，从控制台观察，负载均衡的效果也如预期一般正常。
1.7K130编辑于 2023-10-11 - 来自专栏后端云
OPNFV简介(3) - 和上游关系
相关的上游开源项目的关系 直接与上游的开源项目进行合作 (OpenDaylight, OpenStack, KVM , Xen以及其他) 直接与标准组织进行合作 (ETSI and others) 利用现有代码库
57250发布于 2018-10-24 - 来自专栏迁移内容
RabbitMQ：订阅模型-消息订阅模式
---- 文章目录 一、RabbitMQ 订阅模型-消息订阅（Fanout）模式 1、RabbitMQ 消息订阅（Fanout）模式 2、消息订阅（Fanout）模式组成 3、消息订阅（Fanout）模式流程 二、RabbitMQ 订阅模型-消息订阅（Fanout）模式实现 1、添加 Maven 依赖 2、封装工具类 ConnectionUtil 3、生产者实现 4、消费者-1 实现 5、消费者-2 实现 6、消费者-3 实现 三、订阅模型 三种模式区别 1、RabbitMQ 消息订阅（Fanout）模式 2、RabbitMQ 路由（direct）模式 3、RabbitMQ 主题（topic）模式 --- 3、消息订阅（Fanout）模式流程 消息订阅（Fanout）模式流程： 消息订阅（Fanout）模式 可以有多个消费者 每个消费者有自己的 queue（队列） 每个队列都要绑定到 Exchange（交换机 -消息订阅（Fanout）模式 消费者 * @date 2022-12-26 11:45 上午 **/ public class Customer3 { public static void
2.1K10编辑于 2022-12-28 - 来自专栏python3
1-3 SEO的关系
1、SEO与排名的关系 不完全属于，也不完全独立。 网站排名分竞价排名和自然排名； SEO可以提升网站排名，主要提升的是自然排名，也会辅助竞价排名。 2、SEO与SEM的关系 SEM是搜索引擎营销的缩写，是一种网络营销方式，其中有包括多种具体营销方法； SEM包括：SEO、竞价排名、关键词广告、PPC来电付费 SEO就是SEM的其中一种。 3、SEO与网站运营的关系 SEO只是网站运营中很小的一部分工作内容。 网站运营会用到SEO技术，SEO不是网站运营的全部工作，但却是在网站运营中很大比重的工作，所以部门中也必须有专业的SEO人员。
46020发布于 2020-01-10 - 来自专栏python数据分析实践
Matplotlib数据关系型图表（3）
二、层次关系型图表 层次关系型图表主要表示数据个体之间的层次关系，主要包括包含和从属两类。 比如公司不同部门的组织结构，不同洲的国家包含关系等，包括热力图（含相关系数图）、节点链接图、树形图、冰柱图、旭日图等。 #设置x轴标签和名称 + scale_x_continuous(name = 'Year', breaks = np.arange(2010, 2022, 3)
1.4K10编辑于 2023-02-23 - 来自专栏Android相关
Gradle For Android(3)--管理依赖关系
介绍 依赖关系管理是Gradle的闪光点。 在这个脚本中最好的一点，就是你所需要的只是添加一行到你的build.gradle中，然后Gradle就会从一个远程仓库中下载与之相关的依赖关系的库，以保证它的Classes对你的Project的是可用的 Gradle甚至解决了依赖项是自己的问题，这种依赖关系被称之为Transitive Dependencies。 这一章会介绍以来管理并且解释Android Project中添加依赖关系的几种办法。 手动管理依赖关系是一个很麻烦的事情，你必须定位Library，然后下载Jar文件，把它Copy到你的Project中，然后reference它。 你可以添加一个常规的目录作为仓库，通过使用flatDirs，这也可以让你从这个目录下添加文件到依赖关系中： repositories { flatDir { dirs
2.2K30发布于 2018-10-24 - 来自专栏韩曙亮的移动开发专栏
【EventBus】EventBus 源码解析 ( 注册订阅者 | 订阅方法 | 查找订阅方法 )
文章目录 一、EventBus 注册订阅者 二、订阅方法 三、查找订阅方法 findSubscriberMethods 方法 四、查找订阅方法 findUsingInfo 方法 五、查找订阅方法 findUsingReflectionInSingleClass : ① 获取 订阅者 集合 , 查找当前订阅类中符合条件的订阅方法集合 ; ② 遍历 订阅者 集合 , 进行事件订阅 , 保存数据 , 这些数据就是一些映射关系 /** * EventBus是Java 遍历 订阅者 集合 , 进行事件订阅 , 保存数据 , 这些数据就是一些映射关系 synchronized (this) { for (SubscriberMethod findSubscriberMethods 方法 ---- 订阅方法缓存机制 : 从缓存中获取 订阅方法 , METHOD_CACHE 缓存是一个 HashMap 集合 ; 如果订阅者有很多方法 , 如果每次订阅都要查询所有的方法 , 如果遍历一次 Activity 的所有方法 很消耗性能 ; 因此这里引入了缓存机制 ; 第一次订阅时 , 将方法都放在缓存集合中 , 如果第二次订阅 , 不用再次查找方法
2.8K20编辑于 2023-03-29 - 来自专栏科控自动化
通配符订阅
附录 A - 主题通配符 订阅可能包含特殊字符，允许您一次订阅多个主题。 主题级别分隔符用于将结构引入主题，因此可以为此目的在主题中指定。 多级通配符和单级通配符可用于订阅，但消息发布者不能在主题中使用。 主题级别分隔符 正斜杠 （/） 用于分隔主题树中的每个级别，并为主题空间提供分层结构。 当在订阅者指定的主题中遇到两个通配符时，使用主题级别分隔符非常重要。 多级通配符 数字符号 （#） 是与主题中任意数量的级别匹配的通配符。 例如，如果您订阅了 finance/stock/ibm/#，则会收到有关以下主题的消息： finance/stock/ibm finance/stock/ibm/closingprice
3.5K10编辑于 2022-03-29 - 来自专栏『Ts + React』项目实战
『Dva』订阅
查看文章一、前言本篇文章是『从零玩转 TypeScript + React 项目实战』系列文章的第 6 篇，主要介绍『Dva』中的订阅经过上一篇『Dva』异步处理，文章的介绍，了解了下 Model 当中的 还可以再 Model 中的 Effect 当中做一些异步操作，那么了解了这些内容之后，本篇要介绍一下 Model 当中剩余的部分，也就是订阅。 二、Model 中的订阅在 Model 当中是不是还剩下一个 Subscription：2.1 什么是 SubscriptionSubscription 是什么东西呢？ 它呢是专门用来做订阅的，做订阅它能做什么订阅呢，这个时候去官方文档中看一下。 3.订阅函数的执行时机：Subscription 中定义的方法会在 app.start() 时自动调用，每个方法会收到一个包含 history 和 dispatch 的参数对象，方便我们根据需要使用相关功能
47810编辑于 2024-12-01
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号