springboot集成rabbitmq

我不是女神ヾ 2022-05-23 07:55 331阅读 0赞

RabbitMQ简介  
RabbitMQ使用Erlang语言开发的开源消息队列系统，基于AMQP协议来实现（AMQP的主要特征是面向消息、队列、路由、可靠性、安全）。支持多种客户端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现很出色。

**相关概念**

消息队列通常有三个概念：发送消息（生产者）、队列、接收消息（消费者）。RabbitMQ在这个基本概念之上，多做了一层抽象，在发送消息和队列之间，加入了交换机。这样发送消息和队列就没有直接关系，而是通过交换机来做转发，交换机会根据分发策略把消息转给队列。

图一（MQ基本模型）：

P为发送消息（生产者）、Q为消息队列、C为接收消息（消费者）

图二（RabbitMQ模型）：

P为发送消息（生产者）、X为交换机、Q为消息队列、C为接收消息（消费者）

![1308658-20180521182608882-979039140.png][]　　 ![1308658-20180521182545059-1155725091.png][]

图一 　　　　　　　　　　　　　　　　　　　　　　　　　　　　图二

**RabbitMQ比较重要的几个概念：**

虚拟主机：RabbitMQ支持权限控制，但是最小控制粒度为虚拟主机。一个虚拟主机可以包含多个交换机、队列、绑定。

交换机：RabbitMQ分发器，根据不同的策略将消息分发到相关的队列。

队列：缓存消息的容器。

绑定：设置交换机与队列的关系。

**是时候表演真正的技术了**

为了方便演示，我们分别创建两个springboot项目：

spring-boot-rabbitmq-producer（生产者）

spring-boot-rabbitmq-consumer（消费者）

注意：实际项目中，一个系统可能即为生产者、又为消费者。

**1.添加基础配置**

生产者、消费者基础配置相同。

1.1）集成rabbitmq，添加maven依赖

![复制代码][copycode.gif]

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        
        <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>

![复制代码][copycode.gif]

1.2）添加rabbitmq服务配置（application.properties）

#rabbitmq相关配置
    spring.rabbitmq.host=192.168.15.131
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=admin
    spring.rabbitmq.password=123456

**2.交换机——DirectExchange**

DirectExchange是RabbitMQ的默认交换机，直接使用routingKey匹配队列。

![1308658-20180515095018484-830578829.png][]

2.1）添加一个配置类（消费者）

配置一个routingKey为notify.payment的消息队列

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Configuration</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>DirectConfig { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@Bean</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code> 
      <code>Queue paymentNotifyQueue() { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>return</code> 
      <code>new</code> 
      <code>Queue(</code> 
      <code>"notify.payment"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

2.2）添加一个消息监听类（消费者）

监听routingKey为notify.payment的队列消息

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Component</code> 
     </div> 
     <div> 
      <code>@RabbitListener</code> 
      <code>(queues = </code> 
      <code>"notify.payment"</code> 
      <code>)</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>PaymentNotifyReceive { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@RabbitHandler</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>receive(String msg) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>LogUtil.info(</code> 
      <code>"notify.payment receive message: "</code> 
      <code>+msg);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

2.3）添加一个消息发送类（生产者）

将消息发送至默认的交换机且routingKey为notify.payment

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Component</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>PaymentNotifySender { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@Autowired</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>private</code> 
      <code>AmqpTemplate rabbitTemplate;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>sender(String msg){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>LogUtil.info(</code> 
      <code>"notify.payment send message: "</code> 
      <code>+msg);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>rabbitTemplate.convertAndSend(</code> 
      <code>"notify.payment"</code> 
      <code>, msg);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

2.4）添加一个测试类（生产者）

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@RunWith</code> 
      <code>(SpringRunner.</code> 
      <code>class</code> 
      <code>)</code> 
     </div> 
     <div> 
      <code>@SpringBootTest</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>PaymentNotifySenderTests { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@Autowired</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>private</code> 
      <code>PaymentNotifySender sender;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@Test</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>test_sender() { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>sender.sender(</code> 
      <code>"支付订单号："</code> 
      <code>+System.currentTimeMillis());</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

2.5）执行test\_sender()方法

生产者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:28:53.264&nbsp; INFO 10624 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.PaymentNotifySenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Starting PaymentNotifySenderTests on LAPTOP-1DF7S904 with PID 10624 (started by lianjinsoft...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:28:53.265&nbsp; INFO 10624 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.PaymentNotifySenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : No active profile set, falling back to default profiles: default</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:28:53.305&nbsp; INFO 10624 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:28:54.133&nbsp; INFO 10624 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration' of type ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:28:55.104&nbsp; INFO 10624 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Starting beans in phase 2147483647</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:28:55.114&nbsp; INFO 10624 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.PaymentNotifySenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Started PaymentNotifySenderTests in 2.246 seconds (JVM running for 3.199)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:28:55.343&nbsp; INFO 10624 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：1526286535342</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:28:55.383&nbsp; INFO 10624 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Attempting to connect to: [192.168.15.131:5672]</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:28:55.444&nbsp; INFO 10624 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Created new connection: rabbitConnectionFactory#38be305c:0/SimpleConnection@71984c3 ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:28:55.483&nbsp; INFO 10624 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] s.c.a.AnnotationConfigApplicationContext : Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@7eac9008: ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:28:55.485&nbsp; INFO 10624 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Stopping beans in phase 2147483647</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

消费者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:28:55.490&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：1526286535342</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

分析日志：

从生产者日志第7行可以看出，消息已经成功发送。

从消费者日志可以看出，消息已经成功接收。

**3.交换机——TopicExchange**

TopicExchange是按规则转发消息，是交换机中最灵活的一个。也是最常用的一个。

![1308658-20180515095821882-1047782467.png][]

3.1）添加一个配置类（消费者）

配置一个routingKey为api.core的消息队列并绑定在coreExchange交换机上（交换机的匹配规则为api.core.\*）

配置一个routingKey为api.payment的消息队列并绑定在paymentExchange交换机上（交换机的匹配规则为api.payment.\#）

3.2）添加两个消息监听类（消费者）

监听routingKey为api.core的队列消息

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Component</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>ApiCoreReceive { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@RabbitHandler</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@RabbitListener</code> 
      <code>(queues = </code> 
      <code>"api.core"</code> 
      <code>)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>user(String msg) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>LogUtil.info(</code> 
      <code>"api.core receive message: "</code> 
      <code>+msg);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

监听routingKey为api.payment的队列消息

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Component</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>ApiPaymentReceive { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@RabbitHandler</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@RabbitListener</code> 
      <code>(queues = </code> 
      <code>"api.payment"</code> 
      <code>)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>order(String msg) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>LogUtil.info(</code> 
      <code>"api.payment.order receive message: "</code> 
      <code>+msg);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

3.3）添加两个消息发送类（生产者）

添加一个user()方法，发送消息至coreExchange交换机且routingKey为api.core.user

添加一个userQuery()方法，发送消息至coreExchange交换机且routingKey为api.core.user.query

添加一个order()方法，发送消息至paymentExchange交换机且routingKey为api.payment.order

添加一个orderQuery()方法，发送消息至paymentExchange交换机且routingKey为api.payment.order.query

添加一个orderDetailQuery()方法，发送消息至paymentExchange交换机且routingKey为api.payment.order.detail.query

3.4）添加两个测试类（生产者）

测试ApiCoreSender类中的相关方法

测试ApiPaymentSender类中的相关方法

3.5）验证

3.5.1）执行ApiCoreSenderTests测试类

生产者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:30:05.804&nbsp; INFO 7340 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.lianjinsoft.sender.ApiCoreSenderTests&nbsp; : Starting ApiCoreSenderTests on LAPTOP-1DF7S904 with PID 7340 (started by lianjinsoft in ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:30:05.805&nbsp; INFO 7340 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.lianjinsoft.sender.ApiCoreSenderTests&nbsp; : No active profile set, falling back to default profiles: default</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:30:05.851&nbsp; INFO 7340 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@1e800aaa: ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:30:06.553&nbsp; INFO 7340 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration' of type ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:30:07.375&nbsp; INFO 7340 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Starting beans in phase 2147483647</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:30:07.385&nbsp; INFO 7340 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.lianjinsoft.sender.ApiCoreSenderTests&nbsp; : Started ApiCoreSenderTests in 1.922 seconds (JVM running for 2.846)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:30:07.431&nbsp; INFO 7340 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : api.core.user send message: 用户管理！</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:30:07.463&nbsp; INFO 7340 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Attempting to connect to: [192.168.15.131:5672]</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:30:07.578&nbsp; INFO 7340 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Created new connection: rabbitConnectionFactory#56ace400:0/SimpleConnection@773cbf4f...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:30:07.647&nbsp; INFO 7340 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : api.core.user.query send message: 查询用户信息！</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:30:07.716&nbsp; INFO 7340 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] s.c.a.AnnotationConfigApplicationContext : Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@1e800aaa: ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:30:07.728&nbsp; INFO 7340 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Stopping beans in phase 2147483647</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

消费者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:30:07.609&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : api.core receive message: 用户管理！</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

分析日志：

从生产者日志第7、10行可以看出，api.core.user和api.core.user.query消息均已发送成功。

从消费者日志可以看出，只有api.core.user发送的消息被收到了。

问题：

为什么api.core.user.query发送的消息没有被api.core队列监听消费？

答：因为在TopicConfig配置类中，我们对api.core队列绑定的交换机规则是api.core.\*，而通配符“\*”只能向后多匹配一层路径。

3.5.2）执行ApiPaymentSenderTests测试类

生产者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> 
    <div>
      13 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:31:12.823&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.ApiPaymentSenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Starting ApiPaymentSenderTests on LAPTOP-1DF7S904 with PID 6460 (started by lianjinsoft in ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:12.823&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.ApiPaymentSenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : No active profile set, falling back to default profiles: default</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:12.857&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@1e800aaa: ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:13.718&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration' of type ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:14.530&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Starting beans in phase 2147483647</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:14.539&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.ApiPaymentSenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Started ApiPaymentSenderTests in 2.05 seconds (JVM running for 2.945)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:14.592&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : api.payment.order.query send message: 查询订单信息！</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:14.638&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Attempting to connect to: [192.168.15.131:5672]</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:14.762&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Created new connection: rabbitConnectionFactory#47404bea:0/SimpleConnection@6b54655f ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:14.819&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : api.payment.order.detail.query send message: 查询订单详情信息！</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:14.825&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : api.payment.order send message: 订单管理！</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:14.836&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] s.c.a.AnnotationConfigApplicationContext : Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@1e800aaa: ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:14.840&nbsp; INFO 6460 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Stopping beans in phase 2147483647</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

消费者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:31:14.809&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : api.payment.order receive message: 查询订单信息！</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:14.821&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : api.payment.order receive message: 查询订单详情信息！</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:31:14.829&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : api.payment.order receive message: 订单管理！</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

分析日志：

从生产者日志第7、10、11行可以看出，api.payment.order.query、api.payment.order.detail.query、api.payment.order消息均发送成功。

从消费者日志可以看出，api.payment.order队列监听到了所有消息并均处理成功了。

**知识点：**

TopicExchange交换机支持使用通配符\*、\#

\*号只能向后多匹配一层路径。

\#号可以向后匹配多层路径。

**4.交换机——HeadersExchange**

HeadersExchange交换机是根据请求消息中设置的header attribute参数类型来匹配的（和routingKey没有关系）。

4.1）添加一个配置类（消费者）

配置一个routingKey为credit.bank的消息队列并绑定在creditBankExchange交换机上

配置一个routingKey为credit.finance的消息队列并绑定在creditFinanceExchange交换机上

4.2）添加一个消息监听类（消费者）

添加creditBank()方法，监听routingKey为credit.bank的队列消息

添加creditFinance()方法，监听routingKey为credit.finance的队列消息

4.3）添加一个消息发送类（生产者）

添加一个creditBank()方法，发送消息至creditBankExchange交换机且routingKey为credit.bank

添加一个creditFinance()方法，发送消息至creditFinanceExchange交换机且routingKey为credit.finance

4.4）添加一个测试类（生产者）

4.5）执行ApiCreditSenderTests测试类

生产者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> 
    <div>
      13 
    </div> 
    <div>
      14 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:32:18.954&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.ApiCreditSenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Starting ApiCreditSenderTests on LAPTOP-1DF7S904 with PID 5204 (started by lianjinsoft in...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:18.964&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.ApiCreditSenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : No active profile set, falling back to default profiles: default</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:19.007&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@1e800aaa: ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:19.609&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration' of type ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:20.437&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Starting beans in phase 2147483647</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:20.446&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.ApiCreditSenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Started ApiCreditSenderTests in 1.839 seconds (JVM running for 2.759)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:20.566&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : credit.bank send message: 银行授信(部分匹配)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:20.574&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Attempting to connect to: [192.168.15.131:5672]</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:20.666&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Created new connection: rabbitConnectionFactory#56ace400:0/SimpleConnection@773cbf4f...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:21.064&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : credit.finance send message: 金融公司授信(全部匹配)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:21.070&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : credit.bank send message: 银行授信(全部匹配)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:21.077&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : credit.finance send message: 金融公司授信(部分匹配)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:21.109&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] s.c.a.AnnotationConfigApplicationContext : Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@1e800aaa: ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:21.114&nbsp; INFO 5204 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Stopping beans in phase 2147483647</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

消费者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:32:21.093&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : credit.finance receive message: 金融公司授信(全部匹配)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:21.094&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : credit.bank receive message: 银行授信(全部匹配)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:32:21.097&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : credit.finance receive message: 金融公司授信(部分匹配)</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

分析日志：

通过生产者日志第7、10、11、12可以看出，测试的4个方法均已成功发送消息。

通过消费者日志可以看出，credit.bank监听的队列有一条消息没有接收到。

问题：

为什么ApiCreditSenderTests.test\_creditBank\_type()发送的消息，没有被处理？

答：因为在HeadersConfig配置类中，creditBankExchange交换机的匹配规则是完全匹配，即header attribute参数必须完成一致。

**5.交换机——FanoutExchange**

FanoutExchange交换机是转发消息到所有绑定队列（广播模式，和routingKey没有关系）。

5.1）添加一个配置类（消费者）

配置一个routingKey为api.report.payment的消息队列并绑定在reportExchange交换机上

配置一个routingKey为api.report.refund的消息队列并绑定在reportExchange交换机上

5.2）添加一个消息监听类（消费者）

添加payment()方法，监听routingKey为api.report.payment的队列消息

添加refund()方法，监听routingKey为api.report.refund的队列消息

5.3）添加一个消息发送类（生产者）

添加一个generateReports()方法，发送消息至reportExchange交换机

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Component</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>ApiReportSender { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@Autowired</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>private</code> 
      <code>AmqpTemplate rabbitTemplate;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>generateReports(String msg){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>LogUtil.info(</code> 
      <code>"api.generate.reports send message: "</code> 
      <code>+msg);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>rabbitTemplate.convertAndSend(</code> 
      <code>"reportExchange"</code> 
      <code>, </code> 
      <code>"api.generate.reports"</code> 
      <code>, msg);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

5.4）添加一个测试类（生产者）

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@RunWith</code> 
      <code>(SpringRunner.</code> 
      <code>class</code> 
      <code>)</code> 
     </div> 
     <div> 
      <code>@SpringBootTest</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>ApiReportSenderTests { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@Autowired</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>private</code> 
      <code>ApiReportSender sender;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@Test</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>test_generateReports() { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>sender.generateReports(</code> 
      <code>"开始生成报表！"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

5.5）执行ApiReportSenderTests测试类

生产者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:33:41.453&nbsp; INFO 14356 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.ApiReportSenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Starting ApiReportSenderTests on LAPTOP-1DF7S904 with PID 14356 (started by lianjinsoft in ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:33:41.454&nbsp; INFO 14356 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.ApiReportSenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : No active profile set, falling back to default profiles: default</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:33:41.490&nbsp; INFO 14356 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@1e800aaa: ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:33:42.094&nbsp; INFO 14356 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration' of type...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:33:42.960&nbsp; INFO 14356 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Starting beans in phase 2147483647</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:33:42.972&nbsp; INFO 14356 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.ApiReportSenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Started ApiReportSenderTests in 1.939 seconds (JVM running for 2.843)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:33:43.037&nbsp; INFO 14356 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : api.generate.reports send message: 开始生成报表！</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:33:43.054&nbsp; INFO 14356 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Attempting to connect to: [192.168.15.131:5672]</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:33:43.174&nbsp; INFO 14356 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Created new connection: rabbitConnectionFactory#56ace400:0/SimpleConnection@773cbf4f...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:33:43.237&nbsp; INFO 14356 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] s.c.a.AnnotationConfigApplicationContext : Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@1e800aaa:...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:33:43.240&nbsp; INFO 14356 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Stopping beans in phase 2147483647</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

消费者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:33:43.205&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : api.report.payment receive message: 开始生成报表！</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:33:43.207&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : api.report.refund receive message: 开始生成报表！</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

分析日志：

通过生产者日志第7行可以看出，消息已发送成功。

通过消费者日志可以看出，api.report.payment和api.report.refund队列均收到了同一个消息。

**6.多对一**

在实际项目中，我们的系统通常会做集群、分布式或灾备部署。那么就会出现一对多、多对一或多对多的场景。

那么咱们本地如何模拟多对一呢？

6.1）为了测试方便，我们复用PaymentNotifyReceive案例，在PaymentNotifySenderTests测试类中，增加测试方法

test\_sender\_many2one\_1：请求参数为偶数

test\_sender\_many2one\_2：请求参数为奇数

6.2）执行test\_sender\_many2one\_1()、test\_sender\_many2one\_2()方法

生产者1日志：

生产者2日志：

消费者日志：

分析日志：

从生产者1、生产者2日志中可以看出，所有消息均已经发送成功。

从消费者日志可以看出，所有消息均被成功接收处理。

**7.一对多**

如何模拟一对多？

7.1）为了测试方便，我们继续复用PaymentNotifyReceive案例，在PaymentNotifySenderTests测试类中，增加测试方法

test\_sender\_one2many：循环调用20次。

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Test</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>void</code> 
      <code>test_sender_one2many() { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>for</code> 
      <code>(</code> 
      <code>int</code> 
      <code>i = </code> 
      <code>0</code> 
      <code>; i &lt; </code> 
      <code>20</code> 
      <code>; i++) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>sender.sender(</code> 
      <code>"支付订单号："</code> 
      <code>+i);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

7.2）测试

为了达到一对多的效果，我们需要多启动一个（或多个）消费者。然后执行test\_sender\_one2many()测试方法。

生产者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> 
    <div>
      13 
    </div> 
    <div>
      14 
    </div> 
    <div>
      15 
    </div> 
    <div>
      16 
    </div> 
    <div>
      17 
    </div> 
    <div>
      18 
    </div> 
    <div>
      19 
    </div> 
    <div>
      20 
    </div> 
    <div>
      21 
    </div> 
    <div>
      22 
    </div> 
    <div>
      23 
    </div> 
    <div>
      24 
    </div> 
    <div>
      25 
    </div> 
    <div>
      26 
    </div> 
    <div>
      27 
    </div> 
    <div>
      28 
    </div> 
    <div>
      29 
    </div> 
    <div>
      30 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:36:27.703&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.PaymentNotifySenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Starting PaymentNotifySenderTests on LAPTOP-1DF7S904 with PID 7508 (started by lianjinsoft in...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:27.704&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.PaymentNotifySenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : No active profile set, falling back to default profiles: default</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:27.729&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@7eac9008:...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:28.391&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration' of type...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.285&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Starting beans in phase 2147483647</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.303&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.PaymentNotifySenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Started PaymentNotifySenderTests in 2.197 seconds (JVM running for 3.097)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.504&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：0</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.516&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Attempting to connect to: [192.168.15.131:5672]</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.635&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Created new connection: rabbitConnectionFactory#4f071df8:0/SimpleConnection@42a9e5d1...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.672&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：1</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.679&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：2</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.705&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：3</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.707&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：4</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.710&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：5</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.710&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：6</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.710&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：7</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.713&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：8</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.719&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：9</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.728&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：10</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.729&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：11</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.733&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：12</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.734&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：13</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.734&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：14</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.734&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：15</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.741&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：16</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.742&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：17</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.742&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：18</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.744&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment send message: 支付订单号：19</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.762&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] s.c.a.AnnotationConfigApplicationContext : Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@7eac9008:...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.767&nbsp; INFO 7508 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Stopping beans in phase 2147483647</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

消费者1日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:36:29.675&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：0</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.690&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：2</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.712&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：4</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.714&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：6</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.728&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：9</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.733&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：11</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.737&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：13</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.740&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：15</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.743&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：16</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.745&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：18</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

消费者2日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:36:29.705&nbsp; INFO 13448 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：1</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.709&nbsp; INFO 13448 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：3</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.712&nbsp; INFO 13448 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：5</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.718&nbsp; INFO 13448 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：7</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.722&nbsp; INFO 13448 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：8</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.731&nbsp; INFO 13448 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：10</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.736&nbsp; INFO 13448 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：12</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.738&nbsp; INFO 13448 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：14</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.744&nbsp; INFO 13448 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：17</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:36:29.747&nbsp; INFO 13448 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.payment receive message: 支付订单号：19</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

分析日志：

从生产者日志可以看出，所有的消息均已经发送成功。

从消费者1、消费者2日志可以看出，消息被两个消费者均衡消费了。

**8.发送对象**

实际项目中，请求信息可能包含多个字段。为了保证生产者与消费者两端的字段一致性，通常会传递一个对象。

8.1）为了测试方便，我们在DirectConfig中增加一个消息队列

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Bean</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>Queue refundNotifyQueue() { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>return</code> 
      <code>new</code> 
      <code>Queue(</code> 
      <code>"notify.refund"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

8.2）添加一个消息监听类（消费者）

监听routingKey为notify.refund的队列消息

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Component</code> 
     </div> 
     <div> 
      <code>@RabbitListener</code> 
      <code>(queues = </code> 
      <code>"notify.refund"</code> 
      <code>)</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>RefundNotifyReceive { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@RabbitHandler</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>receive(Order order) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>LogUtil.info(</code> 
      <code>"notify.refund receive message: "</code> 
      <code>+order);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

8.3）添加一个消息发送类（生产者）

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Component</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>RefundNotifySender { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@Autowired</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>private</code> 
      <code>AmqpTemplate rabbitTemplate;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>sender(Order order){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>LogUtil.info(</code> 
      <code>"notify.refund send message: "</code> 
      <code>+order);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>rabbitTemplate.convertAndSend(</code> 
      <code>"notify.refund"</code> 
      <code>, order);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

8.4）添加一个测试类

8.5）执行RefundNotifySenderTests测试类

生产者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:37:47.038&nbsp; INFO 13672 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.RefundNotifySenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Starting RefundNotifySenderTests on LAPTOP-1DF7S904 with PID 13672 (started by lianjinsoft in...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:37:47.041&nbsp; INFO 13672 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.RefundNotifySenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : No active profile set, falling back to default profiles: default</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:37:47.070&nbsp; INFO 13672 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@1e800aaa:...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:37:47.715&nbsp; INFO 13672 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration' of type ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:37:48.779&nbsp; INFO 13672 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Starting beans in phase 2147483647</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:37:48.802&nbsp; INFO 13672 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.RefundNotifySenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Started RefundNotifySenderTests in 2.082 seconds (JVM running for 2.967)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:37:49.085&nbsp; INFO 13672 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.refund send message: Order [id=100001, orderId=1526287069081, amount=1999.99, createTime=...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:37:49.104&nbsp; INFO 13672 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Attempting to connect to: [192.168.15.131:5672]</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:37:49.170&nbsp; INFO 13672 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Created new connection: rabbitConnectionFactory#6b5894c8:0/SimpleConnection@38f57b3d [delegate=...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:37:49.265&nbsp; INFO 13672 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] s.c.a.AnnotationConfigApplicationContext : Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@1e800aaa: ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:37:49.266&nbsp; INFO 13672 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Stopping beans in phase 2147483647</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

消费者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:37:49.242&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.refund receive message: Order [id=100001, orderId=1526287069081, amount=1999.99, createTime=...</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

分析日志：

从生产者日志可以看出，order对象已经发送成功。

从消费者日志可以看出，order对象已经接受成功并可以直接使用。

**注意：**

传递的对象必须支持序列化（实现了Serializable接口）

**9.RPC**

RabbitMQ支持RPC远程调用，同步返回结果。

![1308658-20180515112959267-1677496947.png][]

9.1）为了测试方便，我们在DirectConfig中增加一个消息队列

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Bean</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>Queue queryOrderQueue() { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>return</code> 
      <code>new</code> 
      <code>Queue(</code> 
      <code>"query.order"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

9.2）添加一个消息监听类（消费者）

监听routingKey为query.order的队列消息

9.3）添加一个消息发送类（生产者）

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Component</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>QueryOrderSender { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@Autowired</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>private</code> 
      <code>AmqpTemplate rabbitTemplate;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>sender(String orderId){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>LogUtil.info(</code> 
      <code>"query.order send message: "</code> 
      <code>+orderId);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>Order order = (Order) rabbitTemplate.convertSendAndReceive(</code> 
      <code>"query.order"</code> 
      <code>, orderId);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>LogUtil.info(</code> 
      <code>"query.order return message: "</code> 
      <code>+order);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

9.4）添加一个测试类

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@RunWith</code> 
      <code>(SpringRunner.</code> 
      <code>class</code> 
      <code>)</code> 
     </div> 
     <div> 
      <code>@SpringBootTest</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>QueryOrderSenderTests { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@Autowired</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>private</code> 
      <code>QueryOrderSender sender;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>@Test</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>public</code> 
      <code>void</code> 
      <code>test_sender() { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>sender.sender(</code> 
      <code>"900000001"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

9.5）执行QueryOrderSenderTests测试类

生产者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:38:14.163&nbsp; INFO 2024 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.QueryOrderSenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Starting QueryOrderSenderTests on LAPTOP-1DF7S904 with PID 2024 (started by lianjinsoft in...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:38:14.164&nbsp; INFO 2024 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.QueryOrderSenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : No active profile set, falling back to default profiles: default</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:38:14.197&nbsp; INFO 2024 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@7eac9008: ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:38:14.848&nbsp; INFO 2024 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration' of type ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:38:15.705&nbsp; INFO 2024 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Starting beans in phase 2147483647</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:38:15.715&nbsp; INFO 2024 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] c.l.sender.QueryOrderSenderTests&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Started QueryOrderSenderTests in 1.927 seconds (JVM running for 3.079)</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:38:15.793&nbsp; INFO 2024 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : query.order send message: 900000001</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:38:15.812&nbsp; INFO 2024 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Attempting to connect to: [192.168.15.131:5672]</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:38:15.988&nbsp; INFO 2024 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] o.s.a.r.c.CachingConnectionFactory&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : Created new connection: rabbitConnectionFactory#38be305c:0/SimpleConnection@71984c3 ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:38:16.057&nbsp; INFO 2024 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; main] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : query.order return message: Order [id=100001, orderId=900000001, amount=2999.99, createTime=...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:38:16.079&nbsp; INFO 2024 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] s.c.a.AnnotationConfigApplicationContext : Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@7eac9008: ...</code> 
     </div> 
     <div> 
      <code>2018-05-14 16:38:16.097&nbsp; INFO 2024 --- [&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread-2] o.s.c.support.DefaultLifecycleProcessor&nbsp; : Stopping beans in phase 2147483647</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

消费者日志：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2018-05-14 16:38:16.028&nbsp; INFO 14876 --- [cTaskExecutor-1] com.lianjinsoft.util.LogUtil&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; : notify.refund receive message: 900000001</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

分析日志：

从生产者日志第7行可以看出，消息已经发送成功。从第10行日志可以看出，已经收取到返回的消息，并成功转化为Order对象。

从消费者日志可以看出，已经成功接收到消息并处理完成。

虽然RabbitMQ支持RPC接口调用，但不推荐使用。

原因：

1）RPC默认为单线程阻塞模型，效率极低。

2）需要手动实现多线程消费。

[1308658-20180521182608882-979039140.png]: https://images2018.cnblogs.com/blog/1308658/201805/1308658-20180521182608882-979039140.png
[1308658-20180521182545059-1155725091.png]: /images/20220523/d2e26bd3700b4b478b46afe42410d1f3.png
[copycode.gif]: /images/20220523/7a83b7d6a0d64168b8b2a0d33ae59f36.png
[1308658-20180515095018484-830578829.png]: /images/20220523/eb249e4031eb41d48ca37aee98e4f5b1.png
[1308658-20180515095821882-1047782467.png]: /images/20220523/88b9d91ee61948309e8a87197cff5568.png
[1308658-20180515112959267-1677496947.png]: /images/20220523/edcb3c14539d43c9b01feab4b1077f66.png