rabbitmq 实战

Spring Boot 整合 RabbitMQ 的实战步骤如下：

1. 在 pom.xml 中添加 RabbitMQ 的依赖：

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

2. 在 application.properties 或 application.yml 中配置 RabbitMQ 的连接信息：

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

3. 创建 RabbitTemplate 和 AmqpAdmin 类的 Bean：

@Configuration
public class RabbitConfig {

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        return new RabbitTemplate(connectionFactory);
    }

    @Bean
    public AmqpAdmin amqpAdmin(ConnectionFactory connectionFactory) {
        return new RabbitAdmin(connectionFactory);
    }
}

4. 创建消息生产者，使用 RabbitTemplate 发送消息：

@Service
public class RabbitSender {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void send(String routingKey, Object message) {
        rabbitTemplate.convertAndSend(routingKey, message);
    }
}

5. 创建消息消费者，使用 @RabbitListener 注解监听队列：

@Service
public class RabbitReceiver {

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

6. 使用 AmqpAdmin 在启动时声明队列、交换机、绑定关系

这是一个简单的 Spring Boot 整合 RabbitMQ 的示例，实际应用中可能还需要进行其他配置和调整。