涉及概念解释： 
 Server(Broker):接收客户端连接，实现AMQP协议的消息队列和路由功能的进程；

Virtual Host：虚拟主机的概念，类似权限控制组，一个Virtual Host里可以有多个Exchange和Queue。

Exchange:交换机，接收生产者发送的消息，并根据Routing Key将消息路由到服务器中的队列Queue。（这个有点类似于Nginx服务器的概念）

ExchangeType:交换机类型决定了路由消息行为，RabbitMQ中有三种类型Exchange，分别是fanout、direct、topic；

Message Queue：消息队列，用于存储还未被消费者消费的消息；

Message：由Header和body组成，Header是由生产者添加的各种属性的集合，包括Message是否被持久化、优先级是多少、由哪个Message Queue接收等；body是真正需要发送的数据内容；

BindingKey：绑定关键字，将一个特定的Exchange和一个特定的Queue绑定起来。

消息中的路由键（routing key）如果和 Binding 中的 binding key 一致， 交换器就将消息发到对应的队列中。路由键与队列名完全匹配，如果一个队列绑定到交换机要求路由键为“dog”，则只转发 routing key 标记为“dog”的消息，不会转发“dog.puppy”，也不会转发“dog.guard”等等。它是完全匹配、单播的模式。

每个发到 fanout 类型交换器的消息都会分到所有绑定的队列上去。fanout 交换器不处理路由键，只是简单的将队列绑定到交换器上，每个发送到交换器的消息都会被转发到与该交换器绑定的所有队列上。很像子网广播，每台子网内的主机都获得了一份复制的消息。fanout 类型转发消息是最快的。

topic 交换器通过模式匹配分配消息的路由键属性，将路由键和某个模式进行匹配，此时队列需要绑定到一个模式上。

它将路由键和绑定键的字符串切分成单词，这些单词之间用点隔开。它同样也会识别两个通配符：符号“#”和符号“*”。#匹配0个或多个单词，*匹配一个单词。

> docker pull registry.docker-cn.com/library/rabbitmq:3-management

> docker run -d -p 5672:5672 -p 15672:15672 --name brian_rabbitmq xxxxxx(镜像name或者镜像ID)

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

package com.kawa.mq;
​
import com.kawa.config.Contents;
import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
​
@Service
public class ManageMQService {
​@AutowiredAmqpAdmin amqpAdmin;
​public void createExchange(String exchangeName,String mqType){if(mqType.equals(Contents.DIRECT_EXCHANGE)){amqpAdmin.declareExchange(new DirectExchange(exchangeName));}if(mqType.equals(Contents.FANOUT_EXCHANGE)){amqpAdmin.declareExchange(new FanoutExchange(exchangeName));}if(mqType.equals(Contents.TOPIC_EXCHANGE)){amqpAdmin.declareExchange(new TopicExchange(exchangeName));}}
​public void removeExchange(String exchangeName){amqpAdmin.deleteExchange(exchangeName);}
​public void createQueue(String queueName){amqpAdmin.declareQueue(new Queue(queueName,true));}
​public void removeQueue(String queueName){amqpAdmin.deleteQueue(queueName);}
​public void createBinding(String queueName, String exchangeName, String routingKey){amqpAdmin.declareBinding(new Binding(queueName, Binding.DestinationType.QUEUE,exchangeName,routingKey,null));}
​public void removeBinding(String queueName, String exchangeName, String routingKey){amqpAdmin.removeBinding(new Binding(queueName, Binding.DestinationType.QUEUE,exchangeName,routingKey,null));}
}

package com.kawa.mq;import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class SendMessageService {@AutowiredRabbitTemplate rabbitTemplate;public void sendMessage(String exchange,String routingKey,Object obj){//Message需要自己构造一个；定义消息体和消息头//rabbitTemplate.send(exchange,routingKey,message);//object默认当成消息体，只需要传入发送对象，自动序列化发送给rabbitmq
        rabbitTemplate.convertAndSend(exchange,routingKey,obj);}}

 @Testpublic void sendMessage() {manageMQService.createQueue("brian.test");manageMQService.createExchange("brian",Contents.DIRECT_EXCHANGE);manageMQService.createBinding("brian.test","brian","mymq");Brian brian = new Brian();User user = new User();user.setId((long) 12345678);user.setUsername("cassiel");user.setPassword("#fyds");List<String> list = new ArrayList<>();list.add("我");list.add("爱");list.add("你");list.add("中");list.add("国");Map<String,Object> map = new HashMap<>();map.put("123","包邮");brian.setKawadate(new Date());brian.setLists(list);brian.setObj(map);brian.setUser(user);sendMessageService.sendMessage("brian","mymq",brian);}

package com.kawa.sercice;import com.kawa.pojo.Brian;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;@Service
public class BrianService {@RabbitListener(queues = "brian.test")public void receiveMessage(Brian brian){System.out.println("接收到的消息体:" + brian);}
}