SpringBoot集成RabbitMQ的步骤

笔记内容大部分于来自b站视频 黑马程序员RabbitMQ全套教程，rabbitmq消息中间件到实战

 
            org.springframework.boot
            spring-boot-starter-amqp
        

spring:
  rabbitmq:
    addresses: 你的rabbitMQ所在服务器的ip地址和对应端口（5672）
    username: 你的用户名
    password: 密码

@Configuration
public class RabbitMQConfig {
    public static final String EXCHANGE_NAME = "boot_topic_exchange";
    public static final String QUEUE_NAME = "boot_queue";
    //1.交换机
    @Bean("bootExchange")
    public Exchange bootExchange(){
        return ExchangeBuilder.topicExchange(EXCHANGE_NAME).durable(true).build();
    }
    //2.队列
    @Bean("bootQueue")
    public Queue bootQueue(){
        return QueueBuilder.durable(QUEUE_NAME).build();
    }
    //3.队列和交换机的绑定关系
    @Bean
    public Binding binding(@Qualifier("bootQueue") Queue queue,@Qualifier("bootExchange") Exchange exchange){
        return BindingBuilder.bind(queue).to(exchange).with("boot.#").noargs();
    }

}

@SpringBootTest
class RabbitMQApplicationTests {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Test
    void producer(){
        //发送消息
        String message = "hello rabbitmq";
        rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME,"boot.hhh",message);
    }
}

@Component
public class RabbitMQListener {
    @RabbitListener(queues = "boot_queue")//这里的boot_queue是一个队列名，和生产者的String QUEUE_NAME = "boot_queue"相对应。
    public void ListenerQueue(Message message){
        String s = new String(message.getBody());
        System.out.println(s);
    }
}