当前位置: 首页 > news >正文

面试题:MQ

 一、常见的mq产品

RabbitMQRocketMQKafka、ActiveMQ、ZeroMQ、MetaMq

RabbitMQ: One broker to queue them all | RabbitMQicon-default.png?t=N7T8https://www.rabbitmq.com/

二、作用(面试题) 为什么用MQ?

1、异步处理

2、应用解耦

3、流量削峰

三、交换机类型(面试题

1、Direct Exchange

直连型交换机,根据RoutingKey(路由键)路由到不同的队列

2、Fanout Exchange

扇型(广播)交换机,这个交换机没有路由键概念,就算你绑了路由键也是无视的。 这个交换机在接收到消息后,会直接转发到绑定到它上面的所有队列。

3、Topic Exchange

主题交换机,这个交换机其实跟直连交换机流程差不多,但是它的特点就是在它的路由键和绑定键之间是有规则的。(开始计算

四、面试题:你们是如何保证消息不丢失的?

使用死信队列来保证消息不丢失

五、面试题Rabbitmq怎么保证消息的可靠性?

1.消费端消息可靠性保证:

1.消息确认(Acknowledgements)

消费者在接收到消息后,默认情况下RabbitMQ会自动确认消息(autoAck=true)。为保证消息可靠性,可以设置autoAck=false,使得消费者在处理完消息后手动发送确认(basicAck)。如果消费者在处理过程中发生异常或者未完成处理就终止运行,那么消息在超时时间内将不会被删除,会再次被RabbitMQ投递给其他消费者。

2.死信队列(Dead Letter Queue)

当消息不能被正常消费时(比如达到最大重试次数),可以通过设置TTL(Time To Live)或者死信交换器(Dead Letter Exchange)将消息路由至死信队列,从而有机会后续分析和处理这些无法正常消费的消息。

2.生产端消息可靠性保证:

  1. 消息持久化

当生产者发布消息时,可以选择将其标记为持久化(persistent).这意味着即使 RabbitMQ 服务器重启,消息也不会丢失,因为它们会被存储在磁盘上。

  1. 确认(Confirm)机制

开启confirm回调模式后,RabbitMQ会在消息成功写入到磁盘并至少被一个交换器接受后,向生产者发送一个确认(acknowledgement)。若消息丢失或无法投递给任何队列,RabbitMQ将会发送一个否定确认(nack). 生产者可以根据这些确认信号判断消息是否成功送达并采取相应的重试策略。

RabbitMQ作为消息中间件并启用publisher confirms(发布者确认)与publisher returns(发布者退回)机制时,可以确保消息从生产者到交换机的投递过程得到更准确的状态反馈。


http://www.mrgr.cn/news/838.html

相关文章:

  • 交通感知与车路协同系统-计算机毕设Java|springboot实战项目
  • Vue快速入门(六)——Vue3 状态管理 - Pinia(一)
  • MySQL——单表查询(二)按条件查询(3)带 BETWEEN AND 关键字的查询
  • 探索DevExpress WinForms:.NET世界中的UI库之星
  • [C#]什么是依赖倒置原则:依赖倒置原则的简单示例与应用解析
  • c语言开源库之uthash用法
  • 使用EasyExcel填充Excel并上传至OSS
  • 使用docker compose一键部署MySQL服务
  • Tmagic-editor低代码底层拖拽库Moveable示例学习
  • 微信小程序中实现自动滚动
  • 白盒测试-发送请求
  • Java重修笔记 第三十六天 System类、大数据处理方案
  • 配置mysql5.7环境+使用python管理数据库+使用中间件mycat配置读写分离
  • 使用go实现一个简单的聊天服务器
  • 白骑士的C#教学实战项目篇 4.4 游戏开发
  • 优化大量数据导出到Excel的内存消耗(二):如果数据超出Excel单表上限,则进行分表
  • 前端面试题(二十五)|附赠完整面试流程
  • Python爬虫使用实例
  • Python 文件目录操作,以及json.dump() 和 json.load()
  • 安全自动化和编排:如何使用自动化工具和编排技术来提高安全操作效率。(第一篇)