Spring Cloud 集成 RabbitMQ：快速入门指南

Spring Cloud 提供了对 RabbitMQ 的支持，可以通过 Spring Boot 的自动配置来轻松地集成 RabbitMQ。

添加依赖

在 pom.xml 文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>

配置 RabbitMQ 连接信息

在 application.properties 文件中添加以下配置：

spring.rabbitmq.host=your-rabbitmq-host
spring.rabbitmq.port=your-rabbitmq-port
spring.rabbitmq.username=your-rabbitmq-username
spring.rabbitmq.password=your-rabbitmq-password

创建消息生产者

使用 @EnableBinding 注解启用绑定功能，并使用 @Output 注解定义输出通道：

@EnableBinding(Source.class)
public class MessageProducer {

    @Autowired
    private MessageChannel output;

    public void sendMessage(String message) {
        output.send(MessageBuilder.withPayload(message).build());
    }
}

创建消息消费者

使用 @EnableBinding 注解启用绑定功能，并使用 @Input 注解定义输入通道：

@EnableBinding(Sink.class)
public class MessageConsumer {

    @StreamListener(Sink.INPUT)
    public void receiveMessage(String message) {
        System.out.println('Received message: ' + message);
    }
}

测试

使用 MessageProducer 发送消息，MessageConsumer 接收消息并打印输出。

@Autowired
private MessageProducer producer;

@Test
public void testSendMessage() {
    producer.sendMessage('Hello, RabbitMQ!');
}

以上就是使用 Spring Cloud 整合 RabbitMQ 的步骤。