文章内容收录到个人网站，方便阅读：http://hardyfish.top/Kafka 的写入路径是先写 Leader，再由 Leader 复制到 Followers。对生产者而言是否等 Followers取决于 acks（确认级别）。不存在生产者直接同时写 Leader 和 Follower的机制，复制由 Leader 侧串起完成。写入链路：Leader 串行落盘，Followers 异步拉取复制一次写入在分区（partition）维度上发生：生产者把记录发给该分区的 Leader 副本（leader replica）。Leader 将记录追加到本地日志（log）并更新高水位相关状态。各 F...

文章内容收录到个人网站，方便阅读：http://hardyfish.top/变量存放位置的判断依据Java运行时内存主要分为：栈（Stack） ：线程私有，存放方法调用相关数据。堆（Heap） ：线程共享，存放对象实例。方法区 / 元空间（Method Area / Metaspace） ：存放类元信息、常量池、静态变量。判断依据：基本类型的值（除 String 这种引用类型外）。如果是方法的局部变量 → 存在栈帧的局部变量表如果是对象的成员变量 → 存在对象实例中（堆里）引用类型变量引用本身（指向对象的地址）存放在栈帧局部变量表或对象实例中。对象本体存放在堆中。类的元数据、常量池、静态变量 ...

大家好呀，我是飞鱼最近我做了个小程序：躺了么，我简单介绍下，也欢迎大家试用。为什么做「躺了么」说白了，就是想做个轻松点的小工具，让自己别老被工作牵着走，也别总觉得摸鱼是罪过。记录每天到底花了多少时间在工作、多少时间在放松？有了数据，心里就有数。名字的灵感来自最近很火的APP：死了么，这种反讽风格。我可以把它转成更轻松的问法：不是逼你卷，而是简单问一句：今天躺了吗？这里说句题外话，其实死了么这个APP的创意，应该很多人都能想得到。毕竟现在是孤独经济时代，独居年轻人这个群体规模已经非常庞大。我之前也想做一个类似的，但觉得太简单了，一直在问自己，真有人用么。现在明白了，AI时代了，有想法创意之后任何...

文章内容收录到个人网站，方便阅读：http://hardyfish.top/多线程带来的收益往往写在压测曲线上，代价则藏在“偶发、难复现、只在生产出”的问题里。项目里遇到的坑，大多集中在并发正确性、资源治理、可观测性与性能错觉四个层面。并发正确性：最贵的是“偶发错误”数据竞争与可见性同一份共享状态被多个线程读写，既可能写丢，也可能读到过期值。最常见的表象是计数不准、状态机跳转异常、缓存命中率异常波动。根因通常是缺少互斥与内存可见性保障（例如仅靠普通变量传递“已初始化/已关闭”信号）。复合操作非原子“先检查再执行”在单线程里很自然，在多线程里就是经典竞态：余额校验后扣款、库存校验后减库存、Map...

文章内容收录到个人网站，方便阅读：http://hardyfish.top/看是哪种OOM?看报错信息/监控/容器事件，区分类型，不同解法完全不一样。Java heapjava.lang.OutOfMemoryError: Java heap spaceGC overhead limit exceeded（一直 GC 但回收极少）Direct/Off-heapjava.lang.OutOfMemoryError: Direct buffer memory（NIO/Netty/ByteBuffer）原生内存耗尽（JNA、压缩、TLS、线程栈等）Metaspacejava.lang.OutOfMe...

文章内容收录到个人网站，方便阅读：http://hardyfish.top/乐观锁不加互斥锁阻塞线程，而是让线程先读数据并计算，提交写入时检查版本是否被别人改过。如果被改过就失败并重试/放弃，核心是检测冲突而不是预防冲突。适用：读多写少、冲突概率低的场景（热点不高）。不适用：高冲突时会出现重试风暴。内存并发（Java 层）：CAS/原子类/StampedLock方案 A1：CAS 原子类（Atomic） AtomicInteger stock = new AtomicInteger(100); boolean decOnce(int n) { while (true) { int cur = ...

文章内容收录到个人网站，方便阅读：http://hardyfish.top/线上调试 RPC 服务（如 Dubbo）时，需要确保调试过程对线上业务的影响最小化，可以通过以下方法进行调试，并设置流量不打到某台机器上：1. 流量隔离：让调试机器不接收线上流量方法 1：通过 Dubbo 提供的服务治理功能下线该实例：使用 Dubbo 的服务治理功能，将待调试的机器从服务注册中心摘除，这样其他消费者就不会再调用到这台机器。操作：使用 Dubbo 控制台或管理工具，将调试实例从注册中心（如 Zookeeper、Nacos）中临时移除。设置为 “不可用” 状态。命令示例（基于 Dubbo Admin）： ...

文章内容收录到个人网站，方便阅读：http://hardyfish.top/JDK 7（以及之前）默认垃圾回收器： 新生代：Parallel Scavenge（吞吐量优先收集器）老年代：Parallel Old特点： 并行 GC：多线程回收新生代和老年代，适合批处理、后台任务等吞吐量优先场景。STW（Stop-The-World）时间相对较长。调优主要依赖 -XX:MaxGCPauseMillis 和 -XX:GCTimeRatio。JDK 8默认垃圾回收器：Parallel GC（新生代 Parallel Scavenge + 老年代 Parallel Old）。特点： 吞吐量优先。新生代复...

文章内容收录到个人网站，方便阅读：http://hardyfish.top/这是一个典型的“消息分发模型”设计问题，微博/社交平台在设计大V发博分发时，推模式（push） 和 拉模式（pull） 各有利弊。下面结合你提到的“大V发博客”场景详细分析：一、两种模式简介推模式（push）大V一发微博，系统立即将内容推送到每一个粉丝的时间线中（如写入粉丝的消息队列或Feed中）拉模式（pull）粉丝查看时间线时，实时去拉取他关注的人（如大V）最新发布的内容，再合并排序显示二、微博类应用场景选型✅ 小V/普通用户：使用 推模式粉丝数少，推送量小；内容分发量级低；直接推送到粉丝的 Feed 表中，读取快...

文章内容收录到个人网站，方便阅读：http://hardyfish.top/跳表（SkipList）是 一种有序链表的多级索引结构，通过增加多层索引来加快查找速度。最底层：完整的有序链表（包含所有元素）。上层索引：抽取部分节点作为快捷通道，减少查找步数。查找过程：从最高层索引开始，能向右就向右，不能向右就向下，直到找到目标或最接近的位置。举例（每层越上节点越少）： Level 3: 1 --------- 9 Level 2: 1 --- 5 --- 9 Level 1: 1 3 5 7 9 找元素 7 的过程：从 Level 3 的 1 → 9（超了，往下）Level 2 的 1 → 5 →...

文章内容收录到个人网站，方便阅读：http://hardyfish.top/阿里巴巴 Java 开发手册中明确推荐：使用 ThreadLocal 时必须使用 static 修饰。原因如下。避免内存泄漏的风险原理：每个 Thread 都持有一个 ThreadLocalMap，而这个 Map 的 key 是 ThreadLocal 的弱引用。如果你创建的 ThreadLocal 是非 static 成员变量，它会跟随外部类实例的生命周期。一旦外部类被 GC 回收，而 ThreadLocal 实例也没强引用，就会造成：ThreadLocal 被 GC。ThreadLocalMap 中 key 为 n...

文章内容收录到个人网站，方便阅读：http://hardyfish.top/JVM 年轻代（Young Generation）回收频率过高 可能导致 应用性能下降、GC 开销过大，进而影响系统吞吐量。要找出 导致高频 GC 的具体原因，一般需要按照以下步骤进行分析和优化。现象分析年轻代 GC 过于频繁的常见表现：应用吞吐量下降，CPU 使用率升高Full GC 次数增加，可能因为晋升失败Young GC 频繁触发，应用线程被频繁打断监控 JVM GC 情况通过 JVM 选项打开 GC 日志可以通过 GC 日志 观察 GC 频率： # JDK 8 -XX:+PrintGCDetails -XX:...

文章内容收录到个人网站，方便阅读：http://hardyfish.top/ZAB（Zookeeper Atomic Broadcast）是 ZooKeeper 专门设计的一种原子广播协议，用于保证 数据一致性 和 故障恢复。它主要用于 主从复制（Leader-Follower） ，并确保 写请求（事务）严格有序，同时保证集群在发生 Leader 失效 时能正确恢复。1. ZAB 协议核心目标保证数据一致性 ZooKeeper 采用 强一致性（Linearizability） ，所有写入（事务）按顺序执行。支持主从复制 通过 Leader 负责写操作，Follower 只进行读操作，确保数据同...

文章内容收录到个人网站，方便阅读：http://hardyfish.top/提到“虚拟线程”，很多人可能会觉得陌生，但如果你了解过像Go、Ruby或Python这样的语言，可能马上会联想到“协程”。没错，JDK 21引入的虚拟线程（Virtual Thread），本质上就是Java版的协程，旨在解决传统线程模型的性能瓶颈。传统Java线程的问题在JDK 21之前，Java的线程模型比较简单，采用的是“一对一”的映射方式：每个Java线程对应操作系统的一个轻量级进程（通常是内核线程）。这种模型下，线程的创建、销毁和同步操作都需要系统调用，而系统调用需要在用户态和内核态之间切换，开销不小。尤其是在...