为什么要集成消息队列

在实时协作模块，每条修改记录都会生成一条日志数据，并在多个组件间流转。

前端提交的修改 JSON 会在后端解析为 Java 对象，通过通用 Service 层（为了解耦兼容）路由到 MQ Service。接着由 MQ 完成三件事：先写 Redis 并广播实现实时可见；再写 MySQL 实现持久化落盘；最后定期刷快照存入 MinIO.

如果由业务层直接处理该流程，则会引入大量的条件判断、异常重试以及异构数据源引发的一致性协调问题。引入消息队列后，复杂的底层细节被天然的发布-订阅模型（Pub-Sub）屏蔽。以 RabbitMQ 为例，我们只需构建若干个交换机，绑定三个队列（Redis/MySQL/MinIO），即可通过解耦实现清晰的业务流转。

消息队列的引入，本质上是构建了一个内置的解耦拓扑网络，使整个业务架构与数据流向一目了然。

具体的集成实现

以 Spring AMQP 为例