21 利用分布式消息队列降低系统耦合性，java 后端项目实战

开发低耦合系统是软件设计的终极目标之一，这一目标驱动着软件开发技术的创新 与发展，从软件与硬件的第一次分离到操作系统的诞生；从汇编语言到面向过程的开发语言，再到面向对象的编程语言；从各种软件工具集到各种开发框架；无不体现着降低 软件系统耦合性这一终极目标。可以说，度量一个开发框架、设计模式、编程语言优劣 的重要尺度就是衡量它是不是让软件开发过程和软件产品更加低耦合。

显而易见，低耦合的系统更容易扩展，低耦合的模块更容易复用，一个低耦合的系

统设计也会让开发过程和维护变得更加轻松和容易管理。一个复杂度为 100 的系统，如 果能够分解成没有耦合的两个子系统，那么每个子系统的复杂度不是 50,而可能是 25。

当然，完全没有耦合就是没有关系，也就无法组合出一个强大的系统。那么如何分解系 统的各个模块、如何定义各个模块的接口、如何复用组合不同的模块构造成一个完整的 系统，这是软件设计中最有挑战的部分。

笔者认为，软件架构师最大的价值不在于掌握多少先进的技术，而在于具有将一个 大系统切分成 N 个低耦合的子模块的能力，这些子模块包含横向的业务模块，也包含纵 向的基础技术模块。这种能力一部分源自专业的技术和经验，还有一部分源自架构师对 业务场景的理解、对人性的把握、甚至对世界的认知。

大型网站也常常意味着功能复杂，产品众多。网站为了在市场竞争中胜岀，不断推 出各种新产品，为了把握市场机会，这些产品从策划到上线，时间非常短暂，技术团队 必须在产品设计和需求分析结束之后，快速地开发完成一个新产品。同时经过长期的演 化和发展，这些产品之间的关系错综复杂，维护也变得异常困难。这些问题对网站的可 扩展架构提岀了挑战和要求。

设计网站可扩展架构的核心思想是模块化，并在此基础之上，降低模块间的耦合性, 提高模块的复用性。

我们在本书第 6 章讨论过网站通过分层和分割的方式进行架构伸缩，分层和分割也 是模块化设计的重要手段，利用分层和分割的方式将软件分割为若干个低耦合的独立的 组件模块，这些组件模块以消息传递及依赖调用的方式聚合成一个完整的系统。

在大型网站中，这些模块通过分布式部署的方式，独立的模块部署在独立的服务器 (集群)上，从物理上分离模块之间的耦合关系，进一步降低耦合性提高复用性。

模块分布式部署以后具体聚合方式主要有分布式消息队列和分布式服务。

[](

)2 利用分布式消息队列降低系统耦合性

如果模块之间不存在直接调用，那么新增模块或者修改模块就对其他模块影响最小, 这样系统的可扩展性无疑更好一些。

[](

)2.1 事件驱动架构

事件驱动架构(Event Driven Architecture )：通过在低耦合的模块之间传输事件消息, 以保持模块的松散耦合，并借助事件消息的通信完成模块间合作，典型的 EDA 架构就是 操作系统中常见的生产者消费者模式。在大型网站架构中，具体实现手段有很多，最常 用的是分布式消息队列，如图 7.1 所示。

消息队列利用发布一订阅模式工作，消息发送者发布消息，一个或者多个消息接收 者订阅消息。消息发送者是消息源，在对消息进行处理后将消息发送至分布式消息队列, 消息接受者从分布式消息队列获取该消息后继续进行处理。可以看到，消息发送者和消 息接受者之间没有直接耦合，消息发送者将消息发送至分布式消息队列即结束对消息的处理，而消息接受者只需要从分布式消息队列获取消息后进行处理，不需要知道该消息 从何而来。对新增业务，只要对该类消息感兴趣，即可订阅该消息，对原有系统和业务 没有任何影响，从而实现网站业务的可扩展设计。

消息接受者在对消息进行过滤、处理、包装后，构造成一个新的消息类型，将消息 继续发送出去，等待其他消息接受者订阅处理该消息。因此基于事件（消息对象）驱动 的业务架构可以是一系列的流程。

由于消息发送者不需要等待消息接受者处理数据就可以返回，系统具有更好的响应 延迟；同时，在网站访问高峰，消息可以暂时存储在消息队列中等待消息接受者根据自 身负载处理能力控制消息处理速度，减轻数据库等后端存储的负载压力。

[](

)2.2 分布式消息队列

队列是一种先进先出的数据结构，分布式消息队列可以看作将这种数据结构部署到 独立的服务器上，应用程序可以通过远程访问接口使用分布式消息队列，进行消息存取 操作，进而实现分布式的异步调用，基本原理如图 7.2 所示。

消息生产者应用程序通过远程访问接口将消息推送给消息队列服务器，消息队列服 务器将消息写入本地内存队列后立即返回成功响应给消息生产者。消息队列服务器根据 消息订阅列表查找订阅该消息的消息消费者应用程序，将消息队列中的消息按照先进先出（FIFO ）的原则将消息通过远程通信接口发送给消息消费者程序。

目前开源的和商业的分布式消息队列产品有很多，比较著名的如 Apache ActiveMQ 等，这些产品除了实现分布式消息队列的一般功能，在可用性、伸缩性、数据一致性、性能和可管理性方面也做了很多改善。