springboot集成rabbit

在 Spring Boot 中集成 RabbitMQ 需要在 pom.xml 文件中加入 RabbitMQ 的依赖包：

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

然后，在 application.properties 或者 application.yml 中配置 RabbitMQ 的连接信息：

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

接下来，就可以在 Spring Boot 应用中使用 RabbitMQ 了。

示例代码如下：

@Component
public class RabbitMQSender {

  @Autowired
  private AmqpTemplate amqpTemplate;

  public void send(String queue, String message) {
    amqpTemplate.convertAndSend(queue, message);
  }
}

在这段代码中，使用 @Autowired 注解自动注入了 AmqpTemplate 类，这是 Spring AMQP 提供的用于发送和接收消息的模板类。使用 convertAndSend 方法可以将 Java 对象转换为消息发送到指定的队列中。

如果要接收消息，可以在类中添加如下代码：

@Component
public class RabbitMQReceiver {

  @RabbitListener(queues = "test_queue")
  public void processMessage(String message) {
    System.out.println("Received message: " + message);
  }
}

使用 @RabbitListener 注解可以将方法标记为 RabbitMQ 消息监听器，当有消息到达时，会自动调用该方法处理消息。

希望这些信息能帮到您！