RabbitMQ概述，Rabbitmq是什么

Queue是什么

rabbitmq为了管理不同种类的消息，例如：订单消息和用户消息，那么我们就可以提供多个队列，生产者可以自定义消息队列的名称，并根据需要把消息投递到不同的queue中(每个queue为一个独立的进程)

Exchange是什么

有的producer发给一个queue，有的是发给多个queue，所以我们就需要一个消息路由分发策略的组件，交换器Exchange，把它和queue绑定在一起，有一个类似正则表达式的字符串(bingingkey)用来声明绑定的关系，而这些在exchange里的路由方式和绑定关系我们称为元数据

Rabbitmq是什么

像这样一个包含多个queue进程和exchange组件的消息队列就是所谓的rabbitmq，每一台服务器上的rabbitmq实例就代表一个Broker

Rabbitmq特性

延时队列，死信队列和优先级队列

延时队列

发出消息后希望过一段时间后才消费，rabbitmq通过安装rabbitmq_delayed_message_exchang插件来实现或者rabbitmq通过设置消息的TTL和配置死信队列来实现，消息过期后自动转移到死信队列

应用场景：

• 订单超时自动取消
• 用户注册后延迟发送欢迎邮件
• 任务失败后的延迟重试

死信队列

消费消息是有可能失败的，失败可以进行重试，如果多次重试失败，rabbitmq会将消息放到一个专门的队列放到后面便于我们单独处理，

优先级队列

rabbitmq支持生产者在发送消息的时候为消息标上优先级，消费者总是消费优先级高的消息(高优消息)

Rabbitmq集群

普通集群模式

这个模式，每个rabbitmq都是一个完整的mq实例，都能进行读写，他们之间会互相同步exchange里的元数据，但不会同步queue数据。对于写操作，exchange中的数据会同步，queue中的数据不会同步，对于读操作，如果访问的是broker1中的queue1中的数据，那么会直接返回，如果访问的是broker2，那么会根据exchange2中的元数据去broker1中读取数据再返回给消费者

(单点问题，每个实例的读写能力并没有提升)

镜像队列集群

再普通集群模式的基础上给queue加几个副本（在不同的broker中），他们之间有主从关系，主queue负责读写数据，从queue负责同步主queue的数据，主queue挂了从queue顶上，对于写操作，数据写入主queue后会将exchange和queue的数据同步给其他broker

(牺牲吞吐量换取高可用，带宽压力大)

Quorum队列集群

rabbitmq基于erlang语言开发，它自带虚拟机和分布式通信框架，rabbitmq通过这个分布式通信框架在broker中同步元数据，但是如果broker之间通信断开，可能会出现每个queue都认为自己是主queue，也就是脑裂问题，解决办法就是通过raft一致性算法来同步多个broker中的元数据和队列数据，通过引入选举机制来解决网络分区问题

RabbitMQ通过交换机持久化、队列持久化、消息持久化三层机制（rabbitmq3.6版本后加入lazy queue，收到消息直接存入磁盘而非内存），确保消息在RabbitMQ服务器重启后依然存在；通过Confirm机制、手动ACK、死信队列等机制，确保消息从生产者到消费者的整个流程可靠无丢失