RabbitMQ安装与启动
window安装
（1）下载并安装 Eralng
（2）下载并安装rabbitmq
双击安装，注意不要安装在包含中文和
空格的目录下！安装后window服务中就存在rabbitMQ了，并且是启动状态。
进入官网下载：https://www.rabbitmq.com/install-windows.html
3）安装管理界面（插件）
进入rabbitMQ安装目录的sbin目录，输入命令
rabbitmq‐plugins enable rabbitmq_management
（4）重新启动服务
（5）打开浏览器，地址栏输入http://127.0.0.1:15672 ,即可看到管理界面的登陆页
输入用户名和密码，都为guest 进入主界面
最上侧的导航以此是：概览、连接、信道、交换器、队列、用户管理
docker安装
下载镜像：
docker pull rabbitmq:management
创建容器，rabbitmq需要有映射以下端口: 5671 5672 4369 15671 15672 25672
15672 (if management plugin is enabled)
15671 management监听端口
5672, 5671 (AMQP 0-9-1 without and with TLS)
4369 (epmd) epmd 代表 Erlang 端口映射守护进程
25672 (Erlang distribution)
docker run -di --name=tensquare_rabbitmq -p 5671:5617 -p 5672:5672 -p
4369:4369 -p 15671:15671 -p 15672:15672 -p 25672:25672 rabbitmq:management
浏览器访问 http://xxxxxx:15672/#/
springboot引入rabbitmq依赖：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
编写配置文件application.yml
spring:
rabbitmq:
host: xxxxxx
直接模式（Direct）
什么是Direct模式
我们需要将消息发给唯一一个节点时使用这种模式，这是最简单的一种形式。
任何发送到Direct Exchange的消息都会被转发到RouteKey中指定的Queue。
1.一般情况可以使用rabbitMQ自带的Exchange：”"(该Exchange的名字为空字符串，下
文称其为default Exchange)。
2.这种模式下不需要将Exchange进行任何绑定(binding)操作
3.消息传递时需要一个“RouteKey”，可以简单的理解为要发送到的队列名字。
4.如果vhost中不存在RouteKey中指定的队列名，则该消息会被抛弃。
自我理解：消费者自己有指定的队列，生产者也有指定的队列通过routerkey经过rabbitmq默认的空exchange到相对应的队列中
生产者：
import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.amqp.rabbit.core.RabbitMessagingTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner; @RunWith(SpringRunner.class) @SpringBootTest(classes= Application.class) public class MqTest { @Autowired private RabbitMessagingTemplate rabbitTemplate; @Test public void testSend(){ rabbitTemplate.convertAndSend("queue1","我要红包"); } }
消费者：
import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; /** * 直接模式-消费者 */ @Component @RabbitListener(queues = "queue1") public class Consumer1 { @RabbitHandler public void sendMessage(String msg){ System.out.println("接收到的消息："+msg); } }
测试
开启多个消费者工程，测试运行消息生产者工程，会发现只有一个消费者工程可以接收到消息。
如何在IDEA中多次启动同一个程序呢？
（1）选择IDEA右上角的类名称按钮
（2）选择Edit Configurations
（3）在弹出窗口中取消单例模式 ，点击OK
（4）每次运行前修改application.yml，指定不同的端口
| server: |
运行后在控制台可以看到多个窗口
分列模式（Fanout）
什么是分列模式
当我们需要将消息一次发给多个队列时，需要使用这种模式。如下图：
任何发送到Fanout Exchange的消息都会被转发到与该Exchange绑定(Binding)的所有
Queue上。
1.可以理解为路由表的模式
2.这种模式不需要RouteKey
3.这种模式需要提前将Exchange与Queue进行绑定，一个Exchange可以绑定多个
Queue，一个Queue可以同多个Exchange进行绑定。
4.如果接受到消息的Exchange没有与任何Queue绑定，则消息会被抛弃 。
将相应队列绑定到fanout交换机上
个人理解：相应队列queue绑定到fanout交换机上，生产者往fanout交换机发送消息，绑定好的queue就都有消息了，消费者只要到指定的队列上去取就好了。
生产者：
@Test public void testSendFanout(){ rabbitTemplate.convertAndSend("exchange1","", "分列模式走起"); }
消费者：
创建消息监听类，用于监听queue2的消息
import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; /** * 分列模式-消费者 */ @Component @RabbitListener(queues = "queue2") public class Consumer2 { @RabbitHandler public void sendMessage(String msg){ System.out.println("queue2接收到的消息："+msg); } }
创建消息监听类，用于监听queue3的消息
import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; /** * 分列模式-消费者 */ @Component @RabbitListener(queues = "queue3") public class Consumer3 { @RabbitHandler public void sendMessage(String msg){ System.out.println("queue3接收到的消息："+msg); } }
测试
启动消费者工程，发送消息测试,两个都接受到了分裂模式走起消息。
主题模式（Topic）
什么是主题模式
任何发送到Topic Exchange的消息都会被转发到所有关心RouteKey中指定话题的Queue上
如上图所示
此类交换器使得来自不同的源头的消息可以到达一个对列，其实说的更明白一点就是模
糊匹配的意思，例如：上图中红色对列的routekey为usa.#，#代表匹配任意字符，但是
要想消息能到达此对列，usa.必须匹配后面的#好可以随意。图中usa.news
usa.weather,都能找到红色队列，符号 # 匹配一个或多个词，符号 * 匹配不多不少一个
词。因此 usa.# 能够匹配到 usa.news.XXX ，但是 usa.* 只会匹配到 usa.XXX 。
注：
交换器说到底是一个名称与队列绑定的列表。当消息发布到交换器时，实际上是由你所
连接的信道，将消息路由键同交换器上绑定的列表进行比较，最后路由消息。
任何发送到Topic Exchange的消息都会被转发到所有关心RouteKey中指定话题的
Queue上
1.这种模式较为复杂，简单来说，就是每个队列都有其关心的主题，所有的消息都带有一
个“标题”(RouteKey)，Exchange会将消息转发到所有关注主题能与RouteKey模糊匹配的
队列。
2.这种模式需要RouteKey，也需要提前绑定Exchange与Queue。
3.在进行绑定时，要提供一个该队列关心的主题，如“#.log.#”表示该队列关心所有涉及
log的消息(一个RouteKey为”MQ.log.error”的消息会被转发到该队列)。
“#”表示0个或若干个关键字，“”表示一个关键字。如“log.”能与“log.warn”匹配，无法与“log.warn.timeout”匹配；但是“log.#”能与上述两者匹配。
5.同样，如果Exchange没有发现能够与RouteKey匹配的Queue，则会抛弃此消息
创建topic类型的交换机，绑定相应队列，并添加相应routerkey的值。
queue1 routerkey值为： goods.#
queue2 routerkey值为：#.log
queue3 routerkey值为: goods.log
生产者：
@Test public void testSendTopic1(){ rabbitTemplate.convertAndSend("topictest","goods.aaa","主题模式"); } @Test public void testSendTopic2(){ rabbitTemplate.convertAndSend("topictest","article.content.log","主题模式"); @Test public void testSendTopic3(){ rabbitTemplate.convertAndSend("topictest","goods.log","主题模式"); }
测试结果：