本章延伸一下RabbitMq的其它队列应用
1. Work Queues
生产者（P）生产消息并投递到Queue中，多个消费者(C1 、C2)可以订阅一个Queue，这个时候Queue中的消息会被平均的分摊给多个消费进行处理，而不是每个消费者都收到所有消息并处理。
Java 代码示例-生产者：
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* Description: AMQP JAVA消息生产者
* author: 慢慢来了
* date: 2017/3/31 11:38
*/
@Component
public class RabbitMqProducter {
@Autowired
private AmqpTemplate amqpTemplate;
public void sendMsg(String content){
for(int i = 0 ; i < 3 ; i++) {
amqpTemplate.convertAndSend("S.Q.CRM.TO.MSG" , content + "_" +i);
}
}
}
Java 代码示例-消费者
package com.amqp;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* Description: AMQP JAVA消息消费者
* author: 慢慢来了
* date: 2017/3/31 11:38
*/
@Component
public class RabbitMqConsumer {
@Autowired
private AmqpTemplate amqpTemplate;
@RabbitListener(queues="S.Q.CRM.TO.MSG")
public void getMsg(String msg){
System.out.println("**************Receiver: " + msg);
}
@RabbitListener(queues="S.Q.CRM.TO.MSG")
public void getMsg2(String msg){
System.out.println("--------------Receiver2: " + msg);
}
}
2. Exchanges
上节说的Queue 与Work Queues 都是直接把消息投递到Queue中的，但是RabbitMQ消息传递模型的核心思想是，生产者不发送任何信息直接到队列。（ The core idea in the messaging model in RabbitMQ is that the producer never sends any messages directly to a queue. ）而且生产都不知道消息会投递到哪个Queue上;生产都只需要知道消息发送给Exchage上面就好。
RabbitMQ中的Exchange有四种类型，不同的类型有着不同的路由策略：direct, topic, headers and fanout。
2.1 Binding
RabbitMQ 中通过Binding 将Exchange 与Quque关联起来，这样RabbitMQ就知道如何正确地将消息路由到指定的Quque了。
2.2 Routing key
生产者在将消息发送给Exchange的时候，一般会指定一个routing key，来指定这个路由规则，而这个routing key需要与 Exchange Type 与binding key 联合使用才能最终生效。
在Exchange Tpye 与binding key 固定的情况下(在正常使用情况下，这些内容都是配置好的)，我们的生产者就可以在发送消息给Exchange的时候，通过指定routing key 来指定消息流的流向哪里。
Java代码示例
amqpAdmin.declareBinding(BindingBuilder.bind(queue).to(Exchange).with(routeKey));
2.3 Fanout
fanout类型的Exchange路由规则非常简单，它会把所有发送到该Exchange的消息路由到所有与它绑定的Queue中。
2.4 Direct
direct类型的Exchange路由规则也很简单，它会把消息路由到那些binding key与routing key完全匹配的Queue
2.5 Topic
前面讲到direct类型的Exchange路由规则是完全匹配binding key与routing key，但这种严格的匹配方式在很多情况下不能满足实际业务需求。topic类型的Exchange在匹配规则上进行了扩展，它与direct类型的Exchage相似，也是将消息路由到binding key与routing key相匹配的Queue中，但这里的匹配规则有些不同，它约定：
routing key为一个句点号“. ”分隔的字符串（我们将被句点号“. ”分隔开的每一段独立的字符串称为一个单词），如“queue.user.aaa”、“q.av”、“queue.user.bbb”
binding key与routing key一样也是句点号“. ”分隔的字符串
binding key中可以存在两种特殊字符“”与“#”，用于做模糊匹配，其中“”用于匹配一个单词，“#”用于匹配多个单词（可以是零个）】
Java 示例：
amqpTemplate.convertSendAndReceive(String exchange, String routingKey, Object message);
