Spring Cloud 集成 RabbitMQ

Spring Cloud 整合 RabbitMQ 主要涉及到配置和使用 spring-cloud-starter-stream-rabbit 依赖。以下是一个基本的配置示例和使用 RabbitTemplate 发送和接收消息的代码示例。

1. 添加 Maven 依赖到你的 pom.xml 文件：

<dependencies>
    <!-- Spring Cloud Stream RabbitMQ Binder -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
    </dependency>
</dependencies>
 
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Finchley.SR2</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

2. 在 application.yml 或 application.properties 中配置 RabbitMQ 连接：

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

3. 使用 RabbitTemplate 发送消息：

@Autowired
private RabbitTemplate rabbitTemplate;
 
public void sendMessage(String queueName, String message) {
    rabbitTemplate.convertAndSend(queueName, message);
}

4. 使用 @EnableBinding 注解创建消息通道并使用 @StreamListener 注解来监听消息：

@EnableBinding(value = {Processor.class})
public class MessageReceiver {
 
    @StreamListener(Processor.INPUT)
    public void receive(String payload) {
        System.out.println("Received: " + payload);
    }
}

以上代码展示了如何在 Spring Cloud 应用中整合 RabbitMQ，并使用 RabbitTemplate 发送和接收消息。记得替换 host, port, username, password 等配置以匹配你的 RabbitMQ 服务器信息。