RabbitMq整合Springboot超全实战案例+图文演示+源码自取

RabbitMQ 是一个开源的消息代理和队列服务器，用来通过封装复杂的分布式技术提供简单的消息队列功能。在 Spring Boot 应用中整合 RabbitMQ，可以使用 Spring AMQP 和 Spring Boot 的自动配置。

以下是一个简单的 Spring Boot 应用整合 RabbitMQ 的示例：

1. 添加依赖到 pom.xml：

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

2. 配置 application.properties：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

3. 创建配置类 RabbitMQConfig.java：

@Configuration
public class RabbitMQConfig {
 
    @Bean
    Queue queue() {
        return new Queue("testQueue", true);
    }
 
    @Bean
    DirectExchange exchange() {
        return new DirectExchange("testExchange");
    }
 
    @Bean
    Binding binding(Queue queue, DirectExchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with("testRoutingKey");
    }
}

4. 发送消息的服务 RabbitMQSender.java：

@Service
public class RabbitMQSender {
 
    @Autowired
    private RabbitTemplate rabbitTemplate;
 
    public void send(String message) {
        rabbitTemplate.convertAndSend("testExchange", "testRoutingKey", message);
    }
}

5. 接收消息的服务 RabbitMQReceiver.java：

@Component
@RabbitListener(queues = "testQueue")
public class RabbitMQReceiver {
 
    @RabbitHandler
    public void receive(String message) {
        System.out.println("Received <" + message + ">");
    }
}

6. 启动类 Application.java：

@SpringBootApplication
public class Application {
 
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

7. 使用发送服务发送消息：

@Autowired
private RabbitMQSender sender;
 
public void sendMessage() {
    sender.send("Hello, RabbitMQ!");
}

当你运行这个应用并调用 sendMessage() 方法时，它会通过 RabbitMQ 发送消息到名为 "testQueue" 的队列，并且 RabbitMQReceiver 会接收到消息并打印出来。

以上是一个简单的 RabbitMQ 与 Spring Boot 整合的示例，实际应用中可能需要更复杂的配置和逻辑，但基本概念是一致的。