消息中间件简介及ActiveMQ 下载、安装-架构

捐助

消息中间件简介及ActiveMQ 下载、安装

作者： Woo_home

1956 次浏览

2020-7-7

编辑推荐:

本文主要讲解了什么是消息中间件？消息中间件引出产生背景，消息中间件的定义、常用的消息中间件有哪些？及ActiveMQ 下载、安装。

来自于csdn，,由火龙果软件Anna编辑、推荐。

什么是消息中间件？

上面提到过消息中间件，那么什么是消息中间件呢？

消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型，它可以在分布式环境下扩展进程间的通信

消息中间件引出产生背景

一、系统之间接口耦合比较严重

系统之间直接调用实际工程落地和存在问题

微服务架构后，链式调用是我们在写程序时候的一般流程，为了完成一个整体功能会将其拆分成多个函数（或子模块），比如模块 A 调用模块 B，模块 B 调用模块 C，模块 C 调用模块 D。但在大型分布式应用中，系统间的 RPC 交互繁杂，一个功能背后要调用上百个接口并非不可能，从单机架构过渡到分布式服务架构的通例，这种架构会有哪些问题？

系统之间接口耦合比较严重

每新增一个下游功能，都要对上有相关接口进行改造；

举个例子：假如系统 A 要发送数据给系统 B 和 C，发送给每个系统的数据可能有差异，因此系统 A 对要发送给每个系统的数据进行了组装，然后逐一发送；

当代码上线后又新增了一个需求：

把数据也发送给 D，新上了一个 D 系统也要接受 A 系统的数据，此时需要修改 A 系统，让它感知到 D 的存在，同时把数据处理好 A 再给 D。在这个过程中你会发现，每接入一个下游系统，都要对 A 系统进行代码改造，开发联调的效率很低。其整体架构如下图

二、面对大流量并发时，容易被冲垮

每个接口模块的吞吐量能力是有限的，这个上限能力如果堤坝，当大流量（洪水）来临时，容易被冲垮

举个例子秒杀业务：

上游系统发起下单购买操作，就是下单一个操作

下游系统完成秒杀业务逻辑

（读取订单、库存检查、库存冻结、余额检查、余额冻结、订单生成、余额扣减、库存扣减、生成流水、余额解冻、库存解冻）

三、等待同步存在性能问题

RPC 接口基本上是同步调用，整体服务性能遵循 “木桶理论”，即整体系统的耗时取决于链路中最慢的那个接口

比如 A 调用 B/C/D 都是 50ms，但此时 B 又调用了 B1，花费 2000 ms，那么直接就拖累了整个服务性能

如何解决？

要做到系统解耦，当新的模块接进来时，可以做到代码改动最小；能够解耦

设置流量缓冲池，可以让后端系统按照自身吞吐能力进行消费，不被冲垮；能够削峰

强弱依赖梳理能将非关键调用链路的操作异步化并提升整体系统的吞吐能力；能够异步

消息中间件的定义

面向消息的中间件（Message-Oriented Middleware）MOM 能够很好的解决以上问题

是指利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型在分布式环境下提供应用解耦、弹性伸缩、冗余存储、流量削峰、异步通信、数据同步等功能

大致的过程是这样的：

发送者把消息发送给消息服务器，消息服务器将消息存放在若干个队列 / 主题中，在合适的时候，消息服务器会将消息转发给接收者。在这个过程中，发送和接收是异步的，也就是发送无需等待，而且发送者和接收者的生命周期也没有必然关系；尤其在发布 pub / 订阅 sub 模式下，也可以完成一对多的通信，即让一个消息有多个接收者