消息中间件

发布时间：2023年12月27日

文章目录


在这里插入图片描述
在这里插入图片描述

1. 消息不丢失

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

2. 消息重复消费

在这里插入图片描述

3. 死信交换机实现延时队列

延时队列 = 死信交换机 + TTL
延时队列用在有时间限制的消息的消费问题，可以对消息设置超时时间，当消息超时后就会转发到死信交换机，它也绑定了队列，比如说一个订单，时间到了之后就会由死信交换机路由到队列，拿到这个消息后判断是不是已经支付成功，没有支付成功的话就取消订单。
在这里插入图片描述

4. 消息堆积问题

在这里插入图片描述
在这里插入图片描述

5. rabbitMQ高可用机制

镜像队列和仲裁队列
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

6. Kafka是如何保证消息不丢失的

在这里插入图片描述

在这里插入图片描述
在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

7. 消息的顺序消费

在这里插入图片描述

在这里插入图片描述

8. Kafka高可用机制

kafka的高可用其实是基于分区备份机制实现的，一个分区的消息会保存在不同的broker中，当这个分区的leader对应的broker宕机后，其他的broker中也会有这个分区的备份数据，分区的leader是负责读写数据的，那从这个分区的副本中可以选择一个作为分区的leader，也就实现的高可用。
在这里插入图片描述

在这里插入图片描述

9. kafka数据清理机制

kafka文件存储机制：在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

10. kafka中实现高性能的设计

在这里插入图片描述

在这里插入图片描述
在这里插入图片描述

文章来源:https://blog.csdn.net/qq_51240148/article/details/135243693
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
最新文章