MQ-RabbitMQ死信队列
死信即无法被消费的msg,在某些时候由于特定的原因导致Queue中的消息不能被消费。
死信即无法被消费的msg,在某些时候由于特定的原因导致Queue中的消息不能被消费。
四大核心:生产者、交换机、队列、消费者。
用于解决轮询分发消息不能“能者多劳”的问题,合理利用资源。
ActiveMQ,Kafka,RabbitMQ,RocketMQ,···
使用Docker快速安装RabbitMQ的安装及相关配置。
手动ACK应答可以处理任务不丢失的情况,但是如何保障当 RabbitMQ 服务停掉以后消息生产者发送过来的消息不丢失?
本质是个队列,FIFO先入先出,只不过队列中存放的内容是message而已,还是一种跨进程的通信机制,用于上下游传递消息。
suspend和resume方法已经遗弃了。suspend()用于线程挂起,被挂起的线程必须要等到调用resume()方法后才能继续执行。