小曾博客

别再只盯着 LangChain 了：从执行模型源码看 LangChain/LangGraph、LlamaIndex、CrewAI、AutoGen 的真实分水岭 引言 先说一个我去年踩过的坑。 团队要做一个\

从“记账本”到“原子提交”：拆解 Flink 状态管理与 Exactly-Once 的底层账本逻辑 引言 先说一个我亲身踩过的坑。 2021 年我负责一个实时计费系统，用 Flink 消费 Kafka 里的用户流量日志，按分钟聚合后写入 MySQL 做扣费。上线第一周，财务对账发现每天多扣了约 0.3% 的用户费用。排查三天，定位到问题：Job 因背压触发了 TaskManager 重启，Kafk

Django ORM查询优化与N+1问题解决 引言 去年双十一大促前夜，我接手了一个\

LangGraph多Agent协作模式：Supervisor与Swarm架构 引言 想象一下你正在经营一家现代化的互联网医院。患者进来时，前台分诊护士先判断\

FastAPI + Tortoise ORM 异步数据库实践 引言 去年双十一前，我接手了一个用 FastAPI 写的订单查询服务。压测时 QPS 刚到 800 就上不去了，CPU 却只跑了 30%。打开火焰图一看，asyncio 事件循环里躺着大量 psycopg2 的同步阻塞调用——await db.execute(...) 表面上是异步的，底下却在用线程池硬扛，线程池一满，

Transformer架构深度解读：Self-Attention数学原理 引言 去年双十一大促前夜，我们的智能客服系统遇到了一个诡异的问题：用户问\

Celery分布式任务队列架构与调优 引言 先讲一个真实的生产事故。 某电商团队的大促系统里，用户下单后需要触发 12 个后续动作：扣减库存、发优惠券、写积分、发短信、推送 App 通知、生成对账单……最初这些逻辑都塞在 POST /order 的请求链路里同步执行。平时没问题，大促一开，订单接口 P99 从 200ms 飙到 8 秒，网关连接池被打满，整

Function Calling机制与LangChain Tool集成实践 引言 去年帮一家做企业知识库的团队排查线上事故，现象很诡异：用户问\

MyBatis插件机制与拦截器链源码分析 引言 做过几年业务系统的同学，大概率都遇到过这样的需求：想给所有 SQL 统一加上租户条件、想统计每条 SQL 的耗时、想对敏感字段做脱敏、想在分页时自动改写 SQL……这些需求有个共同点——它们都发生在 SQL 执行的前后，但你不想改业务代码，也不想改 MyBatis 源码。 这时候，MyBatis 的插件机制（Pl

Python元类编程与ORM框架实现 引言 去年我接手一个内部数据平台的重构，需求很简单：把散落在十几个脚本里的 SQL 拼接逻辑收敛成统一的模型层。团队里有人提议直接上 SQLAlchemy，但甲方要求\

Embedding模型选型与语义搜索实践 引言 去年双十一大促前夜，我接到一个紧急电话。某电商平台的\

CompletableFuture异步编程实战与原理 引言 先看一个真实的生产事故。 某电商平台的商品详情页聚合接口，需要并行调用 6 个下游服务：商品基础信息、库存、价格、促销、评价、推荐。早期实现用的是 ExecutorService + Future： Future<Product> productFuture = executor.submit(()

Python协程与生成器的底层实现（yield from解析） 引言 先讲一个我亲身经历的线上事故。 某电商大促期间，一个基于 Django 的商品详情接口突然响应时间从 80ms 飙到 3s。排查后发现，这个接口内部要串行调用 5 个下游服务：库存、价格、促销、评价、推荐。每个 RPC 平均 200ms，串起来就是 1s 起步。运维同学第一反应是\

高并发秒杀系统架构设计演进 引言 2024年双十一零点,某电商平台一款限量5000台的旗舰手机在开售后的第3秒就被抢购一空,峰值QPS冲到 82万。而就在半年前,同一个团队的系统在 5万 QPS 时就开始出现大面积超卖、Redis 连接池打满、数据库 CPU 100% 的连锁雪崩。 这不是一个\

事件驱动架构：Kafka/RabbitMQ/Pulsar选型对比 引言 先讲一个我真实踩过的坑。 三年前我在一家电商公司做订单履约系统。大促前夜，订单服务每秒写入 3 万条消息到一个 RabbitMQ 集群，消费者是库存、积分、风控、通知四个下游服务。结果零点一过，RabbitMQ 的队列积压瞬间冲到千万级，内存告警、磁盘刷盘、连接被打满，最后整个链路雪崩。 事后复盘时我们发现一个残