生产端：使用MessageQueueSelector，按业务 Key（如订单 ID）哈希选择队列

"先止损、再排查、后预防"，核心原则是优先保证核心业务可用，再逐步定位和解决根本问题，绝对不能先花半小时查原因而让业务一直挂着。

用户信息同步：用户改昵称、换头像，变更要实时同步给下游的搜索和排行榜。量一上来，三个问题全冒头——查用户信息慢到两秒起，消息消费出来顺序乱得离谱，改完的头像刚写...

大家好，我是晚安code。更新完数据库，缓存里却还躺着旧数据——这种脏数据我太熟了。上周排查一个订单价格对不上的线上问题，最后定位到就是「先删缓存再写库」在并发...

同步 HTTP 接口有网关、RPC 客户端双层超时兜底，卡住请求会快速释放 Tomcat 线程；但 MQ 消费、异步任务、定时任务属于常驻后台线程模型，线程不依...

在上篇《一次 AI 问答，背后是十几个 Agent 在 “传纸条” — RocketMQ Lite Topic 实战》中，我们通过两个真实场景 — AI 编程助...

其实通过前面两篇文章的介绍，大概应该心里有一个直观感受，防止超卖的最核心关键就是将所有请求进行串行化。

上周我在review一个多Agent系统的架构方案时，看到了一个经典的"翻车现场"：

互联网大厂主流采用 RocketMQ 定时消息 + 本地事务表 + 定时任务兜底 的组合方案，兼顾性能、可靠性和可维护性。

它背后是好几个 Agent 在协作：一个编排 Agent（主 Agent） 把你的问题拆成三件事 -> 查天气、查机票、查日程 -> 分别交给三个服务 Agen...

毕竟大多数小项目里，一个接口调另一个接口，数据库直接读写，功能照样能跑。直到有一天，系统访问量慢慢上来，各种问题开始集中爆发：订单创建变慢、短信发送超时、日志写...

1-2月产品月报 | TDMQ CKafka Serverless 形态正式商业化，TDMQ MQTT 版推出铂金版

用过RocketMQ的都知道，官网只提供了一个集群的starter，如果业务域进行消息隔离，使用了不同的集群，就只能copy、paste这种样板式代码，好烦！！...

在分布式微服务架构中，消息中间件是解耦系统、削峰填谷、异步通信的核心组件。RocketMQ作为阿里开源的金融级分布式消息中间件，凭借高可靠、高吞吐、低延迟的特性...

Producer发送消息的核心入口是DefaultMQProducerImpl#sendDefaultImpl，完整流程：