分布式、中间件和消息队列

From今日头条：https://www.wukong.com/answer/6534675344568353032/?iid=28070358035&app=news_article&share_ansid=6534675344568353032&wxshare_count=1&tt_from=weixin&utm_source=weixin&utm_medium=toutiao_android&utm_campaign=client_share

一、分布式

相对以前单一系统，所有功能、服务都部署在一台服务器上，一挂全挂！

分布式采用了把系统提供的服务分布在不同的服务器上的策略，这样的架构就叫做分布式架构！

【一个业务被拆成多个子业务，部署在多台服务器上，这个就叫做分布式】

　　　　　　　　　　　　    【分布式架构图】

实例：

我有一个系统A，提供一个很简单的接口，根据员工编号查询员工姓名和他的考勤记录。

我拆开两个系统：人员管理系统B和考勤系统C，分别部署在两台服务器上。

这个需求，需要调用一下系统B，再调用一下系统C，最后得到需要的结果。

这个就是分布式。

分布式架构优势：

1，单个服务宕机不影响别的服务正常运行！

2，单个节点所有的负载分布均衡到了多台服务器上！

3，各服务之间相互透明，实现解耦！

注意：

分布之后问题来了，以前的单一系统，所有服务都在同一个机器，在同一个内存里面，直接调用即可；

但现在分布在不同的jvm中，怎么调用呢？或者说数据怎么传输？ --消息中间件应运而生！

二 、中间件

中间件：将具体业务和底层逻辑解耦的软件

目前应用较多消息队列有ActiveMQ，RabbitMQ，Kafka，RocketMQ，ons，它们又可以被称作是消息中间件。

消息中间件解决的就是分布式系统之间消息传递的问题。

1，生产者和消费者之间通过某种方式（点对点或者订阅）实现"绑定"！

2，生产者生产数据，并发送到消息中间件，消息中间件进行落库处理！

3，订阅了消息的消费者通过监听器监听消息中间件，如果有属于自己的消息，进行消费！

注：整个过程中间会有数据一致性问题，怎么解决呢？

【1】保证生产消息到消息中间件的时候进行返回值确认保证这一步的数据一致

【2】在消息到消费者的时候保证返回正确结果即可，如果中间出现异常可进行重试，或者发邮件等

         到此，分布式系统的数据传递通过消息中间件解决了！

但分布式还有如session、日志处理、单点登录等各服务器需要相同数据的问题，可通过接到同一个redis缓存进行处理！

分布式服务的配置文件可以通过统一的文件配置中心统一处理！

添加服务注册和发现，还有服务宕机的监控处理！

例子：

我要开一家炸鸡店（业务端），需要鸡肉，有很多养鸡场（底层），我需要一个一个比较价钱，然后找一家性价比高的养鸡场合作（适配不同底层逻辑）。可能一段时间后，我需要重新选一家养鸡场合作，进货方式、交易方式等要重新制定（重新适配）。

这一套事情太复杂了，于是我找到了一个专门整合养鸡场的第三方代理（中间件），跟他谈好价格和质量后（统一接口），以后我就只需要给代理钱，然后拿肉就行。具体这个第三方代理怎么操作，我不用管。

三、消息队列

消息队列可以看做内存中的队列，有人往里放消息，有人从里取消息。

1、Producer：消息生产者

2、Broker：消息处理中心，负责消息存储、确认、重试等

3、Consumer：消息消费者

消息队列的特点是：异步、解耦、可靠性（消息队列一般会把接收到的消息持久化到本地硬盘上）

例子：

我是做网上商城的，有一个短信系统，当客户下了一个订单之后，通知客户你下单成功。

当订单量比较小的时候，只需要调用发送短信的接口就可以了。

但是如果订单量大了之后呢，并且短信发送晚个一两分钟也没有什么问题，那么就可以使用消息中间件：把待发送的短信发送到消息队列里面，短信系统从消息队列中取出短信进行发送就可以了。

而且还有一个好处：如果短信系统挂掉了，短信消息保存在消息中间件里面不会丢失，等短信系统恢复了之后，继续短信发送即可。