一、Provideer

配置文件

 1 spring.application.name=provider
 2 spring.rabbitmq.host=192.168.50.30
 3 spring.rabbitmq.port=5672
 4 spring.rabbitmq.username=rabbit
 5 spring.rabbitmq.password=rabbit
 6 #设置交换器的名称
 7 mq.config.exchange=log.direct
 8 #info 路由键
 9 mq.config.queue.info.routing.key=log.info.routing.key
10 #error 路由键
11 mq.config.queue.error.routing.key=log.error.routing.key
12 #error 队列名称
13 mq.config.queue.error=log.error

代码

 1 @Component
 2 public class Sender {
 3     @Autowired
 4     private AmqpTemplate amqpTemplate;
 5     
 6     @Value("${mq.config.exchange}")
 7     private String exchange;
 8 
 9     @Value("${mq.config.queue.error.routing.key}")
10     private String routingkey;
11 
12     public void send(String msg) {
13         this.amqpTemplate.convertAndSend(this.exchange, this.routingkey, msg);
14     }
15 }

二、consumer

配置文件

 1 spring.application.name=consumer
 2 spring.rabbitmq.host=192.168.50.30
 3 spring.rabbitmq.port=5672
 4 spring.rabbitmq.username=rabbit
 5 spring.rabbitmq.password=rabbit
 6 #设置交换器名称
 7 mq.config.exchange=log.direct
 8 #info队列名称
 9 mq.config.queue.info=log.info
10 #info路由键
11 mq.config.queue.info.routing.key=log.info.routing.key
12 #error队列名称
13 mq.config.queqe.error=log.error
14 #errot路由键
15 mq.config.queue.error.routing.key=log.error.routing.key

1，InfoReceiver

 1 /*
 2 @RabbitListener bindings:绑定队列
 3 @QueueBinding value:绑定队列的名称
 4             exchange：配置交换器
 5 @Queue value:配置队列名称
 6         autoDelete：是否是一个可删除的临时队列
 7 @Exchange value:为交换器起个名称
 8         type:指定具体交换器类型
 9  */
10 @Component
11 @RabbitListener(
12     bindings=@QueueBinding(
13         value=@Queue(
14             value="${mq.config.queue.info}", 
15             autoDelete="true"
16         ),
17         exchange=@Exchange(
18             value="${mq.config.exchange}",
19             type=ExchangeTypes.DIRECT
20         ),
21         key="${mq.config.queue.info.routing.key}"
22     )
23 )
24 public class Consumer {
25     @RabbitHandler
26     public void process(String msg) {
27         System.out.println("info received:" + msg);
28     }
29 }

2，ErrorReceiver

 1 /*
 2 @RabbitListener bindings:绑定队列
 3 @QueueBinding value:绑定队列的名称
 4             exchange：配置交换器
 5 @Queue value:配置队列名称
 6         autoDelete：是否是一个可删除的临时队列
 7 @Exchange value:为具体交换器起个名称
 8         type:指定具体的交换类型
 9  */
10 @Component
11 @RabbitListener(
12     bindings=@QueueBinding(
13         value=@Queue(
14             value="${mq.config.queue.error}",
15             autoDelete="true"
16         ),
17         exchange=@Exchange(
18             value="${mq.config.exchange}",
19             type=ExchangeTypes.DIRECT
20         ),
21         key="${mq.config.queue.error.routing.key}"
22     )
23 )
24 public class ErrorReceiver {
25     public void process(String msg) {
26         System.out.println("error recevied:" + msg);
27     }
28 }