前言

消息队列是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题。目前在生产环境，使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka， MQ，RocketMQ等。由于每个消息队列都有它的优势和劣势，我们公司对于不同的场景使用了不同类型的消息队列。对于RocketMQ消费端存在消息消费失败的情况，通常有两种方式，一种是consumer端知道怎么处理，另一种是consumer不能处理（broker处理），本文对后一种情况进行介绍，consumer获取到消息但不能正常处理（ack），接下来这个消费失败的消息在Broker里面如何存储和重新让consumer消费，针对这个流程做了深入的分析。本文中的P代表producer，C代表consumer，本文的consumeQueue对应前面的t