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

消息中间件面试题

异步发送(验证码、短信、邮件…)
MYSQL和Redis,ES之间的数据同步
分布式事务
削峰填谷

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

在这里插入图片描述

在这里插入图片描述
RabbitMQ如何保证消息不丢失?

开启生产者确认机制,确保生产者的消息能到达队列
开启持久化功能,确保消息未消费前在队列中不会丢失
开启消费者确认机制为auto,由spring确认消息处理成功后完成ack
开启消费者失败重试机制,多次重试失败后将消息投递到异常交换机,交由人工处理

在这里插入图片描述

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

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

RabbitMQ中死信交换机?(RabbitMQ延迟队列有了解过嘛)
我们当时一个什么业务使用到了延迟队列(超时订单、限时优惠、定时发布…)
其中延迟队列就用到了死信交换机和TTL (消息存活时间)实现的
消息超时未消费就会变成死信(死信的其他情况:拒绝被消费,队列满了)

延迟队列插件实现延迟队列DelayExchange
声明一个交换机,添加delayed属性为true
发送消息时,添加x-delay头,值为超时时间

RabbitMQ如果有100万消息堆积在MQ,如何解决(消息堆积怎么解决)

增加更多消费者,提高消费速度
在消费者内开启线程池加快消息处理速度
扩大队列容积,提高堆积上限,采用惰性队列
在声明队列的时候可以设置属性x-queue-mode为lazy,即为惰性队列
基于磁盘存储,消息上限高
性能比较稳定,但基于磁盘存储,受限于磁盘IO,时效性会降低

http://www.lryc.cn/news/130102.html

相关文章:

  • 麻辣烫数据可视化,麻辣烫市场将持续蓬勃发展
  • 大数据课程J1——Scala的概述
  • 第二章:25+ Python 数据操作教程(第十三节NUMPY 教程与练习)
  • 【Java面试】如果一个线程两次调用start(),会出现什么问题?
  • 购买steam余额有风险吗?以及N种被红锁的情况
  • 使用 BERT 进行文本分类 (02/3)
  • 基于Hadoop的表级监管
  • 【学习日记】【FreeRTOS】延时列表的实现
  • ​LeetCode解法汇总833. 字符串中的查找与替换
  • ide internal errors【bug】
  • 阿里云与中国中医科学院合作,推动中医药行业数字化和智能化发展
  • 【Redis】Redis 的学习教程(五)之 SpringBoot 集成 Redis
  • github以及上传代码处理
  • 【PACS源码】认识PACS的架构和工作流程
  • 【C++】开源:跨平台Excel处理库-libxlsxwriter配置使用
  • 前端-轮询
  • Python “贪吃蛇”游戏,在不断改进中学习pygame编程
  • Linux网络编程_Ubuntu环境配置安装
  • gradle java插件
  • 神经网络基础-神经网络补充概念-48-rmsprop
  • 分析Flink,源和算子并行度不一致时,运行一段时间后,看似不再继续消费的问题,提供解决思路。
  • PyTorch训练深度卷积生成对抗网络DCGAN
  • Spring-4-掌握Spring事务传播机制
  • [PyTorch][chapter 49][创建自己的数据集 1]
  • 中间件(二)dubbo负载均衡介绍
  • springboot异步文件上传获取输入流提示找不到文件java.io.FileNotFoundException
  • 安装jenkins-cli
  • linux通过NC工具启动临时端口监听
  • 开源语音聊天软件Mumble
  • JDK 1.6与JDK 1.8的区别