当前位置：首页 > ds >正文

SpringBoot基于RabbitMQ实现异步请求处理

ds 2025/7/16 17:42:46

概述

本文档介绍如何在SpringBoot中实现基于RabbitMQ的异步处理架构，以提高系统并发处理能力。

架构设计

接口层: 接收请求并进行数据校验
消息队列: 使用RabbitMQ进行异步处理
业务层: 执行具体的数据库交互逻辑

1. 项目依赖配置

Maven依赖

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-validation</artifactId></dependency>
</dependencies>

配置文件

spring:rabbitmq:# RabbitMQ 服务器的基础连接信息host: localhost           # RabbitMQ 服务器的主机地址，默认为本机port: 5672                # RabbitMQ 服务器的端口号，非管理界面端口（默认是5672）username: guest           # 登录 RabbitMQ 的用户名，默认为 guestpassword: guest           # 登录 RabbitMQ 的密码，默认为 guestvirtual-host: /           # 使用的虚拟主机，默认为 "/"listener:simple:concurrency: 5          # 初始消费者数量，即启动时创建的消费者线程数max-concurrency: 10     # 最大消费者数量，用于动态扩展时的最大并发消费者数prefetch: 10            # 每个消费者一次从队列中预取的消息数量，用于控制消息的消费速率acknowledge-mode: auto  # 消息确认模式，auto 表示自动确认（适用于大多数场景），manual 需要手动调用确认template:retry:enabled: true           # 开启 RabbitTemplate 发送消息时的重试机制initial-interval: 1000   # 初始重试间隔时间，单位为毫秒（第一次失败后等待1秒重试）max-attempts: 3         # 最大重试次数（包括首次发送，共尝试3次）

2. RabbitMQ配置

RabbitConfig.java

package com.erp.common.config;import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.amqp.rabbit.annotation.EnableRabbit;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.Binding;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** RabbitMQ配置类，用于定义消息队列、交换机和绑定关系*/
@Configuration
@EnableRabbit
public class RabbitConfig {// 定义业务队列的名称public static final String BUSINESS_QUEUE = "busine