同步调用存在的问题
1.耦合度高
每次加入新的需求，都要修改原来的代码
2.性能下降
调用者需要等待服务提供者响应，如果调用链过长则响应时间等于每次调用的时间之和。
3.资源浪费
调用链中的每个服务在等待响应过程中，不能释放请求占用的资源，高并发场景下会极度浪费系统资源。
4.级联失败
如果服务提供者出现问题，所有调用
异步调用方案
异步调用常见实现就是事件驱动模式
优势二：性能提升，吞吐量提高
优势三：服务没有强依赖，不担心级联失败问题
优势四：流量削峰
万一秒钟来了几万个访问，流量都被Broker挡住，这样压力就小了很多。
异步通信的优点：
耦合度低
吞吐量提升
故障隔离
流量削峰
异步通信的缺点：
依赖于Broker的可靠性、安全性、吞吐能力
架构复杂了，业务没有明显的流程线，不好追踪管理
什么是MQ
MQ，中文是消息队列，字面来看就是存放消息的队列。也就是事件驱动架构中的Broker。
Connections就是连接，不论是消费者还是提供者都应该创建连接，
Channels
Exchanges就是交换机
因为虚拟主机不同，所以被隔离开了
RabbitMQ中的几个概念：
channel：操作MQ的工具
exchange：路由消息到队列中
queue：缓存消息
Virtual host：虚拟主机，是对queue、exchange等资源的逻辑分组
常见消息模型
MQ的官方文档中给出了5个MQ的demo示例，对应了几种不同的用法：
基本消息队列（BasicQueue）
工作消息队列（WorkQueue）
发布订阅，又根据交换机类型不同分为三种：
Fanout Exchange：广播
Direct Exchange：路由
Topic Exchange：主题
官方的HelloWorld是基于最基础的消息队列模型来实现的，只包括三个角色：
publisher：消息发布者，将消息发送到队列queue
queue：消息队列，负责接受并缓存消息
consumer：订阅队列，处理队列中的消息
基本消息队列的消息发送流程：
1.建立connection
2.创建channel
3.利用channel声明队列
4.利用channel向队列发送消息
基本消息队列的消息接收流程
1.建立connection
2.创建channel
3.利用channel声明队列
4.定义consumer的消费行为handleDelivery()
5.利用channel将消费者与队列绑定
MQ 队列的消息一旦被接收马上被销毁，阅后即焚。
idea里面dbug可以看到，执行了订阅代码之后，不管有没有收到消息，我继续往下执行。
AMQP,是在应用程序或之间传递业务消息的开放标准。该协议与语言和平台无关，更符合微服务中独立性的要求。
Spring AMQP是基于AMQP协议定义的一套API规范，提供了模板来发送和接收消息。包含两部分，其中spring-amqp是基础抽象，spring-rabbit是底层的默认实现。
利用SpringAMQP实现HelloWorld中的基础消息队列功能
流程如下
1.在父工程中引入spring-amqp的依赖
2.在publisher服务中利用RabbitTemplate发送消息到simple.queue这个队列
什么是AMQP？
应用间消息通信的一种协议，与语言和平台无关。
SpringAMQP如何发送消息？
引入amqp的starter依赖
配置RabbitMQ地址
利用RabbitTemplate的convertAndSend方法
SpringAMQP如何接收消息？
引入依赖
配置RabbitMQ地址
定义类，添加@Component注解
类中声明方法，添加@RabbitListener注解，方法参数就时消息
注意：消息一旦消费就会从队列删除，RabiitMQ没有消息回溯功能
模拟WorkQueue，实现一个队列绑定多个消费者
基本思路如下：
1、在publisher服务中定义测试方法，每秒产生50条消息，发送到simple.queue
2、在consumer服务中定义两个消息监听者，都监听simple.queue队列
3.消费者1每秒处理50条消息，消费者2每秒处理10条消息
MQ默认是消费者轮流去取消息的，这样一来可能会导致效率降低。为了解决这个问题，我们要对工作能力更强的消费者分配更多的任务。
发布（publish）、订阅（Subscribe)
发布订阅模式与之前案例的区别就是允许将同一消息发送给多个消费者。实现方式是加入了exchange（交换机）。
注意：exchange负责消息路由，而不是存储，路由失败则消息丢失。
Fanout Exchange 会将接收到的消息路由到每一个跟其绑定的queue
利用SpringAMQP演示FanoutExchange的使用
实现思路如下：
1.在consumer服务中，利用代码声明队列、交换机，并将两者绑定
2.在consumer服务中，编写两个消费者方法，分别监听fanout.queue1和fanout.queue2
3.在publisher中编写测试方法，向itcast.fanout发送消息
交换机的作用是什么？
接收publisher发送的消息
将消息按照规则路由到与之绑定的队列
不能缓存消息，路由失败，消息丢失
FanoutExchange的会将消息路由到每个绑定的队列
声明队列、交换机、绑定关系的bean是什么？
指定交换机的名称和消息即可发送信息。
交换机的作用是什么？
接收publisher发送的消息
将消息按照规则路由到与之绑定的队列
不能缓存消息，路由失败，消息丢失
FanoutExchange的会将消息路由到每个绑定的队列
声明队列、交换机、绑定关系的Bean是什么？
Direct Exchange会将接收到的消息根据规则路由到指定的Queeue，因此称为路由模式（routes）。
每一个Queue都与Exchange设置一个Bindingkey
发布者发送消息时，指定小的Routingkey。
Exchange将消息路由到Bindingkey与消息Routingkey一致的队列
描述下Direct交换机与Fanout交换机的差异？
Fanout交换机将消息路由给每一个与之绑定的队列
Direct交换机根据Routingkey判断路由给哪个队列
如果多个队列具有相同的Rountingkey，则与Fanout功能类似
基于@RabbitListener注解声明队列和交换机有哪些常见注解？
TopicExchange是以单词为区分的，比如china.# 就是china....后面不论什么都要。以“.”分隔
测试发送Object类型消息
说明： 在SpringAMQP的发送方法中，接收消息的类型是Object，也就是说我们可以发送任意对象类型的消息，SpringAMQP会帮我们序列化为字节后发送。
不管我们发送的是什么类型的数据，SpringAMQP都会帮我们序列化为字节后发送
SpringAMQP中消息的序列化和反序列化是怎么实现的？
利用MessageConverter实现的，默认是JDK的序列化
注意发送方与接收方必须使用相同的MessageConverter
