第二篇我们简单介绍下RabbitMQ的一些消息传递模式：

1、直接模式（Direct）

  （1）直接模式简介

我们需要将消息发给唯一一个节点时使用这种模式，这是最简单的一种形式。

任何发送到Direct Exchange的消息都会被转发到RouteKey中指定的Queue。
1.一般情况可以使用rabbitMQ自带的Exchange：”"(该Exchange的名字为空字符串，下文称其为default Exchange)。
2.这种模式下不需要将Exchange进行任何绑定(binding)操作。
3.消息传递时需要一个“RouteKey”，可以简单的理解为要发送到的队列名字。
4.如果vhost中不存在RouteKey中指定的队列名，则该消息会被抛弃。 

  （2）创建队列 

做下面的例子前，我们先建立一个叫itcast的队列。

Durability：是否做持久化 Durable（持久） transient（临时）
Auto delete : 是否自动删除 

  （3）代码实现---消息生产者

       一、创建工程rabbitmq_demo，引入amqp起步依赖 ，pom.xml如下：

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring‐boot‐starter‐parent</artifactId>
    <version>2.0.1.RELEASE</version>
<relativePath/>
</parent>
<properties>
    <project.build.sourceEncoding>UTF‐8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF‐8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring‐boot‐starter‐amqp</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring‐boot‐starter‐test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

      二、编写配置文件application.yml

spring:
  rabbitmq:
    host: 192.168.184.134

      三、编写启动类 

@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class);
    }
}

      四、编写测试类

@RunWith(SpringRunner.class)
@SpringBootTest(classes=Application.class)
public class MqTest {

    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Test
    public void testSend(){
        rabbitTemplate.convertAndSend("test","测试");
    }
}

  （4）代码实现---消息消费者 

      一、编写消息消费者类

@Component
@RabbitListener(queues="test" )
public class Customer1 {

    @RabbitHandler
    public void showMessage(String message){
        System.out.println("itcast接收到消息："+message);
    }
}

      二、运行启动类，可以在控制台看到刚才发送的消息 

2、分列模式（Fanout） 

  （1）分列模式简介

当我们需要将消息一次发给多个队列时，需要使用这种模式。如下图：

任何发送到Fanout Exchange的消息都会被转发到与该Exchange绑定(Binding)的所有
Queue上。
1.可以理解为路由表的模式
2.这种模式不需要RouteKey
3.这种模式需要提前将Exchange与Queue进行绑定，一个Exchange可以绑定多个Queue，一个Queue可以同多个Exchange进行绑定。
4.如果接受到消息的Exchange没有与任何Queue绑定，则消息会被抛弃。 

  （2）交换器绑定队列

      一、在queue中添加队列itheima 和kudingyu

      二、新建交换器chuanz（不清楚的再回顾下上个章节）

      三、将itcast 和itheima两个队列绑定到交换器chuanzhi 

      点击chuanzhi进入交换器管理界面 

      点击Bindings添加绑定 itheima和kudingyu 

      绑定后效果如下：

  （2） 代码实现---消息生产者

@Test
public void testSendFanout(){
    rabbitTemplate.convertAndSend("chuanzhi","", "分列模式test");
}

 （3）代码实现---消息消费者

      一、创建消息监听类，用于监听itheima的消息

@Component
@RabbitListener(queues="itheima" )
public class Customer2 {

    @RabbitHandler
    public void showMessage(String message){
        System.out.println("itheima接收到消息："+message);
    }
}

      二、创建消息监听类，用于监听kudingyu的消息 

@Component
@RabbitListener(queues="kudingyu" )
public class Customer3 {

    @RabbitHandler
    public void showMessage(String message){
        System.out.println("kudingyu接收到消息："+message);
    }
}

  （4）测试 ，可以在控制台看到两条消息

3、主题模式（Topic） 

  （1）主题模式简介

任何发送到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”的消息会被转发到该队列)。
4.“#”表示0个或若干个关键字，“”表示一个关键字。如“log.”能与“log.warn”匹配，无法与“log.warn.timeout”匹配；但是“log.#”能与上述两者匹配。
5.同样，如果Exchange没有发现能够与RouteKey匹配的Queue，则会抛弃此消息 。

  （2）创建队列与绑定

      一、新建一个交换器 ，类型选择topic

      二、点击新建的交换器topictest 

      添加匹配规则，添加后列表如下： 

  （2）代码实现 

      一、编写测试类方法：

@Test
public void testSendTopic1(){
    rabbitTemplate.convertAndSend("topictest","goods.aaa","主题模式");
}

      二、输出结果：itcast接收到消息：主题模式 

@Test
public void testSendTopic2(){
    rabbitTemplate.convertAndSend("topictest","article.content.log","主题模式");
}

      三、 输出结果：itheima接收到消息：主题模式

@Test
public void testSendTopic3(){
    rabbitTemplate.convertAndSend("topictest","goods.log","主题模式");
}

     四、 输出结果：

itheima接收到消息：主题模式
itcast接收到消息：主题模式
kudingyu接收到消息：主题模式

至此，RabbitMQ的三种消息传递模式已经介绍完成，各位童鞋动手操作下。