Spring Boot项目集成RabbitMQ实战以及坑点讲解

Spring

为关注IT袋网网的网友们详解Spring的IT小经验，接下来分享详细内容。

本文给大家介绍一下在 Spring Boot 项目中如何集成消息队列 RabbitMQ，包含对 RibbitMQ 的架构介绍、应用场景、坑点解析以及代码实战。

我将使用waynboot-mall项目作为代码讲解，项目地址：https://github.com/wayn111/waynboot-mall。

本文大纲如下

RabbitMQ 架构介绍

RibbitMQ 是一个基于 AMQP 协议的开源消息队列系统，具有高性能、高可用、高扩展等特点。

通常作为在系统间传递消息的中间件，它可以实现异步处理、应用解耦、流量削峰等功能。

RibbitMQ 的主要组件介绍如下，

• producter：生产者，创建消息，然后将消息发布（发送）到 RabbitMQ。
• channel: 信道，多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的 TCP 连接内地虚拟链接，AMQP 命令都是通过信道发出去的，不管是发布消息、订阅队列还是接收消息，这些动作都是通过信道完成。因为对于操作系统来说，建立和销毁 TCP 都是非常昂贵的开销，所以引入了信道的概念，以复用一条 TCP 连接。
• broker: 标识消息队列服务器实体 rabbitmq-server。
• 连接器：这是负责接收客户端连接请求和建立连接的组件。RabbitMQ 支持多种连接器，如 AMQP 0-9-1, AMQP 1.0, MQTT, STOMP 等。
• v-host：虚拟主机，这是 RabbitMQ 的逻辑隔离单元，每个虚拟主机相当于一个独立的代理，拥有自己的交换器、队列、绑定、权限等。不同的虚拟主机之间是相互隔离的，不能共享资源。一个 RabbitMQ 实例可以创建多个虚拟主机，以满足不同的业务需求。
• exchange：交换机，这是负责接收生产者发送的消息，并根据路由规则将消息分发到相应的队列或者其他交换器的组件。RabbitMQ 支持多种类型的交换器，如 fanout, direct, topic, headers 等。
• binding：绑定，这是负责将交换器和队列之间建立关联关系的组件。绑定可以指定一个路由键或者模式匹配规则，以决定哪些消息可以被路由到哪些队列。
• queue：队列，这是负责存储消费者需要消费的消息的组件。队列可以有多种属性和特性，如持久化、排他性、自动删除、死信队列、优先级队列等。队列可以绑定到一个或多个交换器上，并指定一个或多个路由键或者模式匹配规则。
• consuemer：消费者，连接到 RabbitMQ 服务器，并订阅到队列上，接收来自队列的消息。

应用场景