zoukankan      html  css  js  c++  java
  • RabbitMQ面试题

         链接:https://juejin.im/post/5ee812aff265da77190bd5c5   

       1、RabbitMQ是什么?

    RabbitMQ是实现了高级消息队列协议(AMQP)的开源代理软件(亦称面向消息的中间件)。RabbitMQ服务器是用Erlang语音编写的,而群集和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。

       2、RabbitMQ特点?

      可靠性:RabbitMQ使用一些机制来保证可靠性,如持久化、传输确认及发布确认等。

      灵活的路由:在消息进入之前,通过交换器来路由消息。对于典型的路由功能 ,RabbitMQ 已经提供了一些内置的交换器来实现。针对更复杂的路由功能,可以将多个交换器绑定在一起,也可以通过插件

    机制来实现自己的交换器。

      扩展性:多个RabbitMQ节点可以组成一个集群,也可以根据实际业务情况动态地扩展集群中节点。

      高可用性:队列可以在集群中的机器上设置镜像,使得在部分节点出现问题的情况下队列仍然可用。

      多种协议:RabbitMQ除了原生支持AMQ协议,还支持STOMP,MQTT等多种消息中间件协议。

      多语言客户端:RabbitMQ几乎支持所有常用语言,比如Java、Python、Ruby、PHP、C#、JavaScript等。

      管理界面:RabbitMQ提供了一个易用的用户界面,使得用户可以监控和管理消息、集群中的节点等。

      令插件机制:RabbitMQ提供了许多插件,以实现从多方面进行扩展,当然也可以编写自己的插件。

      3、AMQP是什么?

      RabbitMQ是AMQP协议的Erlang的实现(当然RabbitMQ 还支持STOMP2、MQTT3等协议)

      4、AMQP协议3层?

      Module Layer:协议最高层,主要定义了一些客户端调用的命令,客户端可以用这些命令实现自己的业务逻辑。

      Session Layer:中间层,主要负责客户端命令发送给服务器,再将服务端应答返回客户端,提供可靠性同步机制和错误处理。

      TransportLayer:最底层,主要传授二进制数据流,提供帧的处理、信道服用、错误检测和数据表示等。

       5、AMQP模型的几大组件?

      交换器(Exchange):消息代理服务器中用于把消息路由到队列的组件。

      队列(Queue):用来存储消息的数据结构,位于硬盘或内存中。

      绑定(Bingding):一套规则,告知交换器消息应该将消息投递给哪个队列。

       6、生产者Producer?

      消息生产者,就是投递消息的一方。

      消息一般包含两个部分:消息体(payload)和标签(Label)。

      7、消费者Consumer?

      消费消息,也就是接收消息的一方。

      消费者连接到RabbitMQ服务器,并订阅到队列上。消费消息时只消费消息体,丢弃标签。

      8、Broker服务节点?

      Broker可以看做RabbitMQ的服务节点。一般情况下,一个Broker可以看做一个RabbitMQ服务器。

      9、Queue队列?

      Quenue:RabbitMQ的内部对象,用于存储消息。多个消费者可以订阅同一队列,这时队列中的消息会被平摊(轮询)给多个消费者进行处理。

           10、Exchange交换器?

      Exchange:生产者将消息发送到交换器,有交换器将消息路由到一个或多个队列中。当路由不到时,或返回给生产者或直接丢弃。

      11、RoutingKey路由键?

      生产者将消息发送给交换器的时候,会指定一个RoutingKey,用来指定这个消息的路由规则,这个RoutingKey需要与交换器类型和绑定键(BindingKey)联合使用才能 最终生效。

      12、Binding绑定?

      通过绑定将交换器和队列关联起来,一般会指定一个BindingKey,这样RabbitMQ就知道如何正确路由消息到队列了。

           13、交换器4中类型?

      主要有一下4种。

      fanout:把所有发送到该交换器的消息路由到所有与该交换器绑定的队列中。

      direct:把消息路由到BindingKey和RoutingKey完全匹配的队列中。

      topic:

      匹配规则:

      RoutingKey  为一个点号‘.’: 分隔的字符串。比如:java.xiaoka.show

      BindingKey和RoutingKey一样也是点号“. ”分隔的字符串。

      BindingKey可使用*和#用于做模糊匹配,*匹配一个单词,#匹配多个或0个

      Headers:不依赖路由键匹配规则路由消息。是根据发送消息内容中的headers属性进行匹配。性能差,基本用不到。

      14、生产者消息运转?

      1、Producer先连接到Broker,建立连接Connection,开启一个信道(Channel)。

      2、Producer声明一个交换器并设置好相关属性。

      3、Producer声明一个队列并设置好相关属性。

      4、Producer通过路由键将交换器和队列绑定起来。

      5、Producer发送消息到Broker,其中包含路由键、交换器等信息。

      6、相应的交换器根据接收到的路由键查找匹配的队列。

      7、如果找到,将消息存入对应的队列;如果没有找到,会根据生产者的配置丢弃或者返回给生成者。

      8、关闭信道。

      9、管理连接。

      15、消费者接收消息过程?

      1)Producer先连接到Broker,建立连接Connection,开启一个信道(Channel)。

      2)向Broker请求消费响应的队列中消息,可能会设置响应的回调函数。

      3)等待Broker回应并投递响应队列中的消息,接收消息。

      4)消费者确认收到消息,ack。

      5)RabbitMQ从队列中删除已经确定的消息。

      6)关闭信道。

      7)关闭连接。

      16、交换器无法根据自身类型和路由键找到符合条件队列时,有哪些处理?

      mandatory:true 返回消息给生产者。

      mandatory:false 直接丢弃。

      17、死信队列

      DLX,全称为DEAD-Letter-Exchange,死信交换器,死信邮箱。当消息在一个队列中变成死信(dead message)之后,它能被重新被发送到另一个交换器中,这个交换器就是DLX,绑定DLX的队列就称之为死信队列。

      18、导致的死信的几种原因?

      消息被拒(Basic.Reject/Basic.Nack)且requeue = false

      消息TTl过期。

      队列满了,无法再添加。

      19、延迟队列

      存储对应的延迟信息,指当消息被发送以后,并不想让消费者立刻拿到消息,而是等待特定时间后,消费者才能拿到这个消息进行消费。

      20、优先级队列?

      优先级高的队列会先被消费。

      可以通过x-max-priority参数来实现。

      当消费速度大于生产速度且Broker没有堆积的情况下,优先级显得没有意义。

      21、事务机制?

      RabbitMQ  客户端中与事务机制相关的方法有三个:

      channel.txSelect 用于将当前的信道设置成事务模式。

      channel.txCommit 用于提交事务。

      channel.txRollback 用于事务回滚,如果在事务提交执行之前由于RabbitMQ 异常崩溃或者其他原因抛出异常,通过txRollback来回滚。

      22、发送确认机制?

      生产者把信道设置为confirm确认模式,设置后,所有再该信道发布的消息都会被指定一个唯一的ID,一旦消息被投递到所有匹配的队列之后,

    RabbitMQ就会发送一个确认(Basic.Ack)给生产者(包含消息的唯一ID),这样生产者就知道消息到达对应的目的地了。

      23、消息这获取消息的方式?

      推

      拉

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

      channel.basicNack

      channel.basicReject

      25、消息传输保证层级?

      At most once:最多一次。消息可能会丢失,但不会重复传输。

      At least once:最少一次。消息绝不会丢失,但可能会重复传输。

      26、vhost?

      每一个RabbitMQ服务器都能创建虚拟的消息服务器,也就虚拟主机(virtual host),简称vhost。

      默认为“/”。

       27、集群中的节点类型?

      内存节点:ram,将变更写入内存。

      磁盘节点,disc,磁盘写入操作。

      RabbitMQ 要求最少有一个磁盘节点。

      28、队列结构

      通常由以下两部分组成?

      rabbit_amqueue_process:负责协议相关的消息处理,即接收生产者发布的消息、向消费者交付消息、处理消息的确认(包括生产端的confirm和消费端的ack)等。

      backing_queue:是消息存储的具体形式和引擎,并向rabbit amqqueue process 提供相关的接口以供调用。

      29、RabbitMQ中消息可能有的几种状态?

      alpha:消息内容(包括消息体 、属性和headers)和消息索引都存储在内存中。

      beta:消息内容保存在磁盘中,消息索引保存在内存中。

      gamma:消息内容保存在磁盘中,消息索引在磁盘和内存中都有。

      delta:消息内容和索引都在磁盘中。

      

  • 相关阅读:
    数据库基础理解学习-Mysql
    玫瑰花小制作分享-JavaScript(七夕专属浪漫)
    爬虫探索Chromedriver+Selenium初试
    Python 数据结构理解分享
    Python 实用第三方库安装方法
    Python安装-Pycharm+Anaconda
    oracle父子级查询数据树结构
    如何查看class文件的编译jdk版本号
    PL/SQL developer 11.0注册码
    linux 下tomcat出现 Native memory allocation (malloc) failed to allocate 1915224064 bytes for committing reserved memory问题
  • 原文地址:https://www.cnblogs.com/zhangzeyuan/p/13952571.html
Copyright © 2011-2022 走看看