RabbitMQ消息服务器主要解决应用程序之间异步消息传输问题，传统的MQ分为点对点和主题与订阅，RabbitMQ使用Exchange（交换机）实现更加灵活的消息传递。

前面介绍过几个概念，RoutingKey，Binding，Queue,Exchange,

Binding将Exchange和Queue绑定在一起，Exchange是交换机，Queue是消息队列，Exchange的四种类型决定如何将生产者的消息分发到Queue上。

RoutingKey是路由关键字，生产者根据RoutingKey决定将消息发送到哪个Exchange上，进而由Exchange决定将消息发送到哪个Queue上，消费者就可以从Queue获得消息。

 

交换机类型Direct

将符合Routing Key匹配到指定的Exchange，进而到指定的Queue上，类似点对点

交换机类型Fanout

忽略Routing Key，将消息发送到所有与Exchange绑定的Queue上，类似广播

交换机类型Topic

是根据统配符投递消息

*匹配一个单词，#匹配一个或多个单词

交换机类型Headers

类似Direct，只是不再使用RoutingKey匹配投递，而是使用headers中消息属性匹配Queue

 

下面的例程是使用Direct类型的交换机

 

编写消息生产者，需要在生产者中定义或使用Exchange和Queue

运行后，通过RabbitMQ控制台可以看到

我们看到消息队列TestQueue中有一条消息。

 

编写消息消费者，

需要在生产者中定义或使用Exchange和Queue

运行消费者程序后，查看RabbitMQ管理台，发现消息消失了。

 

Java使用RabbitMQ必须下载RabbitMQ客户端类库，这里使用的是amqp-client-3.2.2.jar版本，为了方便使用类库，还需要下载API amqp-client-3.2.2-javadoc.jar

 

API解图

 

这里两个文件，可以通过云盘下载：

https://pan.baidu.com/s/1miBtbRi

 

 

程序代码下载

https://pan.baidu.com/s/1dF4fGOh