消息中间件的选择：RabbitMQ是一个明智的选择

ゞ浴缸里的玫瑰 2024-04-22 19:02 80阅读 0赞

![在这里插入图片描述][acb8a7e0bf334001af9f95d515c4f452.gif_pic_center]

> [?wei\_shuo的个人主页][wei_shuo]
> 
> ?[wei\_shuo的学习社区][wei_shuo 1]
> 
> ?Hello World ！

--------------------

### MQ（Message Queue） ###

> MQ（消息队列）是一种用于在应用程序之间进行异步通信的技术；允许应用程序通过发送和接收消息来进行解耦和协同工作
> 
> 消息生产者（Producer）：负责创建和发送消息到消息队列中；它将消息发送到指定的队列或主题
> 
> 消息队列（Message Queue）：是消息的缓冲区，用于存储生产者发送的消息；消息队列可以采用不同的模式，如点对点（Point-to-Point）和发布/订阅（Publish/Subscribe）模式
> 
> 消息消费者（Consumer）：负责从消息队列中接收和处理消息；消费者可以订阅一个队列或主题，并从中接收消息

![在这里插入图片描述][531186f76d084edc97b55d7b1fa79248.png_pic_center]

#### RabbitMQ ####

![在这里插入图片描述][0ecdd1cea15c4b18987f80a6c232a4b6.png_pic_center]

> RabbitMQ是一个开源的消息队列系统，它实现了高级消息队列协议（AMQP）标准；RabbitMQ提供了可靠的消息传递机制，使应用程序能够在分布式系统中进行可靠的异步通信

#### SpringAMQP ####

![在这里插入图片描述][055d802b65b5429eb09f8154412a8e0a.png_pic_center]

> Spring AMQP是一个基于Spring框架的开源项目，用于简化使用AMQP（高级消息队列协议）的应用程序的开发；它提供了与AMQP兼容的消息传递的抽象和封装，使开发人员能够更轻松地使用消息队列系统，如RabbitMQ
> 
>  *  用于异步处理入站消息的侦听器容器
>  *  用于发送和接收消息的RabbitTemplate
>  *  RabbitAdmin用于自动声明队列，交换和绑定

>  *  消息（Message）：在RabbitMQ中，消息是信息的载体，可以是任何形式的数据。它通常包含一个消息体和一些可选的属性；消息可以由生产者发布到交换机，然后由交换机路由到一个或多个队列中
>  *  交换机（Exchange）：交换机是消息的分发中心；它接收生产者发布的消息，并根据预定义的路由规则将消息路由到一个或多个队列中；RabbitMQ提供了几种类型的交换机，包括直连交换机（direct）、主题交换机（topic）、扇形交换机（fanout）和标头交换机（headers），以满足不同的消息路由需求
>  *  队列（Queue）：队列是消息的缓冲区，用于存储交换机发送过来的消息。消费者可以从队列中订阅并获取消息进行处理；RabbitMQ支持多个消费者同时订阅同一个队列，采用竞争消费模式
>  *  绑定（Binding）：绑定是交换机和队列之间的关联关系。它定义了消息从交换机路由到哪些队列中；绑定通常包括一个交换机名称、一个队列名称和一个路由键（Routing Key）；路由键在直连交换机和主题交换机中起到关键作用，用于匹配消息和队列
>  *  生产者（Producer）：生产者是消息的发送者，它将消息发布到RabbitMQ的交换机中；生产者可以选择指定消息的交换机、路由键和其他属性
>  *  消费者（Consumer）：消费者是消息的接收者，它从队列中订阅并获取消息进行处理；消费者可以选择指定要消费的队列，并可以设置消息的确认机制、并发控制
>  *  虚拟主机（Virtual Host）：虚拟主机提供了逻辑上的隔离，允许在同一个RabbitMQ服务器上创建多个独立的消息代理；每个虚拟主机都有自己的交换机、队列和权限控制
>  *  持久化（Durability）：RabbitMQ支持将交换机和队列设置为持久化，以确保在服务器重启或崩溃后仍然存在；持久化的消息也可以在重启后恢复
>  *  消息确认（Message Acknowledgment）：消费者可以使用消息确认机制来确保消息被成功处理；一旦消费者确认接收到消息并完成处理，RabbitMQ将从队列中删除该消息；如果消费者在处理消息时发生错误，消息可以重新投递或进入死信队列
>  *  高可用性和可扩展性：RabbitMQ支持集群部署，通过在多个节点上复制队列和交换机来提供高可用性和可扩展性；集群中的节点可以相互同步消息和状态，以实现负载均衡和故障转移

--------------------

> ? 结语：创作不易，如果觉得博主的文章赏心悦目，还请——`点赞`?`收藏`⭐️`评论`?

--------------------

![在这里插入图片描述][d3ab6ddb82c2490abc1a7836a1dc557c.gif_pic_center]

[acb8a7e0bf334001af9f95d515c4f452.gif_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/22/47f2409ceac04c9fa821a640f1e00787.gif
[wei_shuo]: https://blog.csdn.net/weixin_62765017
[wei_shuo 1]: https://bbs.csdn.net/forums/wei_shuo_study
[531186f76d084edc97b55d7b1fa79248.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/22/899623a8bb824f58b2c6248d3daff645.png
[0ecdd1cea15c4b18987f80a6c232a4b6.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/22/d794c3acf69449289e5f87642f95415c.png
[055d802b65b5429eb09f8154412a8e0a.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/22/a185204bdb684ff59be58ebd82fcc60b.png
[d3ab6ddb82c2490abc1a7836a1dc557c.gif_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/22/4ba0048e578b4873b0311ba4e858e9e0.gif