---实践是检验真理的唯一标准---

RabbitMQ组成部分、RabbitMQ的uml原理图、RabbitMQ核心组成部分、RabbitMQ操作流程、RabbitMQ死信的执行原理、RabbitMQ延迟队列的实现、RabbitMQ的Java工作模式

原理图

核心组成介绍

1.Broker：消息队列服务器实体
2.vhost：虚拟主机,一个broker里可以有多个vhost，用作不同用户的权限分离
3.Exchange：消息交换机，指定消息规则，处理消息和队列之间的关系
Exchange Types：direct、topic、fanout、headers
4.Queue：消息的载体,每个消息都会被投到一个或多个队列
5.Binding：绑定，把exchange和queue按照路由规则绑定起来
6.Routing Key：路由关键字,exchange根据这个关键字进行消息投递
7.channel：信道，打开信道才能进行通信，一个channel代码一个会话任务，它是真实 TCP 连接之上的虚拟连接
8.producer：生产者，投递消息的程序
9.consumer：消费者，接受消息的程序

Exchange Types
direct（直连）

根据RouteKey完全匹配到接收队列中
可以使用default Exchange,不需要执行binding操作

topic（主题）

可以使用模糊匹配到queue中，匹配中的都发送
* 匹配一个单词
# 匹配0个或多个字符
需要执行Exchange和Queue的binding操作

fanout（分发）

将Exchange中所有的消息都发送到 与Exchange绑定的Queue中

headers（标题）--很少用

通过匹配AMQP消息的header而非路由键

处理方式

1.queue如何持久化

1.将queue的持久化标识durable设置为true,则代表是一个持久的队列
2.发送消息的时候将deliveryMode=2

2.接收方特殊情况

# 消息确认有两步：消息接收和消息确认
1.如果消费者接收到消息，在确认之前断开了连接或取消订阅：
RabbitMQ会认为消息没有被分发，会重新分发
2.消费者接收到消息却没有确认消息，连接也未断开：
RabbitMQ认为该消费者繁忙，将不会给该消费者分发更多的消息

3.丢数据的问题

1.生成者丢数据:
  transaction和confirm模式
  confirm:rabiitMQ没收到会发送nack给生成者重新发；
        rabiitMQ收到则回复ack
2.队列丢数据:
  queue持久化+confirm机制配合使用
3.消费者丢数据:
 消费端挂掉/处理消息异常时，没有响应ack，就会一直重发

4.死信队列

消息被拒绝（Basic.Reject或Basic.Nack）并且设置 requeue 参数的值为 false
消息过期了
队列达到最大的长度
过期消息:
  队列设置：在队列申明的时候使用 x-message-ttl 参数，单位为 毫秒
  单个消息设置：是设置消息属性的 expiration 参数的值，单位为 毫秒

5.延迟队列

实现方式：过期时间和死信队列
配置方式：
1.过期消息通过队列中设置 x-message-ttl 参数实现
  arguments.put("x-message-ttl", 30000); 
2.死信队列设置 x-dead-letter-exchange 指定交换机,比如：exchange.dead
  arguments.put("x-dead-letter-exchange", "exchange.dead"); 
3.给exchange.dead绑定队列
  channel.queueBind("queue_dead", "exchange.dead", "routingkey.dead");

程序模式

https://www.rabbitmq.com/getstarted.html

P：Publish X：Exchange C：consumer 红色：channel
1.最简单

2.工作队列

3.发布订阅

4.路由

5.主题

6.RPC

7.发布确认

---

--------Java实现代码是下次的主题------