day06-购物车优化 - 《项目四：点餐系统》

使用MQ的前提：请求不要求立即得到执行结果

使用MQ进行解耦，商品服务把提供的数据发送到RabbitMQ中，搜索服务、订单服务、库存服务之需要从对应的队列中拉取所以需要的数据即可，二不需要强依赖与商品服务

由串行执行变为异步执行，提高代码执行效率；

服务即便宕机不会影响主体业务使用

消息在队列中等待，服务器可根据性能逐步消费

Kafka 最开始就是专门为了处理日志产生的。

MQ在项目中的问题：当要在项目中替换MQ类型时，如从rabbitMq转为RoocketMq
1、开发人员的学习成本和项目开发的成本
2、系统和MQ之间的耦合

解决方法：
在项目中，我们使用SpringCloude Stream 来整合各类消息中间件，降低系统和中间件的耦合性。

组成	说明
Middleware	中间件，支持 RabbitMQ、Kafka、RocketMQ等。
Binder	目标绑定器，目标指的是 Kafka 还是 RabbitMQ。绑定器就是封装了目标中间件的包。如果操作的是 Kafka 就使用 spring-cloud-stream-binder-kafka，如果操作的是 RabbitMQ 就使用 spring-cloud-stream-binder-rabbit。
@Input	注解标识输入通道，接收（消息消费者）的消息将通过该通道进入应用程序。
@Output	注解标识输出通道，发布（消息生产者）的消息将通过该通道离开应用程序。
@StreamListener	监听队列，消费者的队列的消息接收。
@EnableBinding	注解标识绑定，将信道 channel 和交换机 exchange 绑定在一起。

该模型图中有如下几个核心概念：

Source：当需要发送消息时，我们就需要通过 Source.java，它会把我们所要发送的消息进行序列化（默认转换成 JSON 格式字符串），然后将这些数据发送到 Channel 中；
Sink：当我们需要监听消息时就需要通过 Sink.java，它负责从消息通道中获取消息，并将消息反序列化成消息对象，然后交给具体的消息监听处理；
Channel：通常我们向消息中间件发送消息或者监听消息时需要指定主题（Topic）和消息队列名称，一旦我们需要变更主题的时候就需要修改消息发送或消息监听的代码。通过 Channel 对象，我们的业务代码只需要对应 Channel 就可以了，具体这个 Channel 对应的是哪个主题，可以在配置文件中来指定，这样当主题变更的时候我们就不用对代码做任何修改，从而实现了与具体消息中间件的解耦；
Binder：通过不同的 Binder 可以实现与不同的消息中间件整合，Binder 提供统一的消息收发接口，从而使得我们可以根据实际需要部署不同的消息中间件，或者根据实际生产中所部署的消息中间件来调整我们的配置。