springcloud 集成rabbitmq

以下是在Spring Cloud中使用RabbitMQ的基本步骤：

1. 引入依赖：在pom.xml文件中引入以下依赖：

<dependency>  
 
     <groupId>org.springframework.cloud</groupId>  
 
     <artifactId>spring-cloud-starter-bus-amqp</artifactId>  
 
 </dependency>  
 
 <dependency>  
 
     <groupId>org.springframework.boot</groupId>  
 
     <artifactId>spring-boot-starter-amqp</artifactId>  
 
 </dependency>

2. 配置RabbitMQ：在application.properties或application.yml文件中配置RabbitMQ的相关属性，例如：

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

3. 创建消息代理：创建一个消息代理，用于发送和接收消息。例如：

@Configuration  
 
 public class MessageConfig {  
 
    
 
     @Bean  
 
     public MessageChannel messageChannel() {  
 
         return new DirectChannel();  
 
     }  
 
    
 
     @Bean  
 
     public MessageProducer messageProducer(MessageChannel messageChannel) {  
 
         return new MessageProducer(messageChannel);  
 
     }  
 
    
 
     @Bean  
 
     public MessageConsumer messageConsumer(MessageChannel messageChannel) {  
 
         return new MessageConsumer(messageChannel);  
 
     }  
 
 }

4. 发送消息：使用MessageProducer发送消息。例如：

@Autowired  
 
 private MessageProducer messageProducer;  
 
    
 
 public void sendMessage(String message) {  
 
     messageProducer.send(MessageBuilder.withPayload(message).build());  
 
 }

5. 接收消息：使用MessageConsumer接收消息。例如：

@Autowired  
 
 private MessageChannel messageChannel;  
 
    
 
 @StreamListener(target = "messageChannel")  
 
 public void receiveMessage(String message) {  
 
     System.out.println("Received message: " + message);  
 
 }