Skip to content

Main Navigation首页

Java基础面试题

Java并发编程面试题

MyBatis面试题

Spring面试题

SpringMVC面试题

SpringBoot面试题

SpringCloud面试题

消息队列基础

RabbitMQ精选面试题

Kafka精选面试题

RocketMQ精选面试题

Appearance

Sidebar Navigation

消息队列基础

为什么使用MQ？优点？常用场景？使用MQ有什么缺点？Kafka、ActiveMQ、RabbitMQ、RocketMQ 的区别？消息队列如何选型?MQ 有哪些常见问题？如何解决这些问题？依托消息中间件如何实现异步？

RabbitMQ精选面试题

RabbitMQ是什么？使用RabbitMQ有什么好处？RabbitMQ的特点?AMQP是什么?AMQP协议3层？AMQP模型的几大组件？RabbitMQ有那些基本概念？什么是生产者Producer?什么是消费者Consumer?什么是Broker服务节点？什么是Queue队列？什么是Exchange交换器？什么是RoutingKey路由键？什么是Binding绑定？RabbitMQ 中的 Broker 是指什么？Cluster 又是指什么？vhost 是什么? 起什么作用?RabbitMQ的工作模式有几种？消息基于什么传输?RabbitMQ中消息可能有的几种状态?如何确保消息正确地发送至RabbitMQ?生产者消息如何运转？RabbitMQ队列结构？消费者获取消息的方式？消息如何分发?消息怎么路由？消息传输保证层级？消费者接收消息过程？如何确保消息接收方消费了消息?如何避免消息重复投递或重复消费?消费者某些原因无法处理当前接受的消息如何来拒绝？如何解决RabbitMQ丢数据的问题?如何保证消息的可靠性投递?消息如何保证幂等性？消息如何被优先消费？如何保证消息的顺序性?多个消费者监听一个队列时，消息如何分发?无法被路由的消息去了哪里?死信队列和延迟队列的使用?消息在什么时候会变成死信?RabbitMQ如何实现延时队列?RabbitMQ事务机制？RabbitMQ的集群模式有几种？集群节点类型有几种？如何自动删除长时间没有消费的消息？如何确保消息不丢失？

Kafka精选面试题

什么是Kafka？Kafka中有哪几个组件?什么是消费者或用户？Kafka中的 Broker 是干什么的？什么是生产者？什么是消费者组？偏移的作用是什么？Kafka系统工具有哪些类型？Kafka为什么那么快?Kafka的message格式是什么？Kafka可以接收的消息最大为多少？Kafka的优点有那些？为什么要使用 Kafka？为什么要使用消息队列？Kafka存在那些局限性？Leader和Follower的概念是什么？为什么要使用Apache Kafka集群？Kafka集群中保留期的目的是什么？Kafka和Flume之间的主要区别是什么？Apache Kafka是分布式流处理平台吗？如果是，你能用它做什么？流API的作用是什么？消费者API的作用是什么？连接器API的作用是什么？Kafka中的 zookeeper 起到什么作用？可以不用zookeeper吗？没有zookeeper可以使用Kafka吗？Kafka中的 ISR、AR 又代表什么？ISR 的伸缩又指什么？副本和 ISR 扮演什么角色？Kafka Follower如何与Leader同步数据?为什么Kafka的复制至关重要？什么是Kafka中的地域复制？什么是多租户？什么情况下一个 Broker 会从ISR中踢出去?如果 Leader Crash 时，ISR为空怎么办副本长时间不在ISR中，这意味着什么？Kafka Producer如何优化写入速度?Kafka Producer API的作用是什么？生产者中，什么情况下会发生 QueueFullException？Kafka Producer 写数据，ACK 为 0，1，-1 时分别代表什么？当ack为-1时，什么情况下，Leader 认为一条消息 Commit了？Kafka Unclean 配置代表什么？会对 spark streaming 消费有什么影响？Kafka 中 Consumer Group 是什么概念？Kafka 中的消息是否会丢失和重复消费？为什么Kafka不支持读写分离？Kafka 中是怎么体现消息顺序性的？消费者提交消费位移时提交的是当前消费到的最新消息的offset还是offset+1?Kafka 如何实现延迟队列?Kafka 中的事务是怎么实现的？Kafka Leader选举机制原理是什么？

RocketMQ精选面试题

RocketMQ由哪些角色组成，每个角色作用和特点是什么？RocketMQ中的Topic和JMS的queue有什么区别？RocketMQ Broker中的消息被消费后会立即删除吗？RocketMQ消费模式有几种？RocketMQ消息是push还是pull？为什么要主动拉取消息而不使用事件监听方式？Broker如何处理拉取请求的？RocketMQ如何做负载均衡？当消费负载均衡consumer和queue不对等的时候会发生什么？消息重复消费如何解决？如何让 RocketMQ 保证消息的顺序消费？怎么保证消息发到同一个queue？RocketMQ如何保证消息不丢失？RocketMQ的消息堆积如何处理？如果Consumer和Queue不对等，上线了多台也在短时间内无法消费完堆积的消息怎么办？堆积消息会超时删除吗？堆积的消息会不会进死信队列？RocketMQ 在分布式事务支持这块机制的底层原理?高吞吐量下如何优化生产者和消费者的性能?RocketMQ 是如何保证数据的高容错性的?任何一台Broker突然宕机了怎么办？Broker把自己的信息注册到哪个NameServer上？RocketMQ如何分布式存储海量消息的？任何一台 Broker 突然宕机了怎么办？还能使用吗？消息会不会丢？怎么知道有哪些 Broker ？如何知道要连那个Broker？NameServer到底可以部署几台机器？为什么要集群化部署？系统如何从NameServer获取Broker信息？如果Broker宕了，NameServer是怎么感知到的？Broker挂了，系统是怎么感知到的？Master Broker 是如何将消息同步给 Slave Broker 的？消费消息时是从Master获取还是Slave获取？如果 Slave Broker 挂掉了，会对整个系统有影响吗？Master Broker 突然挂了，这样会怎么样？

目录概览

Table of Contents for current page

消费者某些原因无法处理当前接受的消息如何来拒绝？

channel.basicNack
channel.basicReject

更新时间:

上一题如何避免消息重复投递或重复消费?

下一题如何解决RabbitMQ丢数据的问题?

鄂ICP备19026530号-5

Copyright © 2016-present 一航