Spring Boot 集成 RabbitMQ(一)

1、RabbitMQ 和 SpringBoot 的基础概念

RabbitMQ 是一个开源的 MQ (Message Queue,消息队列) 客户端服务器实现,遵循 AMQP(Advanced Message Queuing Protocol)协议。它允许应用发送消息并不直接传递到目标对象,而是通过交换器,队列,绑定的方式进行处理和转发,从而实现应用的解耦,异步并且能够确保可靠性。

Spring Boot 是由 Pivotal 团队提供的全新框架,用于简化 Spring 应用的初始搭建以及开发过程。该框架使用了特定的方式来进行配置,从而使开发人员不再需要定义模板化的配置,简化了开发流程。

2、为何需要 SpringBoot 和 RabbitMQ,它们能带来什么好处 ?

  引入 Spring Boot 和 RabbitMQ 的优势主要体现在以下方面:

  • 解耦:不同的服务之间通过消息队列进行通信,降低了系统的耦合度。
  • 异步:消息生产者向队列中发送消息后,不需要同步等待消费者处理完成。
  • 增强可靠性:通过消息确认机制确保消息的成功投递。
  • 削峰填谷:在高并发情况下,消息生产者的生产能力可能远大于消费者的处理能力,消息队列可以作为一个缓冲,存储这些消息等待消费者消费。

3、SpringBoot 和 RabbitMQ 的工作原理介绍

 Spring Boot 通过自动配置、独立运行的方式,极大的简化了 Spring 应用的开发。在 Spring Boot 的核心设计中,存在四个重要的原则:

  • 开箱即用:Spring Boot 微服务的 jar 包可以直接运行
  • 提供种类丰富的“starter”依赖,简化 Maven 配置
  • 无需任何 XML 配置
  • 提供一系列大型项目中常见的非功能性特性,如安全、指标收集

RabbitMQ 则是典型的生产者-消费者模型,其工作原理包括三个重要的阶段:

  • 生产者生成消息:生产者产生数据后作为消息发送到 RabbitMQ。
  • 消息存储:RabbitMQ 将来自生产者的消息暂存在队列中,等待消费者来接收。
  • 消费者接收消息:一个或多个消费者连接到消息队列中,等待消息到来。当消息到达时,消费者从队列中获取消息并进行处理。

使用 Spring Boot 集成 RabbitMQ,我们可以轻易地创建出生产者和消费者,通过注解和配置的方式使用 RabbitMQ 的强大功能。

在 SpringBoot 中集成 RabbitMQ,您需要遵循以下步骤:

  1. 首先,您需要在您的计算机上安装 RabbitMQ。这就像在您的系统中安装任何软件一样。您可以从 RabbitMQ 官方网站 下载安装包进行安装。

  2. 然后,在 SpringBoot 项目中添加 RabbitMQ 的依赖。假设您正在使用 Maven,那么您需要在 pom.xml 文件中添加以下依赖:

xml

<dependencies>
    <!-- 添加 Spring Boot 的 RabbitMQ starter -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
</dependencies>
  1. 接下来,配置 RabbitMQ。您需要在 application.properties 或者 application.yml 文件中添加 RabbitMQ 的相关配置,以下是一个样例配置:
# RabbitMQ 的主机名或 IP 地址
spring.rabbitmq.host=localhost

# RabbitMQ的端口号,默认为5672
spring.rabbitmq.port=5672

# RabbitMQ 的用户名
spring.rabbitmq.username=guest

# RabbitMQ 的密码
spring.rabbitmq.password=guest

# RabbitMQ 的 virtual host,用于隔离连接、交换器和队列, 默认为"/"
spring.rabbitmq.virtual-host=/

以上即是 SpringBoot 集成 RabbitMQ 的基本步骤。

需要注意的是,以下为您可能需要的一些额外配置选项:

  • spring.rabbitmq.publisher-confirm-type:消息发送到交换器Exchange后触发回调的类型,可以设置为:none、simple、correlated。
  • spring.rabbitmq.publisher-returns:当消息无法路由到队列时,是否返回给生产者,它需要和spring.rabbitmq.template.mandatory 一起使用。
  • spring.rabbitmq.template.mandatory:当消息无法路由到队列从而返回给生产者时,需要设置 mandatory 为 true,否则不会返回。
  • spring.rabbitmq.listener.simple.acknowledge-mode:消费者的确认模式,默认为自动确认,有三种:NONE、MANUAL、AUTO。

相关推荐

  1. Springboot集成Rabbitmq

    2024-04-05 06:10:04       32 阅读
  2. SpringBoot集成RabbitMQ

    2024-04-05 06:10:04       41 阅读
  3. SpringBoot集成rabbitMq

    2024-04-05 06:10:04       40 阅读
  4. Spring Boot 集成 RabbitMQ()

    2024-04-05 06:10:04       36 阅读
  5. Springboot 集成Rabbitmq之延时队列

    2024-04-05 06:10:04       33 阅读

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2024-04-05 06:10:04       94 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2024-04-05 06:10:04       100 阅读
  3. 在Django里面运行非项目文件

    2024-04-05 06:10:04       82 阅读
  4. Python语言-面向对象

    2024-04-05 06:10:04       91 阅读

热门阅读

  1. Day2-Hive的多字段分区,分桶和数据类型

    2024-04-05 06:10:04       38 阅读
  2. 自动化分享----pywinauto

    2024-04-05 06:10:04       38 阅读
  3. ansible安装

    2024-04-05 06:10:04       36 阅读
  4. 每日一题 --- 滑动窗口最大值[力扣][Go]

    2024-04-05 06:10:04       38 阅读
  5. MCU 与 SoC 的主要区别

    2024-04-05 06:10:04       26 阅读
  6. postcss安装与使用

    2024-04-05 06:10:04       32 阅读
  7. Elasticsearch 8.x ELK 搭建并配置 SSL

    2024-04-05 06:10:04       31 阅读