Springcloud 整合rabbitmq

Spring Cloud 提供了对 RabbitMQ 的支持，使得我们可以很容易地在分布式系统中使用 RabbitMQ 来实现消息传递。下面是 Spring Cloud 整合 RabbitMQ 的步骤：

添加依赖

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

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

配置 RabbitMQ

在 application.yml 文件中添加 RabbitMQ 的配置，例如：

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

创建消息生产者

创建一个消息生产者，例如：

@Component
@EnableBinding(Source.class)
public class MessageProducer {
 
    @Autowired
    private MessageChannel output;
 
    public void sendMessage(String message) {
        output.send(MessageBuilder.withPayload(message).build());
    }
}

这里使用了 @EnableBinding 注解来启用 Spring Cloud Stream，同时使用了 Source 接口来定义输出通道。

创建消息消费者

创建一个消息消费者，例如：

@Component
@EnableBinding(Sink.class)
public class MessageConsumer {
 
    @StreamListener(Sink.INPUT)
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

这里使用了 @EnableBinding 注解来启用 Spring Cloud Stream，同时使用了 Sink 接口来定义输入通道，使用 @StreamListener 注解来监听输入通道的消息。

测试

在需要发送消息的地方注入 MessageProducer，调用 sendMessage 方法发送消息。例如：

@Autowired
private MessageProducer messageProducer;
 
messageProducer.sendMessage("Hello, RabbitMQ!");

运行程序，可以看到消息消费者接收到了消息。

以上就是 Spring Cloud 整合 RabbitMQ 的步骤，通过 Spring Cloud Stream，我们可以更加方便地使用 RabbitMQ 来实现消息传递