服务异步通信--RabbitMQ

深碍√TFBOYSˉ_ 2024-03-25 11:40 56阅读 0赞

黑马- SpringCloud微服务技术栈 项目中设计到的服务异步通信，项目部署成功，知识介绍全面。

### 项目梳理 ###

1.  知识点是按照集数依次整理，方便日后回来查找。
2.  考虑到不是固定的联网方式，时而WiFi，时而热点，配置静态IP会导致每次网络变更后都需要重新配置，所以虚拟机使用的动态路由，当需要运行相关程序时，IP变化，只需要修改yml文件里的配置即可。
3.  将代码路径列举主要是为后续审查。
4.  mq的代码路径`E:\微服务\实用篇\day04-MQ\资料\mq-demo`。

#### 异步通信 ####

1.  **MQ**–RabbitMQ–SpringAMQP（P61）
2.  **同步调用**–优点：时效性较强，可以立即得到结果；缺点：耦合度高、性能和吞吐能力下降、有额外的资源消耗、有级联失败问题。
3.  **异步调用**的实现-事件驱动优势，事件驱动架构-Broker。
4.  异步通信–优点：耦合度低、吞吐量提升、故障隔离、流量削峰；缺点：依赖于Broker的可靠性、安全性、吞吐能力、架构复杂了，业务没有明显的流程线，不好追踪管理。
5.  MQ（MessageQueue）：消息队列，存放消息的队列。
6.  RabbitMQ、ActiveMQ、RocketMQ、Kafka的对比分析。（P64）
7.  **RabbitMQ**–部署安装、页面介绍、结构和概念。

# 在线拉取
    docker pull rabbitmq:3-management
    # 上传好tar包，命令加载镜像
    docker load -i mq.tar
    # 运行MQ容器
    docker run \
     -e RABBITMQ_DEFAULT_USER=itcast \
     -e RABBITMQ_DEFAULT_PASS=123321 \
     --name mq \
     --hostname mq1 \
     -p 15672:15672 \
     -p 5672:5672 \
     -d \
     rabbitmq:3-management
     # 查看全部容器
     docker ps -a
     # 重启后重启容器
    docker start mq

1.  RabbitMQ部署成功后页面元素分析–channel：操作MQ的工具、exchange：路由消息到队列、queue：缓存消息、virtual host：虚拟主机，是对queue、exchange等资源的逻辑分组。
2.  RabbitMQ入门案例–简单队列模型。官方文档-入门案例-publisher：消息发布者，将消息发送到队列；queue：消息队列，负责接收并缓存消息；consumer：订阅队列，处理队列中的消息。
3.  基本消息队列的消息发送流程和基本消息队列的消息接收流程。（P67）
4.  **SpringAMQP**–基于AMQP协议定义的一套API规范，提供模板来发送和接受消息；AMQP介绍–应用间消息通信的一种协议，与语言和平台无关。
5.  **简单队列模型**–利用SpringAMQP实现HelloWorld的基础消息队列功能–引入amqp的starter依赖；配置RabbitMQ地址；利用RabbitTemplate的convertAndSend方法来发送消息。（P67）
6.  Work queue–工作队列，可以提高消息处理速度，避免队列消息堆积-默认为：消息预取。
7.  **Work模型**–多个消费者绑定到一个队列，同一条消息只会被一个消费者处理；通过设置prefetch来控制消费者预取的消息数量。（P71）
8.  **发布、订阅模型**–允许将同一消息发送给多个消费者。实现方式是加入了exchange（交换机）；exchange类型-Fanout：广播、Direct：路由、Topic：话题。（P72）
9.  exchange（交换机）作用–接收publisher发送的消息；将消息按照规则路由到与之绑定的队列；负责消息路由，而不是存储，路由失败则消息丢失。
10. Fanout Exchange–将接收到的消息路由到每一个跟其绑定的queue。
11. Direct Exchange–**路由模式**会将接收到的消息根据规则路由到指定的Queue（每一个Queue都与Exchange设置一个BindingKey）；发布者发送消息时，指定消息的RoutingKey；Exchange将消息路由到BindingKey与消息RoutingKey一致的队列。（P74）
12. TopicExchange–与Direct Exchange类似，区别在于routingKey必须是多个单词的列表，并且以 **.** 分割；Queue与Exchange指定BindingKey时可以使用通配符：\#-代指0个或多个单词；\*：代指一个单词。
13. 消息转换器–SpringAMQP中消息的反序列化和反序列化-利用MessageConverter实现的，默认是JDK的序列化；注意发送方与接收方必须使用相同的MessageConverter。

`->微服务技术栈异步通信课程视频`

https://www.bilibili.com/video/BV1LQ4y127n4?p=61

`<-`

`学习整理笔记，记录每一个学习瞬间`