RabbitMQ消息可靠性分析

Posted 2021-05-16 ITdfq

---

第一步

---

第二步

---

第三步

在SpringBoot中Queue和交换器都是持久化的，他们的构造方法中durable:true 开启持久化

---

第四步

@RabbitHandler  //根据这个注解进行执行方法
public void process(String msg){
    System.out.println("Consumer1-Receiver:"+msg);
}

• @RabbitHandler是自动确认的，只要消费者拿到消息，就会把消息从队列中删掉
• 如果程序发生异常就需要手动处理
• 第一步创建配置文件