Spring Cloud 整合 RabbitMQ 主要涉及到配置和使用 spring-cloud-starter-stream-rabbit 依赖。以下是一个基本的配置示例和使用 RabbitTemplate 发送和接收消息的代码示例。
- 添加 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>
- 在
application.yml 或 application.properties 中配置 RabbitMQ 连接：
spring:
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
- 使用 RabbitTemplate 发送消息：
@Autowired
private RabbitTemplate rabbitTemplate;
public void sendMessage(String queueName, String message) {
rabbitTemplate.convertAndSend(queueName, message);
}
- 使用
@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 服务器信息。