kafka是什么中间件(中间件卡不卡)

导语：中间件-kafka原理-正常、重试、死信队列、延时队列原理及区别

正常队列、重试队列、死信队列、延时队列原理及区别

中间件-kafka原理

消费失败问题

试想如果消费者在消费时发生了异常，那么就不会对这一次消费进行确认（Ack）,进而发生回滚消息的操作之后消息始终会放在队列的顶部，然后不断被处理和回滚，导致队列陷入死循环。

为了解决该问题，引入回退队列。可以为每个队列设置一个回退队列。

回退队列

消费端消费消息失败时，为防止消息无故丢失而重新将消息回滚到Broker中，这个时候可以将消息写入回退队列。

重试队列

与回退队列不同的是重试队列一般分成多个重试等级，每个重试等级一般也会设置重新投递延时，重试次数越多投递延时就越大。

回退队列和死信队列都是为异常的处理提供的一种机制保障；可以将重试队列看作为回退队列的一种。

例子

消息第一次消费失败入重试队列Q1，Q1的重新投递延迟为5s，在5s过后重新投递该消息；如果消息再次消费失败则入重试队列Q2，Q2的重新投递延迟为10s，在10s过后再次投递该消息。以此类推，重试越多次重新投递的时间就越久，为此需要设置一个上限，超过投递次数就入死信队列。

搭配：正常队列+重试队列+死信队列的例子如下

1.第一次消费失败，消息进入5秒重试队列。

2.5秒队列投递失败，消息进入10秒重试队列；

3.10秒队列重试失败，消息进入死信队列；

这里的投递均为消费者主动拉取；

5、10、20、30……这里可以根据业务场景灵活进行配置，逐级增加延时时长。

延时队列

再来看看常用的延时队列

生产者和消费者步骤

1.延时队列并不直接写入目标topic队列，而是先写入内置delay-topic的延时队列中；

2.由DelayService针对不同延时等级的topic开启不同线程进行拉取，将达到指定时间的消息写入目标topic；

3.消费者正常订阅和消费；

重试队列与延迟队列区别

相同点：都是需要设置延迟级别。

区别点：延迟队列动作由内部触发，重试队列动作由外部消费端触发；延迟队列作用一次，而重试队列的作用范围会向后传递。

​

本文内容由快快网络小萱创作整理编辑！