1.简介

遵循AMQP协议
erlang语言开发，是面向并发的语言
官网：www.rabbitmq.com
普通安装和docker安装，建议docker

AMQP:
是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。目标是实现一种在全行业广泛使用的标准消息中间件技术，以便降低企业和系统集成的开销，并且向大众提供工业级的集成服务。
RabbitMQ实现AMQP：

生产者：消息的创建者，发送到 rabbitmq;

消费者：连接到 rabbitmq，订阅到队列上，消费消息，持续订阅(basicConsumer)和单条订阅(basicGet).

消息：包含有效载荷和标签，有效载荷指要传输的数据，标签描述了有效载荷，并且 rabbitmq 用它来决定谁获得消息，消费者只能拿到有效载荷，并不知道生产者是谁。

交换器：生产者配置

路由键、绑定：生产者和消费者都配置路由键，生产者绑定路由键和交换器，消费者绑定路由键、队列、交换器

队列：消费者配置（可能是多个消费者消费同一个交换器）

image.png

2.消息中间件优点

解耦
用户下单后，订单系统需要通知库存系统。传统的做法是，订单系统调用库存系统的接口。
异步通信能力
注册功能发短信发邮件
缓冲
流量削峰：消息中间件像是一个巨大的蓄水池，将高峰期大量的请求存储下来慢慢交给后台进行处理，对于秒杀业务来说尤为重要
日志处理：将消息队列用在日志处理中，比如 Kafka 的应用，解决大量日志传输的问题。
伸缩性
消息通讯：
点对点通讯:客户端 A 和客户端 B 使用同一队列，进行消息通讯。
聊天室通讯:客户端 A，客户端 B，客户端 N 订阅同一主题，进行消息发布和接收。实现类似聊天室效果。
扩展性

3.消息中间件与RPC区别

依赖性
比如发短信服务，RPC 调用，短信通知服务挂了，整个业务就挂了，这个就是依赖性导致的，而消息中间件则没有这个依赖性。
同步性
RPC 方式是典型的 ‘同步’ 方式，让远程调用像本地调用。消息中间件方式属于 ‘异步’ 方式。

4.消息中间件比较

image.png

5.rabbit消息确认

消费者收到的每一条消息都【必须】进行确认(自动确认和自行确认)。

【消费者】在声明【队列】时，可以指定 autoAck 参数，当 autoAck=false 时，RabbitMQ 会等待消费者显式发回 ack 信号后才从内存(和磁盘，如果是持久化消息的话)中移去消息。否则，RabbitMQ 会在队列中消息被消费后立即删除它。
采用消息确认机制后，只要令 autoAck=false，消费者就有足够的时间处理消息(任务)，不用担心处理消息过程中消费者进程挂掉后消息丢失的问题，因为 RabbitMQ 会一直持有消息直到消费者显式调用 basicAck 为止。
RabbitMQ 不会为未 ack 的消息设置超时时间，它判断此消息是否需要重新投递给消费者的唯一依据是消费该消息的消费者连接是否已经断开。这么设计的原因是 RabbitMQ 允许消费者消费一条消息的时间可以很久很久。

如果消息达到无人订阅的队列会怎么办?
消息会一直在队列中等待，RabbitMq 默认队列是无限长度的。

多个消费者订阅到同一队列怎么办?
消息以循环的方式发送给消费者，每个消息只会发送给一个消费者。

消息路由到了不存在的队列怎么办?
一般情况下，凉拌，RabbitMq 会忽略，当这个消息不存在，也就是这消息丢了。

6.虚拟主机

虚拟消息服务器，vhost，本质上就是一个 mini 版的 mq 服务器，有自己的队列、交换器和绑定，最重要的，自己的权限机制。Vhost 提供了逻辑上的分离，可以将众多客户端进行区分，又可以避免队列和交换器的命名冲突。Vhost 必须在连接时指定，rabbitmq 包含缺省 vhost:“/”，通过缺省用户和口令 guest 进行访问。

7.交换机类型

共有四种 direct,fanout,topic,headers，其种 headers(几乎和 direct 一样)不实用，可以忽略。

direct

路由键完全匹配，消息被投递到对应的队列， direct 交换器是默认交换器。声明一个队列时，会自动绑定到默认交换器，并且以队列名称作为路由键:channel->basic_public($msg,’’,’queue-name’)

image.png

Fanout
消息广播到绑定的队列，不管队列绑定了什么路由键，消息经过交换器，每个队列都有一份。

image.png
Topic
通过使用“ * ”和“#”通配符进行处理，使来自不同源头的消息到达同一个队列，”.”将路由键分为了几个标识符，“*”匹配 1 个，“#”匹配一个或多个。

image.png

假设有交换器 topic_course，
数字有 one,two,three，
技术有 kafka,jvm,redis，
字母有 A、B、C，
路由键的规则为数字+“.”+技术+“.”+字母，如:one.kafka.A。
所有信息
channel.queueBind(queueName,TopicProducer.EXCHANGE_NAME, "#");
one所有信息
channel.queueBind(queueName,TopicProducer.EXCHANGE_NAME, "one.#");
one的A
channel.queueBind(queueName,TopicProducer.EXCHANGE_NAME, "one.#.A");
channel.queueBind(queueName,TopicProducer.EXCHANGE_NAME, "one.*.A");