RabbitMQ简介
RabbitMQ是一个由erlang开发的AMQP(Advanved Mesaage Queue Protocol)的开源实现。
核心概念
Message:消息，消息是不具名的，它由消息头和消息体组成。消息体是不透明的，而消息头则由一系列的可选属性组成，这些属性包括rounting-key(路由键)、priority(相对于其他消息的优先权)、delivery-mode(指出该消息可能需要持久性存储)等。
Publisher
消息的生产者，也是一个向交换器发布消息的客户端应用程序。
Exchange
交换器，用来接收生产者发送的消息将这些消息路由给服务器中的队列。
Exchange有4种类型：direct(默认),fanout,topic(主题)和headers,不同类型的Exchang转发消息的策略有所区别
Queue
消息队列，用来保存消息直到发送给消费者。它是消费的容器，也是消息的终点。一个消息可投入一个或多个队列。消息一直在队列里面，等待消费者连接到这个队列将其取走。
Binding
绑定，用于消息队列和交换器之间的关联。一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则，所以可以将交换器理解成一个由绑定构成的路由表。
Exchange和Queue的绑定可以是多对多的关系。
Connection
网络连接，比如一个TCP连接。
Channel
信道，多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内的虚拟连接，AMQP命令都是通过信道发出去的，不管是发布消息、订阅队列还是接收消息，这些动作是通过信道完成。因为对于操作系统来说建立和销毁TCP都是非常昂贵的开销，所以引入了信道的概念，以复用一条TCP连接。
Consumer
消息的消费者，表示一个从消息队列中取得消息的客户端应用程序。
Virtual Host
虚拟主机，表示一批交换器、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个vhost本质上就是一个mini版的RabbitMQ服务器，拥有自己的队列、交换器、绑定和权限机制。vhost是AMQP概念的基础，必须在连接时指定，RabbitMQ默认的vhost是 /。
Broker
表示消息队列服务器实体
RabbitMQ运行机制
AMQP中的消息路由
AMQP中消息的路由过程和Java开发者熟悉的JMS存在一些差别，AMQP中增加了Exchange和Binding的角色。生产者把消息发布到Exchange上，消息最终到达队列并被消费者接收，而Binding决定交换器的消息应该发送到那个队列。
Exchange类型
Exchange分发消息时根据类型的不同分发策略有区别，目前共四种类型：direct、fanout、topic、headers。headers匹配AMQP消息的header而不是路由键，headers交换器和direct交换器完全一致，但性能差很多，目前几乎用不到了，所以直接看另外三种类型：
消息中的路由键(rounting key) 如果和Binding中的binding key 一致，交换器就将消息发到对应的队列中。路由键与队列名完全匹配，如果一个队列绑定到交换机要求路由键为"dog",则只转发routing key 标记为 "dog" 的消息，不会转发"dog.puppy",也不会转发"dog.guard"等等。 它是完全匹配、单播的模式
RabbitMQ整合
1.引入spring-boot-starter-amqp
2.application.yml配置
3.测试RabbitMQ
1.AmqpAdmin：管理组件
2.RabbitTemplate:消息发送处理组件
示例代码：
/**
* 发送方
* 单点(点对点)
*/
@Test
public void contextLoadsRabbitMq(){
//Message需要自己构造一个;定义消息体内容和消息头
//rabbitTemplate.send(exchange,routeKey,message);
//Object默认当成消息体，只需要转入要发送的对象，自动序列化发送给rabbitmq
//rabbitTemplatec.convertAndSend(exchage,routeKey,object);
Map map =new HashMap<>();
map.put("msg","这是第一个消息");
map.put("data", Arrays.asList("helloWold",123456,true));
//路由键atguigu.news
rabbitTemplate.convertAndSend("exchange.direct","atguigu.news",map);
}
/**
* 接收方
*/
public void receive(){
//接收路由键,atguigu.news
Object a =rabbitTemplate.receiveAndConvert("atguigu.news");
System.out.println(a.getClass());
System.out.println(a);
}
/**
* 广播
*/
public void sendMessage(){
rabbitTemplate.convertAndSend("exchange.direct","",new Book("西游记","罗贯中"));
}
