1. RabbitMQ简介

RabbitMQ是由erlang语言开发，基于AMQP（高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开发中应用非常广泛。
RabbitMQ官方地址：http://www.rabbitmq.com

1.1 消息队列

MQ全称为Message Queue，即消息队列。
“消息队列”是在消息的传输过程中保存消息的容器。它是典型的：生产者、消费者模型。生产者不断向消息队列中生产消息，消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的，而且只关心消息的发送和接收，没有业务逻辑的侵入，这样就实现了生产者和消费者的解耦。

1.2 消息队列使用场景

• 任务异步处理：
  高并发环境下，由于来不及同步处理，请求往往会发生堵塞。我们可以异步处理请求，从而缓解系统的压力。将不需要同步处理的并且耗时长的操作由消息队列通知消息接收方进行异步处理。减少了应用程序的响应时间。

• 应用程序解耦合：
  MQ相当于一个中介，生产方通过MQ与消费方交互，它将应用程序进行解耦合，不至于功能里面的某一个操作宕机后导致后续操作无法进行。
  
  
  
  
  

2. 为什么要学习RabbitMQ

先来看下面一个电商项目的场景：
??商品的原始数据保存在数据库中，增删改查都在数据库中完成。
??搜索服务数据来源是索引库（Elasticsearch），如果数据库商品发生变化，索引库数据不能及时更新。
??商品详情做了页面静态化处理，静态页面数据也不会随着数据库商品更新而变化。
??如果我们在后台修改了商品的价格，搜索页面和商品详情页显示的依然是旧的价格，这样显然不对。该如何解决？

我们可能会想到这么做：
??方案1：每当后台对商品做增删改操作，同时修改索引库数据及更新静态页面。
??方案2：搜索服务和商品页面静态化服务对外提供操作接口，后台在商品增删改后，调用接口。 
这两种方案都有个严重的问题：就是代码耦合，后台服务中需要嵌入搜索和商品页面服务，违背了微服务的独立原则。

这时，我们就会采用另外一种解决办法，那就是消息队列：
??商品服务对商品增删改以后，无需去操作索引库和静态页面，只需向MQ发送一条消息（比如包含商品id的消息），也不关心消息被谁接收。 搜索服务和静态页面服务监听MQ，接收消息，然后分别去处理索引库和静态页面（根据商品id去更新索引库和商品详情静态页面）。 

3. 常见MQ产品

• ActiveMQ：基于JMS
• RabbitMQ：基于AMQP协议，erlang语言开发，稳定性好
• RocketMQ：基于JMS，阿里巴巴产品，目前交由Apache基金会
• Kafka：分布式消息系统，高吞吐量
  语言的支持：ActiveMQ，RocketMQ只支持Java语言，Kafka可以支持多们语言，RabbitMQ支持多种语言
  效率方面：ActiveMQ，RocketMQ，Kafka效率都是毫秒级别，RabbitMQ是微秒级别的
  消息丢失，消息重复问题： RabbitMQ针对消息的持久化，和重复问题都有比较成熟的解决方案
  
  
  
  

4. RabbitMQ架构

4.1 简单架构图

RabbitMQ详解

原文：https://www.cnblogs.com/itlihao/p/14630396.html