电子商务网站推广方法,西宁 专业网站建设,网站优化一年多少钱,各大招聘网站收费标准RabbitMQ面试题
面试官#xff1a;RabbitMQ-如何保证消息不丢失 候选人#xff1a; 嗯#xff01;我们当时MYSQL和Redis的数据双写一致性就是采用RabbitMQ实现同步的#xff0c;这里面就要求了消息的高可用性#xff0c;我们要保证消息的不丢失。主要从三个层面考虑 第一…RabbitMQ面试题
面试官RabbitMQ-如何保证消息不丢失 候选人 嗯我们当时MYSQL和Redis的数据双写一致性就是采用RabbitMQ实现同步的这里面就要求了消息的高可用性我们要保证消息的不丢失。主要从三个层面考虑 第一个是开启生产者确认机制确保生产者的消息能到达队列如果报错可以先记录到日志中再去修复数据 第二个是开启持久化功能确保消息未消费前在队列中不会丢失其中的交换机、队列、和消息都要做持久化 第三个是开启消费者确认机制为auto由spring确认消息处理成功后完成ack当然也需要设置一定的重试次数我们当时设置了3次如果重试3次还没有收到消息就将失败后的消息投递到异常交换机交由人工处理 面试官RabbitMQ消息的重复消费问题如何解决的 候选人 嗯这个我们还真遇到过是这样的我们当时消费者是设置了自动确认机制当服务还没来得及给MQ确认的时候服务宕机了导致服务重启之后又消费了一次消息。这样就重复消费了 因为我们当时处理的支付订单|业务唯一标识它有一个业务的唯一标识我们再处理消息时先到数据库查询一下这个数据是否存在如果不存在说明没有处理过这个时候就可以正常处理这个消息了。如果已经存在这个数据了就说明消息重复消费了我们就不需要再消费了 面试官那你还知道其他的解决方案吗 候选人 嗯我想想~ 其实这个就是典型的幂等的问题比如redis分布式锁、数据库的锁都是可以的 面试官RabbitMQ中死信交换机 ? RabbitMQ延迟队列有了解过嘛 候选人 嗯了解过 我们当时的xx项目有一个xx业务需要用到延迟队列其中就是使用RabbitMQ来实现的。 延迟队列就是用到了死信交换机和TTL消息存活时间实现的。 如果消息超时未消费就会变成死信在RabbitMQ中如果消息成为死信队列可以绑定一个死信交换机在死信交换机上可以绑定其他队列在我们发消息的时候可以按照需求指定TTL的时间这样就实现了延迟队列的功能了。 我记得RabbitMQ还有一种方式可以实现延迟队列在RabbitMQ中安装一个死信插件这样更方便一些我们只需要在声明交互机的时候指定这个就是死信交换机然后在发送消息的时候直接指定超时时间就行了相对于死信交换机TTL要省略了一些步骤 面试官如果有100万消息堆积在MQ , 如何解决 ? 候选人 我在实际的开发中没遇到过这种情况不过如果发生了堆积的问题解决方案也所有很多的 第一:提高消费者的消费能力 ,可以使用多线程消费任务 第二增加更多消费者提高消费速度 使用工作队列模式, 设置多个消费者消费消费同一个队列中的消息 第三扩大队列容积提高堆积上限 可以使用RabbitMQ惰性队列惰性队列的好处主要是 ①接收到消息后直接存入磁盘而非内存 ②消费者要消费消息时才会从磁盘中读取并加载到内存 ③支持数百万条的消息存储 面试官RabbitMQ的高可用机制有了解过嘛 候选人 嗯熟悉的~ 我们当时项目在生产环境下使用的集群当时搭建是镜像模式集群使用了3台机器。 镜像队列结构是一主多从所有操作都是主节点完成然后同步给镜像节点如果主节点宕机后镜像节点会替代成新的主节点不过在主从同步完成前主节点就已经宕机可能出现数据丢失 面试官那出现丢数据怎么解决呢 候选人 我们可以采用仲裁队列与镜像队列一样都是主从模式支持主从数据同步主从同步基于Raft协议强一致。 并且使用起来也非常简单不需要额外的配置在声明队列的时候只要指定这个是仲裁队列即可
