目录

• 一、前情提示
• 二、选择性订阅部分核心数据
• 三、RabbitMQ的queue与exchange的绑定回顾
• 四、direct exchange实现消息路由
• 五、按需订阅数的代码实现
• 六、更加强大而且灵活的按需订阅

一、前情提示

上一篇文章《你以为架构师天天就画图写PPT吗，告诉你其他事儿多了去了~》，我们已经给出了一整套的数据一致性的保障方案。

我们从如下三个角度，给出了方案如何实现。并且通过数据平台和电商系统进行了举例分析。

• 核心数据的监控
• 数据链路追踪
• 自动化数据链路分析

目前为止，我们的架构图大概如下所示：

并且咱们之前对于这种架构下，如何基于MQ进行解耦的实现也做了详细的说明。

有不清楚的同学，可以具体看一下之前的三篇文章：

1. 第一次当架构师，我设计高并发架构发现了N个痛点。。。
2. 百亿级流量的系统架构该怎么设计，今天就来教会你！
3. 我跟同事之间一次关于“架构设计”的嘴炮，大家一起听听…

那么这篇文章，我们就基于这个架构，在数据一致性方面做进一步的说明。同样，我们以RabbitMQ这个消息中间件来举例。

二、选择性的订阅部分核心数据

首先一个基于MQ实现的细节点就在于，比如对数据监控系统而言，他可能仅仅只是要从MQ里订阅部分数据来消费罢了。