springCloud 集成mq

Spring Cloud 支持与多种消息队列系统集成，其中包括 RabbitMQ 和 Apache Kafka 等。可以使用 Spring Cloud Stream 对消息队列进行抽象，简化对消息队列的使用。

下面是一个简单的使用 RabbitMQ 的示例：

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

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

2. 在配置文件中添加 RabbitMQ 的连接信息：

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

3. 在代码中使用 @EnableBinding 注解绑定消息通道：

@EnableBinding(Sink.class)
public class MqReceiver {
  @StreamListener(Sink.INPUT)
  public void receive(Object payload) {
    System.out.println("Received: " + payload);
  }
}

以上是 Spring Cloud 集成 RabbitMQ 的简单示例，可以根据需要进行扩展和定制。