标签: 故障排查

  • RocketMQ 生产环境 P99 抖动排查实战:PageCache 剧烈回收引发的 Broker Busy 与 Mmap 预热机制解析

    排查过程中,某高并发压测场景下的 RocketMQ 集群(v4.9.4)频繁爆出 [TIMEOUT_CLEAN_QUEUE]broker busy,发送延迟 P99 从 5ms 突增至 2000ms+。核心原因是 Linux PageCache 脏页回写与 mmap 缺页中断(Page Fault)阻塞了 Broker 写线程。结论先行:通过开启 RocketMQ 的 warmMapedFileEnable=truetransientStorePoolEnable=true,配合下调 OS 内核的 vm.dirty_background_ratio,可彻底斩断内核级阻塞,将 P99 稳定压制在 10ms 以内。

    故障现场与指标观测

    某次大促前夕的全链路压测中,单 Broker 节点 QPS 压到 4w 时,客户端开始出现大量的 MQBrokerException: broker busyRemotingTooMuchRequestException 报错。

    查看 Broker 端 store.logbroker.log,满屏如下报错:

    202X-XX-XX XX:XX:XX WARN [SendMessageThread_1] - [TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while, period in queue: 205ms, size of queue: 853
    202X-XX-XX XX:XX:XX WARN [SendMessageThread_2] - OS page cache busy, osPageCacheBusyTimeOutMills=1000
    

    调出监控看板:

    1. CPU Load:平时 4-5 左右,故障发生瞬间 Load Average 飙升至 40+。

    2. 磁盘 IOiostat -xdm 1 显示 await 偶尔飙高,但 util% 只有 50% 左右,磁盘并未彻底被打满。

    3. 内存指标free -m 显示 buff/cache 占用接近 85%,物理空闲内存(free)极少。

    此时通过 strace -p -T -e trace=mmap,munmap,write,pwrite64 抓取底层系统调用,发现部分写操作耗时极其离谱,甚至超过 1 秒。这就引出了一个经典的架构错觉:我都全异步了,为什么还会卡?

    为什么异步刷盘(ASYNC_FLUSH)依然会阻塞写线程?

    很多开发人员认为,只要 RocketMQ 配置了 flushDiskType=ASYNC_FLUSH,消息只要写到内存(PageCache)就算成功,磁盘 IO 慢绝不会影响发送延迟。这是一个极其致命的认知盲区。

    RocketMQ 的 CommitLog 默认采取 1GB 固定大小,通过 mmap(Memory Mapped Files)将物理文件映射到用户态的虚拟内存中。Broker 处理写请求的核心路径是: SendMessageProcessor -> CommitLog.putMessage() -> MappedFile.appendMessagesInner() -> ByteBuffer.put(data)

    问题就出在这个 ByteBuffer.put() 上。这虽然是内存操作,但在 Linux 内核视角下,它随时可能被阻塞,原因有二:

    1. 缺页中断(Minor/Major Page Fault): 当 Broker 滚动创建新的 1GB CommitLog 并执行 mmap 时,Linux 采用的是“延迟分配”策略。仅仅是建立了虚拟内存地址映射,并未分配实际物理页。当写线程第一次往这个地址 put 数据时,会触发内核缺页中断,内核需要去寻找空闲物理页并建立页表。如果此时系统物理内存紧张,内核触发直接回收(Direct Reclaim),写线程就会被死死卡住。

    2. PageCache 脏页回写阻塞: 当脏页积累到内核阈值(vm.dirty_ratio,默认 20%)时,Linux 会挂起所有尝试生成新脏页的用户进程,强行同步刷盘。此时你的 ByteBuffer.put() 会直接退化为同步阻塞写。

    深度解析:CommitLog Mmap 与 读写分离预热机制

    为了规避上述内核级别的阻塞,RocketMQ 提供了几项极为核心的防御性存储机制。

    1. 强制预热与内存锁定(warmMapedFileEnable)

    配置 warmMapedFileEnable=true 后,Broker 在创建新的 1GB MappedFile 时,会提前在后台线程中将其填满 0,强行触发所有的缺页中断,真正分配物理内存。 不仅如此,RocketMQ 还会调用 JNA 执行 mlockmadvise

    // 核心源码示意 (MappedFile.java)
    LibC.INSTANCE.mlock(pointer, 1024 * 1024 * 1024);
    LibC.INSTANCE.madvise(pointer, 1024 * 1024 * 1024, LibC.MADV_WILLNEED);
    

    mlock 直接告诉内核:“这 1GB 内存你给我锁死在 RAM 里,绝对不允许 Swap 出去!”。这就彻底消除了写消息时发生 Page Fault 的可能性。

    2. 堆外内存写池(transientStorePoolEnable)

    这是应对 PageCache 毛刺的终极武器(仅限异步刷盘有效)。 开启后,RocketMQ 会预先向 OS 申请一块 DirectByteBuffer 内存池(不受 JVM GC 影响,也暂时不进 PageCache)。 写数据路径变为:写请求 -> DirectByteBuffer -> 立即返回客户端成功。 后台 CommitRealTimeService 线程定期将 DirectByteBuffer 的数据写入 FileChannel(进入 PageCache),再由 FlushRealTimeService 线程异步刷盘。 这是一种极致的读写分离策略,彻底将“接收消息的写线程”与“PageCache 分配/刷盘”解耦。

    极客实战:RocketMQ 存储与内核参数双向调优

    解决此类抖动问题,绝不能只改应用配置,必须深入 OS 层联动调优。以下是我在生产环境经过验证的黄金配置标准。

    RocketMQ 核心配置 (broker.conf)

    # 强制使用异步刷盘
    flushDiskType=ASYNC_FLUSH
    # 开启堆外内存池缓冲,彻底解耦写请求与PageCache抖动
    transientStorePoolEnable=true
    # 开启Mmap预热与内存锁定,消除运行时缺页中断
    warmMapedFileEnable=true
    # 优化PageCache锁超时机制(如果发生抖动,快速失败,依赖重试)
    osPageCacheBusyTimeOutMills=1000
    

    Linux 内核 IO 参数调优 (/etc/sysctl.conf)

    光配 Broker 不够,必须改造内核的脏页回写策略:

    # 脏页占总内存的 5% 时,pdflush 后台线程开始异步刷盘(原默认10%)
    # 目的:提早刷盘,细水长流,避免积压
    vm.dirty_background_ratio = 5
    
    # 脏页占总内存的 40% 时,强制阻塞所有用户态写进程(原默认20%)
    # 目的:拉开与 background_ratio 的差距,给突发流量留足 Buffer
    vm.dirty_ratio = 40
    
    # 坚决不使用 Swap(避免mmap的内存被换出)
    vm.swappiness = 1
    
    # 预留给 OS 应急的物理内存(例如 128G 内存机器配 2G)
    # 目的:避免缺页中断时因无空闲内存触发直接回收(Direct Reclaim)引发系统停顿
    vm.min_free_kbytes = 2097152
    

    执行 sysctl -p 生效。经过这一套连招组合拳,压测 P99 稳如泰山,再也没有出现过 broker busy

    常见问题 (FAQ)

    Q1:开启 transientStorePoolEnable=true 后,如果 Broker 进程直接 Crash(如 OOM Killer),数据会丢失吗? 会。这就是享受极致低延迟的代价。该模式下数据首先写入 DirectByteBuffer,这是用户态进程的堆外内存。如果进程被 kill -9 或者 Crash,这部分尚未 commit 到 OS PageCache 的数据将会丢失。如果你对数据一致性要求极度苛刻(如金融交易),只能忍受延迟,关闭此项并使用 SYNC_FLUSH

    Q2:为什么消费重试队列(%RETRY%)里的消息会导致明显的磁盘 IO 升高和 Broker 负载增加? RocketMQ 是基于 CommitLog 的混合存储。正常消费是顺序读写(刚写完的数据大概率还在 PageCache 中,命中率极高)。但重试队列消费的是过去某个时间点的冷数据。这就迫使 Broker 产生大量的随机 IO(读磁盘),导致 PageCache 污染,驱逐掉热数据,从而引发全局性能下降。应对策略通常是单独隔离重试服务,或使用 NVMe SSD 扛随机 IO。

    Q3:遇到 [TIMEOUT_CLEAN_QUEUE]broker busy,除了存储层问题,还有什么原因? 如果磁盘 IO 不高,PageCache 也没问题,你需要检查是不是 JVM 发生了长时间的 Stop-The-World (STW)。尤其是 G1 GC 配置不当,或是业务代码向 RocketMQ 发送超大消息(如几 MB 的报文),导致 Broker 在反序列化/网络传输时消耗大量 CPU 和内存资源,阻塞了 Netty 的 Worker 线程。

  • K8S API Server 被打挂的元凶:记一次 CRD Status 更新引发的 Reconcile 死循环惨案

    排查某个生产 K8S 集群异常时,发现 APIServer P99 延迟飙升至 4000ms 以上,etcd 磁盘 IOPS 直接打满。排查结论极度缺乏常识:业务团队新上线的一个 Operator 在 Reconcile 循环中毫无节制地更新 CRD 的 Status 字段(甚至注入了 time.Now()),且未配置任何 Event Filter。这导致了一个经典的死循环:更新 Status -> 触发 Update 事件 -> 进入 WorkQueue -> 再次 Reconcile -> 再次更新 Status。最终演变成针对 APIServer 的内网 DDoS,直接干碎了控制平面。

    这种低级失误在 Operator 开发中屡见不鲜。如果你连 K8S 声明式 API 的控制循环语义和 Informer 机制都没搞懂,就不要去碰 controller-runtime

    现场还原与指标雪崩

    近期监控系统疯狂报警,核心集群的 apiserver_request_duration_seconds_bucket 指标中,Mutating API 的 P99 延迟从平时的 15ms 暴涨到 4s。同时,etcd 节点的 etcd_disk_wal_fsync_duration_seconds 指标出现剧烈抖动,底层存储 IOPS 处于持续饱和状态。

    第一反应是控制平面被恶意击穿。拉取 APIServer 的审计日志和 QPS 监控(apiserver_request_total),发现某个特定资源 appconfigs.biz.example.comPUT / PATCH 请求 QPS 高达 8000+,且全集中在 /status 子资源上。

    随便抓一条 APIServer 的日志:

    I0814 10:23:45.123456       1 trace.go:205] Trace[12345678]: "Update /apis/biz.example.com/v1/namespaces/default/appconfigs/test-app/status" (started: 202x-xx-xx..., 3.5s)
    

    很明显,是新上的 Operator 出了严重 Bug。

    扒开烂代码:愚蠢的 Reconcile 逻辑

    把出问题 Operator 的代码拉下来,看一眼 Reconcile 函数和 Controller 的注册逻辑,简直是灾难现场。

    致命代码片段 1:无意义的动态 Status 更新

    func (r *AppConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
        var instance bizv1.AppConfig
        if err := r.Get(ctx, req.NamespacedName, &instance); err != nil {
            return ctrl.Result{}, client.IgnoreNotFound(err)
        }
    
        // ... 执行一些实际的业务逻辑 ...
    
        // 灾难的根源:每次 Reconcile 都无脑更新时间戳
        instance.Status.LastReconciledTime = metav1.Now()
        instance.Status.Phase = "Running"
    
        if err := r.Status().Update(ctx, &instance); err != nil {
            return ctrl.Result{}, err
        }
    
        return ctrl.Result{}, nil
    }
    

    致命代码片段 2:毫无防备的 Watch 注册

    func (r *AppConfigReconciler) SetupWithManager(mgr ctrl.Manager) error {
        return ctrl.NewControllerManagedBy(mgr).
            For(&bizv1.AppConfig{}). // 没有任何 Predicate 过滤
            Complete(r)
    }
    

    底层原理解析:为什么会死循环?

    在 Kubernetes 的架构中,任何对 Object 的修改(无论是 Spec 还是 Status,甚至是 Annotations 的变动),都会导致该 Object 的 ResourceVersion 发生改变。

    当这段代码执行 r.Status().Update() 时,底层发生了什么?

    1. APIServer 接收到更新请求,持久化到 etcd,并生成一个新的 ResourceVersion

    2. Operator 内部的 Reflector 通过 List-Watch 机制感知到这个变更,将带有新 ResourceVersion 的对象推入 DeltaFIFO

    3. Informer 处理这个 Delta 事件,更新本地 Indexer 缓存,并触发 Update 事件回调。

    4. 由于 SetupWithManager 中没有配置任何过滤条件,这个 Update 事件被原封不动地转换成了一条针对该 NamespacedName 的 Reconcile Request,塞进 WorkQueue

    5. Worker 协程从队列中取出 Request,再次执行 Reconcile

    6. Reconcile 中又执行了 metav1.Now() 生成了全新的时间戳,再次发起 Update

    死循环正式确立。 Operator 的 CPU 飙升,APIServer 的连接池被耗尽,etcd 疯狂刷盘写 WAL,最终整个 K8S 控制平面的响应能力被拖垮。

    破局与防御性编程实践

    修复这个 Bug 只需要两步,但更重要的是建立防御性编程的思维。

    1. 引入 GenerationChangedPredicate 拦截无效事件SetupWithManager 中,必须明确告诉 Controller:我只关心 Spec 的变化,不关心 Status 的变化。Kubernetes 通过 metadata.generationmetadata.resourceVersion 来区分这一点。修改 Spec 会自增 generation,而仅修改 Status 只会改变 resourceVersion

    import "sigs.k8s.io/controller-runtime/pkg/predicate"
    
    func (r *AppConfigReconciler) SetupWithManager(mgr ctrl.Manager) error {
        return ctrl.NewControllerManagedBy(mgr).
            For(&bizv1.AppConfig{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})).
            Complete(r)
    }
    

    注:如果你的 Controller 需要响应 Annotation 或 Label 的变化,不能简单使用 GenerationChangedPredicate,需要自定义 Predicate 逻辑。

    2. 状态对比,拒绝盲目 Update 不要在 Reconcile 中无脑塞 metav1.Now()。状态是用来反映资源当前真实情况的,不是用来做心跳上报的。在调用 Update 之前,必须做 DeepEqual 或者状态哈希校验,只有真正发生变化时才发起网络请求。

    // 好的实践:对比新老状态
    oldStatus := instance.Status.DeepCopy()
    
    // ... 计算新的 status ...
    instance.Status.Phase = "Running"
    // 取消无意义的 LastReconciledTime 更新
    
    if !reflect.DeepEqual(oldStatus, &instance.Status) {
        if err := r.Status().Update(ctx, &instance); err != nil {
            return ctrl.Result{}, err
        }
    }
    

    3. 利用 Client-Side Rate Limiter 兜底 哪怕业务逻辑写出了死循环,也绝不能把底层的 APIServer 打挂。在实例化 Manager 时,应当配置合理的限速器(RateLimiter),控制入队重试的指数退避频率和最大 QPS。

    排查清单:Operator Reconcile 性能与死循环速查

    1. APIServer QPS 异常突增定位: 优先检查 Prometheus apiserver_request_total 指标,按 resourceverb 分组,找出请求量异常的 CRD 和操作类型(通常是 UPDATE / PATCH status)。

    2. Controller 队列深度监控: 观察 workqueue_depthworkqueue_adds_total 指标。如果某个 Controller 的 adds_total 呈陡峭直线飙升,必然存在 Reconcile 死循环。

    3. 检查 Event Predicate 配置: 确认 SetupWithManager 是否使用了 GenerationChangedPredicate,或者是否在自定义的 Update Func 中过滤掉了 oldObj.ResourceVersion == newObj.ResourceVersion 的无效事件。

    4. 排查 Informer Cache 穿透: 绝对禁止在 Reconcile 中使用 r.Client.Get 获取对象后,直接在原对象指针上修改并绕过 Client 调用。如果强行修改 informer 缓存的对象而不提交到 APIServer,会导致本地缓存污染和不可预期的异常。始终对拿到的对象做 DeepCopy

    5. CRD Subresource 配置核对: 检查 CRD 的 YAML 定义中是否启用了 subresources: status。如果没有启用,对 Status 的更新会被当作对主对象的更新处理,极易引发锁冲突和额外的业务级混乱。

  • 深入 PostgreSQL MVCC 机制:从 500GB 表膨胀看 Autovacuum 与 xmin 陷阱实战

    PG 核心表突发 500GB 膨胀,查询 P99 从 50ms 飙升至 3s。根因是长事务或废弃复制槽拖住了全局 xmin 视界,导致 Autovacuum 彻底失效,引发 Dead Tuples 堆积的“死亡螺旋”。本文拆解 PG 14 的 MVCC 与 VACUUM 底层机制,并给出防御性调优基线。

    现场与线索

    某次排查过程中,监控大盘开始疯狂告警:某 PG 14.5 生产集群磁盘使用率突破 85%,核心业务读写耗时严重劣化。登录主机查看系统负载,Load Average 飙升至 60+(32核机型),I/O Wait 居高不下。

    通过 pg_stat_user_tables 排查表状态,发现一张核心订单表 n_dead_tup(死元组数量)高达数千万,表物理体积从原本的 50GB 暴涨到了 550GB。

    显然,这是一次典型的表膨胀(Table Bloat)。立刻手动触发分析:

    VACUUM VERBOSE orders;
    

    终端很快返回了令人窒息的日志:

    INFO:  vacuuming "public.orders"
    INFO:  "orders": found 0 removable, 45120485 nonremovable row versions in 702581 pages
    DETAIL:  45120485 dead row versions cannot be removed yet, oldest xmin: 245189012
    

    关键信息在 0 removablecannot be removed yet。Autovacuum 其实在正常调度,只是它无权清理这些死元组。

    为什么正常执行的 Autovacuum 无法回收死元组(Dead Tuples)?

    要解释这个问题,必须扒开 PostgreSQL 基于多版本并发控制(MVCC)的底层实现。

    在 PG 中,执行 UPDATEDELETE 并不会原地修改或删除数据。UPDATE 实际上是 DELETE + INSERT。旧的数据行被称为 Dead Tuple。PG 在每行数据(Tuple)头部维护了两个核心隐藏字段:

    • t_xmin:插入/更新该元组的事务 ID。

    • t_xmax:删除/更新该元组的事务 ID(如果是活元组,此值为 0)。

    当 Autovacuum 扫描表时,它需要判断一个 Dead Tuple 是否可以被物理回收。判断的唯一法则基于 全局最小活跃事务 ID(Global Xmin Horizon)。 如果一个 Dead Tuple 的 t_xmax 大于或等于 当前系统中正在运行的最老活跃事务的 ID(也就是 oldest xmin),那么这个 Dead Tuple 绝对不能被清理。因为那个老事务如果执行查询,根据 MVCC 可见性规则,它依然需要读取这行“历史数据”。

    因此,一旦系统中出现“刺客”拖住了全局 xmin,哪怕你把 Autovacuum 调得再激进,也是徒劳。常见的“刺客”有三种:

    1. 长事务(Long Transactions):代码里忘了 COMMITidle in transaction 状态。

    2. 废弃的逻辑复制槽(Abandoned Replication Slots):下游消费端宕机,导致主库一直保留 WAL 和 xmin 视图。

    3. 两阶段提交的孤儿事务(Prepared Transactions)

    揪出元凶

    执行以下 SQL 抓取系统中最老的事务或复制槽:

    -- 查长事务
    SELECT pid, usename, state, backend_xmin, backend_xid, 
           age(backend_xmin) AS xmin_age, query, state_change
    FROM pg_stat_activity 
    WHERE backend_xmin IS NOT NULL 
    ORDER BY age(backend_xmin) DESC LIMIT 5;
    
    -- 查复制槽
    SELECT slot_name, plugin, slot_type, active, xmin, 
           catalog_xmin, age(xmin) AS xmin_age 
    FROM pg_replication_slots 
    ORDER BY age(xmin) DESC;
    

    排查发现,业务端有个定时任务触发了死锁异常被捕获,但在异常处理逻辑中漏掉了 Rollback,导致一个 idle in transaction 的会话挂了 3 天,彻底锁死了全局 xmin 推进。

    解决手段简单粗暴:直接 pg_terminate_backend(pid) 杀掉僵尸会话。随后 Autovacuum 迅速介入,大量死元组被标记为可复用空间(FSM, Free Space Map)。

    生产级 Autovacuum 防御性调优基线

    原生 PG 的默认配置极度保守,是为了能在树莓派或低配虚机上跑起来而设计的。把默认配置直接上到几十核的高并发生产环境,等于给系统埋雷。

    为了防止类似“死亡螺旋”的发生,我们在 postgresql.conf 中必须落地以下防御性配置策略(基于 PG 14):

    1. 斩断长事务的黑手

    绝对不要相信业务代码能完美处理所有异常分支。在数据库侧兜底是运维的基本素养。

    # 防御性配置:强制终结空闲时间过长的事务(极度重要)
    idle_in_transaction_session_timeout = '10min'
    
    # (可选)针对高并发OLTP,设置单条语句最大执行时间
    # statement_timeout = '30s'
    

    2. 限制复制槽的 WAL 与 xmin 保留

    PG 13 引入了关键配置,防止死掉的逻辑复制槽把主库磁盘撑爆。

    # 限制复制槽最大保留的WAL大小,超出此值将强制失效复制槽
    max_slot_wal_keep_size = '50GB'
    

    3. 释放 Autovacuum 的 I/O 枷锁

    默认的 autovacuum_vacuum_cost_limit 是 200,它限制了 VACUUM 进程的 I/O 速率,导致在大表中 VACUUM 速度远落后于 UPDATE 产生垃圾的速度。

    # 降低触发阈值,避免累积过多才开始清理
    # 默认是0.2(20%),对于1亿行的表,要等2000万行变更才触发,太晚了
    autovacuum_vacuum_scale_factor = 0.05
    autovacuum_analyze_scale_factor = 0.02
    
    # 提升 VACUUM 的 I/O 配额限制(默认 200 太低,SSD 环境可以直接上 2000~5000)
    autovacuum_vacuum_cost_limit = 2000
    autovacuum_vacuum_cost_delay = 2ms
    

    避坑指南:很多人喜欢调大 autovacuum_max_workers(默认 3)。注意,所有 Worker 是平分 autovacuum_vacuum_cost_limit 这个 I/O 额度的。如果只加 Worker 不加 Limit,每个 Worker 的执行速度反而会变得像蜗牛一样慢,加剧锁竞争。

    常见问题 (FAQ)

    Q1:表已经膨胀到 500GB 了,杀死长事务后,Autovacuum 跑完了,为什么磁盘空间没有释放? A:Autovacuum 只能将 Dead Tuple 占用的空间标记为 Free Space Map (FSM) 供后续 INSERT/UPDATE 复用,它不会将空间退还给操作系统(除非恰好死元组都在表文件的物理末尾)。如果急需释放磁盘空间,不能使用常规 VACUUM,需要使用 VACUUM FULL(会获取 8 级排他锁,阻塞读写),或在生产环境使用第三方工具 pg_repackpg_squeeze 进行在线无锁空间重组。

    Q2:日志里疯狂打印 “WARNING: oldest xmin is far in the past”,并伴随 Transaction ID Wraparound 警告,怎么救? A:XID 环绕是 PG 最严重的问题之一。PG 的事务 ID 是 32 位整数(约42亿),用尽后会绕回,导致未来的事务把旧数据看作不可见,造成“数据蒸发”错觉。当到达防环绕阈值时,PG 会强制进入只读模式。 一旦触发警告,需立即停止应用写入,找出拖住 xmin 的老事务/复制槽清理掉,并手工执行 VACUUM (FREEZE, VERBOSE) table_name 来冻结老数据的 XID。若已宕机,需进入单用户模式(Single-User Mode)手动执行 Freeze。

    Q3:频繁触发 VACUUM 会不会对 WAL 产生剧烈影响? A:会。当开启了 wal_log_hints = on 或使用了数据校验和(Checksums),且发生 Checkpoint 后的第一次页面修改时,PG 会触发全页写入(Full Page Writes, FPW)。VACUUM 过程中如果是第一次 touch 某个页,也会产生大量的 FPW,导致 WAL 体积激增。这是保证 Crash Safe 的必要代价。应对策略是合理拉长 Checkpoint 间隔(调大 max_wal_sizecheckpoint_timeout),降低 FPW 的发生频率。

  • TiDB 集群 P99 暴涨至 5000ms:一个 2 亿行大事务 DELETE 引发的 Percolator 惨案

    某次排查过程中,核心交易集群的 TiDB 节点发生大面积 OOM,集群 P99 延迟从日常的 10ms 直接飙升到 5000ms 以上,TiKV 节点接连抛出 Server is busy 拒绝服务。先说最终结论: 某位研发在后台归档任务中,执行了一条没有任何 LIMIT 和分批的 DELETE 语句,企图在一个事务内删掉 2 亿行历史数据。由于对底层 Percolator 分布式事务模型一无所知,这个超级大事务不仅瞬间抽干了 TiDB Server 的内存,残留在 TiKV 的海量锁和 MVCC 墓碑(Tombstone)更是直接引发了读写雪崩。

    案发现场:从 OOM 到全局雪崩

    监控面板上,故障的爆发几乎是垂直的:

    1. tidb_server_memory_usage 指标在 3 分钟内从 4GB 飙升到 64GB(容器 Limit),随后节点被内核 OOMKilled

    2. TiKV 的 Raft apply duration P99 飙到秒级,Coprocessor CPU 打满。

    3. 应用端出现大量 java.sql.SQLException: Lock wait timeout exceeded; try restarting transactionRegion is unavailable

    切到机器上抓一下 dmesg,典型得不能再典型的 OOM:

    [123456.789] Memory cgroup out of memory: Kill process 5678 (tidb-server) score 1980 or sacrifice child
    [123456.790] Killed process 5678 (tidb-server) total-vm:85934028kB, anon-vm:67108864kB, file-vm:0kB, shmem-vm:0kB
    

    翻看 INFORMATION_SCHEMA.SLOW_QUERY 和存活节点的 TiDB 日志,抓到了罪魁祸首:

    DELETE FROM trade_orders WHERE create_time < '2023-01-01 00:00:00';
    

    就是这么一句平平无奇的 SQL,命中了近 2 亿条数据。

    当我拿着这条 SQL 去找对应业务线的开发时,得到的答复是:“我们用的是分布式数据库啊,底层不是无限水平扩展的吗?删个历史数据怎么就挂了?”

    这种把分布式数据库当成魔法、完全无视底层物理定律的想法,是导致大多数生产灾难的根源。分布式 != 无底洞。

    刨根问底:为什么分布式数据库最怕“大事务”?

    在单机 MySQL (InnoDB) 中,大事务会撑爆 Undo Log,导致长事务阻塞和主从延迟。而在 TiDB 这类基于 Percolator 模型的分布式 HTAP 数据库中,大事务的杀伤力是指数级的。

    1. OOM 的元凶:两阶段提交(2PC)的内存缓冲

    TiDB 处理事务使用的是 Percolator 模型的变种。在事务提交(Commit)之前,客户端(即 TiDB Server)会把所有修改的数据缓存在自己的内存中。 当执行这句 2 亿行的 DELETE 时,TiDB Server 需要将这 2 亿个 Key 的修改操作(在底层,DELETE 也是一种写入,即写入包含 Tombstone 标记的 KV)装进内存。 算一笔最简单的账:单行数据的 Key + Value 加上事务元数据假设为 200 Byte。 200,000,000 * 200 Byte ≈ 40 GB。 更要命的是,Go 语言在处理如此庞大的对象分配时,GC 会产生巨大的开销,内存碎片加上堆栈扩展,轻轻松松就能把 64GB 的容器内存干爆。

    2. “掩耳盗铃”的配置修改

    其实 TiDB 为了防止这种惨案,出厂设置是有保护机制的:txn-total-size-limit 默认通常为 100MB。 理论上,这个事务早就该报 Transaction too large 失败了。但我查阅配置变更历史时发现,前段时间该业务线抱怨过几次批量更新报错,某位缺乏敬畏之心的运维,直接将全网的 txn-total-size-limit 改成了 10GB! 放开这种硬性防御阈值,等于拆掉了保险丝。TiDB 成功绕过了配置限制,然后死在了物理内存耗尽上。

    3. 锁残留与 Resolve Lock 风暴

    TiDB Server OOM 崩溃后,灾难并没有结束。 在 Percolator 2PC 的 Prewrite 阶段,TiDB 会在 TiKV 端写入大量的 Primary Lock 和 Secondary Lock。TiDB Server 进程猝死,导致这些锁变成了“孤儿锁”。 此时,正常的业务请求如果读取到了这些被锁住的 Key,就会发现事务处于 Pending 状态。为了保证 ACID,读请求必须触发锁清理机制(Resolve Lock)。 几十万个并发查询撞上几千万个残留锁,瞬间引发了海量的 RPC 交互:

    [WARN] [endpoint.go:612] ["error response"] [err="Key is locked (primary)"] 
    [WARN] [resolve.go:128] ["resolve lock timeout"] [txn=43981293847123984]
    

    TiKV 的 RPC 线程池直接打满,Raftstore 处理缓慢,最终导致大面积的 Region unavailable,连正常的小事务也无法提交。

    终极解法与避坑指南

    对于分布式数据库的批量数据清理,绝对不能用传统的“大事务一波流”。如果你需要删几亿条数据,请把“防御性编程”刻在脑子里。

    正规的落地姿势有三种:

    方案 A:非事务 DML(Non-transactional DML) 新版 TiDB 提供了原生的批处理语法,直接在内部完成分批提交,不保证事务的原子性(反正删历史数据也不需要原子性),彻底绕过大事务限制:

    BATCH ON id LIMIT 10000 
    DELETE FROM trade_orders WHERE create_time < '2023-01-01 00:00:00';
    

    方案 B:按时间分区的 Drop Partition 对于日志流、流水表,建表时就应该规划好时间分区(Partition By Range)。清理历史数据只需一条 ALTER TABLE trade_orders DROP PARTITION p2022;。这在底层仅仅是元数据的解绑,瞬间完成,没有 MVCC,没有锁冲突。

    方案 C:TiDB TTL (Time to Live) 机制 如果业务特性允许,直接在表结构上加上 TTL 属性:

    ALTER TABLE trade_orders TTL = `create_time` + INTERVAL 1 YEAR;
    

    交由 TiDB 后台按 Region 慢慢清理,对前台业务透明。

    排查清单:同类大事务问题速查 (Troubleshooting Checklist)

    1. 核对 OOM 与系统日志 立刻在 TiDB 节点执行 dmesg -T | grep -i oom,如果命中 tidb-server,说明发生过严重的内存挤兑,大概率是大事务或者无索引的巨型 JOIN。

    2. 定位元凶 SQL 检索 INFORMATION_SCHEMA.SLOW_QUERY,重点关注 Mem_maxTxn_start_tsQuery_time 极大的语句: SELECT query, mem_max, process_time FROM information_schema.slow_query ORDER BY mem_max DESC LIMIT 5;

    3. 检查全局限制配置 不要盲目调大保护参数。检查 tidb_mem_quota_query(单条 SQL 内存限制)和 txn-total-size-limit(总事务大小限制),恢复到合理阈值(推荐单事务不要超过 1GB)。

    4. 清理遗留的悲观锁/乐观锁 如果 OOM 后集群持续卡顿,观察 Grafana 中的 TiKV-Details -> Locks 面板。必要时可通过临时调低 resolve-lock 的 backoff 时间来加速孤儿锁清理,或联系官方辅助清理陈旧的 MVCC tombstone 触发手动 Compaction。

    分布式架构给了你海量存储的错觉,但底层的内存、网络 IO 和锁机制依然遵循着严密的物理约束。在生产环境敲下回车之前,想想底层要付出多大的代价。

  • Exit Code 159 连环暴雷:一份“原汁原味”的 Seccomp 配置是如何干碎生产集群的

    排查某核心计费链路故障时,处理了一起令人血压飙升的 P0 事故。现象很简单:核心服务在一次例行发布后陷入无限 CrashLoopBackOff,容器退出码清一色是 159。而真正引发雪崩的,是研发为了绕过报错,随手加上的一句 privileged: true,直接触发了节点级 Falco 规则引擎的“死亡螺旋”,导致整台宿主机 Load Average 飙升至 80+,最终 OOM。

    结论先行:Exit Code 159 意味着进程收到了 SIGSYS (128 + 31) 信号,触发了 Seccomp 机制的系统调用拦截。 事故的根本原因是业务团队为了应付安全合规扫描,从几年前的博客上盲目抄了一份 Seccomp 白名单配置,漏掉了新版 glibc 强依赖的 clone3 系统调用。更不可原谅的是,面对拦截,他们没有去审计日志补齐规则,而是选择直接裸奔,进而引爆了底层的安全监控器。

    防御性编程的底线在于:不要用更大的错误,去掩盖一个你没看懂的报错。 接下来,我们把事故现场扒开,看看底层到底发生了什么。

    现场复原:神秘的 159 退出码与“消失的线程”

    服务起不来,查看 Pod 状态:

    $ kubectl get pods -n billing
    NAME                              READY   STATUS             RESTARTS   AGE
    billing-svc-7f8b9d4c-x9j2k        0/1     CrashLoopBackOff   12         3m
    

    看一眼容器退出日志,没有任何 Java 异常栈,只有一句冰冷的提示:Pod the container terminated with exit code 159.

    遇到 159,老鸟的直觉应该立刻指向 Seccomp(Secure Computing Mode)。登录所在 Node,直接翻内核审计日志:

    $ dmesg -T | grep audit | grep "sig=31"
    [Mon ...] audit: type=1326 audit(1690000000.123:45): auid=4294967295 uid=1000 gid=1000 ses=4294967295 pid=14321 comm="java" exe="/opt/java/bin/java" sig=31 arch=c000003e syscall=435 compat=0 ip=0x7f8a9b8c2d4e code=0x80000000
    

    这是一条标准的 Seccomp 拦截日志。拆解一下核心字段:

    • sig=31:触发了 SIGSYS 信号,内核直接 Kill 了该线程。

    • arch=c000003e:代表 x86_64 架构。

    • syscall=435:重点来了,在 x86_64 下,系统调用号 435 对应的是 clone3

    • code=0x80000000:对应 SECCOMP_RET_KILL_THREAD

    为什么会突然拦截 clone3?排查后发现,业务基础镜像最近升级到了基于 Ubuntu 22.04(内置 glibc 2.34+),而新版 glibc 在创建线程时默认优先使用 clone3。但业务提交的那份陈年 Seccomp 白名单(Default Profile)里,压根没有 435 这个系统调用!

    灾难升级:当“掩耳盗铃”遇上 Falco 规则引擎

    按照正常的逻辑,拿到 syscall=435,去 Seccomp Profile 的 syscalls 列表里加上 clone3 就完事了。但研发团队为了快速恢复,做了一个极其愚蠢的操作:直接在 YAML 里移除了 Seccomp 限制,甚至为了“保险起见”,加了特权模式:

    securityContext:
      privileged: true # 罪恶之源
      # seccompProfile:
      #   type: Localhost
      #   localhostProfile: "strict-profile.json"
    

    Pod 确实跑起来了,但集群的噩梦才刚刚开始。监控大屏上,该 Node 的 CPU 使用率瞬间打满,Falco(容器安全监控系统)的 Pod 疯狂重启。

    抓取 Node 的 top 和 eBPF 性能指标,发现 Falco 正在被按在地上摩擦。为什么?

    因为集群的安全团队在 Falco 中配置了这样一条规则,用于监控特权容器内的可疑命令执行:

    - rule: Privileged Container Exec
      desc: Detect any execve in a privileged container
      condition: >
        evt.type = execve and container
        and container.privileged = true
        and proc.cmdline pmatch ( "sh", "bash", "curl", "wget" )
      output: "Privileged execve (user=%user.name container_id=%container.id command=%proc.cmdline)"
      priority: WARNING
    

    注意那个 pmatch(正则前缀匹配)。业务 Pod 配置了 livenessProbe,每 5 秒执行一次 sh -c "curl -s http://localhost:8080/health"。 由于改成了特权容器,探针的每一次执行都会命中这条 Falco 规则。更要命的是,正则表达式是非常消耗 CPU 的操作。在高并发场景下,海量的 sys_enter_execve 事件涌入 Falco 的 eBPF Ring Buffer,导致 Falco 陷入重度计算,大量事件 Drop:

    # 查看 Falco drop 统计
    $ curl -s http://localhost:8765/metrics | grep falco_stats_drop_count
    falco_stats_drop_count 4589212
    

    最终,Falco 因处理不过来吃光了内存,被宿主机的 OOM Killer 无情干掉,整个节点短暂处于监控盲区。

    技术结论与正规军玩法

    解决这类问题,靠的不是拍脑袋加权限,而是建立正确的安全配置基线和调试方法。

    1. 永远不要用 SECCOMP_RET_KILL 作为默认动作调试 在生产环境引入自定义 Seccomp 前,正确的做法是先将 default action 设置为 SCMP_ACT_LOG。这样内核只会记录审计日志,而不会杀死进程:

    {
      "defaultAction": "SCMP_ACT_LOG",
      "syscalls": [
        {
          "names": ["clone", "clone3", "epoll_pwait", "futex"],
          "action": "SCMP_ACT_ALLOW"
        }
      ]
    }
    

    跑几天后,提取 /var/log/audit/audit.log 里的记录,分析出业务实际需要的 syscall 集合,再切回 SCMP_ACT_ERRNOSCMP_ACT_KILL

    2. 使用 SPO(Security Profiles Operator)自动化录制 不要手工猜系统调用。K8s 官方提供的 Security Profiles Operator 支持 LogEnricher 机制,可以在 Staging 环境跑一遍完整的回归测试,SPO 会自动帮你生成精确到业务级别的 Seccomp/AppArmor Profile。

    3. Falco 规则的防御性优化 Falco 规则引擎极度依赖条件短路(Short-circuit evaluation)。

    • 将高频过滤条件(如 evt.type = execve)放在最前面。

    • 尽量用 in= 替代正则 pmatchregex

    • 必须对 K8s 探针做白名单豁免,绝不能让健康检查触发报警逻辑。

    排查清单:容器运行时安全拦截速查

    遇到容器莫名其妙死亡、无日志退出、或权限拒绝时,请直接核对以下三步:

    1. 核对 Exit Code 159 (Seccomp拦截)

      • 现象:容器 CrashLoopBackOff,退出码 159
      • 命令:dmesg | grep -i seccompjournalctl -k | grep "sig=31"
      • 动作:提取 syscall= 后面的数字,去查阅 ausyscall x86_64 ,确认被拦截的调用(常见如 clone3=435, rseq=334)。
    2. 核对 AppArmor 拦截 (EPERM / Permission Denied)

      • 现象:代码里抛出 EPERM,或者 open/mkdir 报错,但文件权限明明是 777。
      • 命令:dmesg | grep -i apparmor | grep DENIED
      • 动作:检查 profile= 字段,确认是否使用了过于严苛的 AppArmor 模板限制了特定目录的写权限。
    3. 核对 Falco 性能瓶颈 (节点 Load 飙升 / 事件丢弃)

      • 现象:部署 Falco 后宿主机 CPU 升高,应用延迟抖动。
      • 命令:检查监控指标 falco_stats_drop_count
      • 动作:排查是否有规则使用了高昂的 regex,或者审计了太高频的 open / read 等系统调用,务必加上 container.name 的白名单豁免。
  • 深入排查 Go 业务 CPU 尖峰:从 pprof 盲区到 Linux perf 揭秘 futex 锁竞争实战

    仅靠 pprof 无法彻底看清 Go 程序的性能瓶颈。在某次高并发网关的 CPU 突发抖动排查中,pprof 仅显示微小的 GC 耗时,而通过 Linux perf 结合火焰图,最终定位到底层元凶是 sync.RWMutex 导致的系统调用 futex 激烈竞争。本文将还原从应用层到内核层的持续性能剖析过程。

    现场还原:幽灵般的 CPU 尖峰

    某次核心网关业务进行压测时,系统 p99 延迟从稳定的 20ms 突增至 800ms 以上。此时监控面板上出现了诡异的现象:

    • 节点 Load Average 狂飙,远超 CPU 核心数。

    • top 命令显示该 Go 进程(基于 Go 1.20.4 编译,运行于 Linux 5.10 内核)CPU 占用率达到 700%(8核机器)。

    • 但通过 go tool pprof 抓取 30 秒的 CPU Profile,看到的消耗却非常平缓。

    执行标准 pprof 采样:

    go tool pprof -text http://localhost:6060/debug/pprof/profile?seconds=30
    

    输出结果显示,没有任何一个业务函数占用超过 5% 的 CPU 时间,排在前面的全是 runtime 调度和网络 epoll 等底层函数:

    Showing nodes accounting for 1.20s, 35.10% of 3.42s total
    Dropped 214 nodes (cum <= 0.02s)
          flat  flat%   sum%        cum   cum%
         0.45s 13.16% 13.16%      0.45s 13.16%  runtime.epollwait
         0.30s  8.77% 21.93%      0.30s  8.77%  runtime.futex
         0.25s  7.31% 29.24%      0.40s 11.70%  runtime.findrunnable
         ...
    

    pprof 统计的总耗时只有区区 3.42s,这与 top 看到的进程 700% 满负荷运行(30秒内理应消耗接近 210秒的 CPU 时间)存在巨大的鸿沟。

    为什么 pprof 的采样数据与 top 看到的 CPU 负载严重不符?

    这涉及 Go pprof 的底层采样机制盲区。

    Go 原生的 CPU Profiler 默认通过 setitimer 系统调用触发 SIGPROF 信号进行采样(频率默认 100Hz)。当程序大量时间消耗在 系统调用(Syscalls) 阻塞、不可中断睡眠状态,或者发生极高频的内核态上下文切换时,基于用户态信号的 Profiler 往往会发生“漏采”。

    简单来说:pprof 擅长看 User Space 的纯计算逻辑(如序列化、复杂算法),但对于 Kernel Space 的阻塞和抢占,它是个高度近视眼。当你的 CPU 时间被内核态吃干抹净时,pprof 交出的报告自然是一笔糊涂账。

    穿透内核:使用 perf 与 FlameGraph 还原真相

    既然用户态工具失明,必须动用 Linux 系统级性能调优核武器:perf。通过记录 CPU 硬件计数器,我们能同时捕获 User 和 Kernel 栈。

    1. 抓取全局性能事件

    在问题机器上直接对该进程进行 30 秒的全栈采样(采样频率设为 99Hz 以避免与特定周期事件共振):

    # -F 99: 99次/秒采样频率
    # -p: 进程号
    # -g: 记录调用栈 (call graph)
    perf record -F 99 -p 18374 -g -- sleep 30
    

    2. 生成火焰图

    原始的 perf.data 不可读,通过 Brendan Gregg 的火焰图工具链进行可视化转换:

    # 解析 perf.data 输出明文
    perf script > out.perf
    
    # 折叠调用栈
    ./stackcollapse-perf.pl out.perf > out.folded
    
    # 生成 SVG 火焰图
    ./flamegraph.pl out.folded > cpu_flamegraph.svg
    

    3. 火焰图解析

    打开 cpu_flamegraph.svg 后,真相大白。火焰图的 X 轴表示 CPU 耗时比例。 在生成的火焰图中,有一座极为宽阔的“平顶山”(占总 CPU 宽度的 60% 以上),调用链明确指向: 业务函数 getFromCache -> sync.(*RWMutex).RLock -> runtime.gopark -> runtime.futex -> [kernel.kallsyms] -> sys_futex -> do_futex

    这意味着:CPU 的计算资源根本没有用来处理业务逻辑,而是全耗在了内核锁原语 futex(Fast Userspace Mutex)的自旋、挂起和唤醒操作上。

    根因剖析:读写锁降级与 sys_futex 风暴

    切回业务代码,排查 getFromCache 所在的逻辑:

    var cacheLock sync.RWMutex
    var globalCache = make(map[string]string)
    
    func getFromCache(key string) string {
        cacheLock.RLock()
        defer cacheLock.RUnlock()
        return globalCache[key]
    }
    

    这段看似极度常规的读缓存代码,在超高并发(十万级 QPS)下是个致命的性能毒药。

    Go 的 sync.RWMutex 在设计上偏向写公平。当有一个写锁请求(Lock())到达时,后续所有的读锁请求(RLock())都会被阻塞排队,以防止写饥饿。 排查过程中发现,有个后台 Goroutine 每 10 秒会全量刷新一次该 globalCache 并加写锁。

    在这个极短的写锁持有窗口期内:

    1. 海量的读请求涌入,全部在 RLock() 处被拦截。

    2. Go 的 P(Processor)发现 Goroutine 阻塞,触发 runtime.gopark 让出执行权。

    3. 底层 M(OS 线程)调用内核 futex 将线程挂起等待。

    4. 写锁释放时,使用 futex 唤醒数以千计堆积的 Goroutines。

    5. 爆发 惊群效应(Thundering Herd),大量线程瞬间从休眠态转为就绪态,疯狂抢占 CPU,产生极其惨烈的 Context Switch。

    极客排查与改造方案

    明确了是全局单点锁在多核架构下的竞争问题,解决方案必须走向“无锁化”或“锁粒度细化”。

    方案一:锁分片(Lock Sharding)

    最典型的防御性编程思路,参考 ConcurrentHashMap 的分段锁。

    const shardCount = 256
    
    type ShardedCache struct {
        shards [shardCount]struct {
            sync.RWMutex
            data map[string]string
        }
    }
    
    // 散列函数,规避单点竞争
    func (c *ShardedCache) getShard(key string) int {
        hash := fnv.New32a()
        hash.Write([]byte(key))
        return int(hash.Sum32()) % shardCount
    }
    
    func (c *ShardedCache) Get(key string) string {
        shard := &c.shards[c.getShard(key)]
        shard.RLock()
        defer shard.RUnlock()
        return shard.data[key]
    }
    

    通过 256 个分片,将锁竞争的碰撞概率降到了原来的 1/256,彻底消除了单点 futex 风暴。

    方案二:写时复制(Copy-on-Write) + atomic.Value

    既然是读多写少的缓存场景,使用原子操作直接替换底层指针是性能最高的方式,达到读操作 0 阻塞。

    var cache atomic.Value
    
    // 初始化
    cache.Store(make(map[string]string))
    
    func getFromCache(key string) string {
        // 无锁读取
        m := cache.Load().(map[string]string)
        return m[key]
    }
    
    func updateCache(newData map[string]string) {
        // 整个替换 map 指针
        cache.Store(newData)
    }
    

    改造上线后,再次抓取 perf 火焰图,sys_futex 的高塔完全消失,节点 Load Average 从 30 回落到 2 左右,p99 延迟稳定在 15ms。

    常见问题 (FAQ)

    Q1:线上运行 perf record 收集数据,会对生产环境业务造成明显的性能损耗吗? 只要不使用过高的采样频率,开销是完全可控的。文章中推荐使用 -F 99(每秒 99 次)而不是默认的 -F 4000 或直接不加限制。对于生产环境,99Hz 产生的额外 CPU 开销通常不到 1%,完全可以安全进行数分钟的常规采样。

    Q2:如果程序的内存一直缓慢上涨,但 pprofheap 视图看到的 inuse_space 很小,该用什么思路排查? 大概率发生了非 Go 堆内存泄漏(即 CGO 调用、mmap 显式分配、或者 glibc/jemalloc 底层的碎片化)。此时 pprof 无能为力。建议通过 cat /proc//smaps 查看具体的内存段映射,结合 bcc/eBPFmemleak 工具,或者使用 perf record -e page-faults 追踪哪些底层 C 函数在频繁触发缺页中断。

    Q3:除了手敲命令生成 SVG,现在业界有哪些主流的持续性能分析(Continuous Profiling)落地架构? 现代云原生架构多采用基于 eBPF 的持续 Profiling 平台。主流开源方案包括 Pyroscope 和 Parca。它们通过 DaemonSet 在每个 Kubernetes 节点部署 Agent,利用 eBPF 的低开销特性全天候抓取所有 Pod 的 CPU/内存/锁信息,并存储在专门的时序数据库中,支持随时回溯任意时间点的火焰图,是排查偶发性能毛刺的最佳实践。

  • Jenkins K8S 动态 Agent 疯狂重启劫难:被隐式降级击穿的 JNLP 通信防线

    某次排查过程中,核心业务线的 CI/CD 流水线彻底瘫痪,Jenkins 任务队列(Queue)积压突破 500。与此同时,底层 Kubernetes 集群告警群炸锅,API Server 出现严重的请求限流(Throttling),P99 延迟飙升至 3 秒以上。

    最终排查结论:架构团队在做 Jenkins 迁移与高可用改造时,仅配置了 Layer 7 的 Ingress 规则,却遗漏了 Jenkins Remoting 通信依赖的 Layer 4 TCP(50000)端口。导致 K8S 动态 Agent Pod 启动后无法与 Master 建立 JNLP 连接。Jenkins Kubernetes 插件因此陷入了致命的“申请 Pod -> Agent 注册超时 -> 销毁 Pod -> 无限重试”死循环,硬生生把集群 API Server 给打穿了。

    把 Jenkins 当成一个普通的无状态 Web 服务去搞云原生改造,而不去深究其底层 Master-Agent 的心跳与通信模型,这种粗暴的操作在生产环境中是极其致命的。

    案发现场:失控的调度器与死亡循环

    接到报障后,第一时间登录集群查看资源状态。终端里的现象令人窒息:

    $ kubectl get pods -n jenkins | grep jnlp-agent | wc -l
    842
    
    $ kubectl get pods -n jenkins | grep jnlp-agent | head -n 5
    jnlp-agent-8f73b-5x9qp   0/1     ContainerCreating   0          12s
    jnlp-agent-8f73b-9m2kx   1/1     Terminating         0          1m45s
    jnlp-agent-8f73b-p2v1l   0/1     ContainerCreating   0          8s
    jnlp-agent-8f73b-x8c4d   1/1     Terminating         0          1m45s
    

    数百个 Agent Pod 处于 ContainerCreatingTerminating 状态。再去查看 Jenkins Master 的系统日志,满屏都是类似下面的报错:

    INFO: Kubernetes pod jnlp-agent-8f73b-9m2kx started
    WARNING: Failed to connect to agent jnlp-agent-8f73b-9m2kx within 100 seconds. 
    INFO: Terminating node jnlp-agent-8f73b-9m2kx
    INFO: Queue task #4023 still pending, provisioning a new agent...
    

    转头查看其中一个 Agent Pod 的内部日志,终于抓到了真凶:

    INFO: Locating server among [https://jenkins.company.com/]
    WARNING: Failed to connect to https://jenkins.company.com/tcpSlaveAgentListener/: Connection refused
    java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    ...
    INFO: Retrying in 10 seconds
    

    深度剖析:为什么缺少一个端口会导致雪崩?

    要理解这个故障,必须理清 Jenkins Kubernetes Plugin 的工作状态机。这绝不只是一个“网络不通”的简单 Bug,而是一个典型的分布式状态机不同步导致的雪崩。

    1. Remoting 协议的固执:Jenkins Master 与 Agent 之间的通信基于 Jenkins Remoting 协议,这是一个重度依赖序列化与长连接的 Java 二进制协议。默认情况下,Agent 启动后,会先通过 HTTP(S) 请求 Master 的主入口,获取 X-Jenkins-CLI-Port 或相关 TCP 端口信息(通常是 50000),随后尝试建立直连 TCP 通道。

    2. L7 Ingress 的拦截:改造期间,Jenkins Master 被放到了 Nginx Ingress 后端。Ingress 默认只处理 HTTP/HTTPS 协议(L7)。当 Agent 尝试向 jenkins.company.com:50000 建立 TCP 握手时,流量直接在网关层被丢弃或拒绝。

    3. 致命的机制错位(State Mismatch)

    4. K8S 视角:Pod 已经成功拉起,容器状态是 Running,K8S 认为任务完成。
    5. Jenkins 视角:向 K8S 发送了 Pod 创建请求,且等待 Agent 进程发起 JNLP 注册回调。
    6. 死循环触发:等待 100 秒后(默认超时时间),Jenkins Master 依然没收到 Agent 的 JNLP 注册心跳。它不仅不会认为是自己的网络配置问题,反而会固执地判定:“这个 Pod 死掉了,为了满足队列里等待的构建任务,我必须销毁它,并向 K8S 申请一个新的 Pod。”

    当并发构建任务达到 50 个,每个任务都在触发这种“申请 -> 等待 -> 销毁 -> 再申请”的循环时,K8S 的 kube-apiserver 就成了重灾区。大量的 POST /api/v1/namespaces/jenkins/podsDELETE 请求瞬间填满了 API Server 的队列,触发限流,进而影响整个集群内其他核心业务 Pod 的调度与扩缩容。

    解决方案与防御性配置

    针对此类问题,修复网络通信只是第一步,更重要的是在架构层面加上防御性兜底限制。

    1. 拥抱 WebSocket,抛弃底层 TCP 直连

    既然 L4 暴露配置繁琐且容易在各种负载均衡器上踩坑,最优雅的做法是直接让 JNLP 流量复用 HTTP(S) 的 L7 通道。从 Jenkins 2.217 开始,Remoting 已经原生支持 WebSocket。

    在 JCasC (Jenkins Configuration as Code) 的配置中,必须在 K8S Cloud 配置项里显式开启 webSocket: true

    jenkins:
      clouds:
        - kubernetes:
            name: "kubernetes"
            # 直接走集群内部 DNS 通信,绕过外部 Ingress,降低网络开销与故障点
            serverUrl: "https://kubernetes.default"
            namespace: "jenkins-agents"
            jenkinsUrl: "http://jenkins-master.jenkins.svc.cluster.local:8080"
            # 开启 WebSocket,彻底解决 TCP 50000 端口穿透问题
            webSocket: true
            # 【防御性编程核心】设置全局容量上限,哪怕死循环也不会打穿 API Server
            containerCapStr: "100" 
    

    2. 配置 Kubernetes Plugin 的防雪崩限制

    永远不要假设外部系统会乖乖按预期工作。必须给 Jenkins 向 K8S 索要资源的行为加上硬性枷锁:

    • containerCapStr: 限制整个 K8S Cloud 并发存活的 Agent 总数。

    • 在每个 podTemplate 级别设置 instanceCap:防止单一异常的 Pipeline 把所有集群资源耗尽。

    3. 剥离通信链路(Cluster Internal Routing)

    如果你只是在同一个 K8S 集群内部署 Jenkins Master 和调度 Agent,Agent 连接 Master 绝对不应该 绕一圈跑到外网 Ingress 再进来。不仅增加延迟,还多引入了一层网络设备的故障风险。 强制在 jenkinsUrl 中使用 K8S 内部的 FQDN:http://..svc.cluster.local:

    排查清单与同类问题速查

    如果你也遇到了 Jenkins Agent 疯狂重启或一直在 Pending/Terminating 之间横跳,请核对以下清单:

    1. 排查 JNLP 握手阻断:查看 Agent Pod 的日志。如果出现 Connection refusedConnection timed out,且指向 Master 的 50000 端口,立刻检查安全组、网络策略 (NetworkPolicy) 或 LoadBalancer 的 L4 暴露情况,或者直接开启 WebSocket。

    2. 检查 Jenkins Master URL 配置:如果 Manage Jenkins -> System -> Jenkins URL 配置错误,Agent 会拿到一个无法解析的地址。在 K8S 环境下,尽量在 Cloud 配置的 jenkinsUrl 中覆盖并强制指定 ClusterIP 或内部 DNS。

    3. 监控 ContainerCap 触顶情况:如果在 Jenkins 侧看到任务一直卡在 ‘Jenkins’ doesn’t have label ‘xxx’ 或者 Waiting for next available executor,但没有看到新 Pod 创建,检查系统日志确认是否触发了 containerCap 上限。

    4. 防御性兜底检查:确认有没有恶意的 Groovy 脚本在无限触发重试。检查 Pipeline 里的 retry() 块逻辑是否包含了环境构建阶段,避免因业务代码逻辑错误引发基础设施级别的 Ddos 攻击。