Rabbit MQ实战【direct交换器】-蒲公英云

Rabbit MQ实战【direct交换器】

spring boot版本：2.1.10.RELEASE

本文涉及两个项目 rabbitmq-direct-consumer 和 rabbitmq-direct-provider，所需maven依赖和配置相同。

在这里插入图片描述

rabbitmq-direct-consumer项目

创建消息接收类

package com.ebook.rabbitmq;
import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.rabbit.annotation.*;
import org.springframework.stereotype.Component;
/** * @author:JZ * @date:2020/2/2 */
@Component
@RabbitListener(bindings = @QueueBinding(
        value = @Queue(value = "${mq.config.queue.info}", autoDelete = "true"),//autoDelete表示队列为临时队列
        exchange = @Exchange(value = "${mq.config.exchange}", type = ExchangeTypes.DIRECT),
        key = "${mq.config.queue.info.routing.key}"
    ))
public class InfoReciver { 
    @RabbitHandler
    public void process(String msg) { 
        System.out.println("接收到INFO日志：" + msg);
    }
}

rabbitmq-direct-provider项目

（1）创建消息发送类

package com.ebook.rabbitmq;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import java.util.Date;
/** * @author:JZ * @date:2020/2/2 */
@Component
public class Sender { 
    @Value("${mq.config.exchange}")
    private String exchange;
    @Value("${mq.config.queue.info.routing.key}")
    private String infoRoutingKey;
    @Autowired
    private AmqpTemplate rabbitTemplate;
    public void send() { 
        String msg = "hello：" + new Date();
        this.rabbitTemplate.convertAndSend(this.exchange, this.infoRoutingKey, msg);
    }
}

（2）创建测试类

import com.ebook.rabbitmq.RabbitmqDirectProvider;
import com.ebook.rabbitmq.Sender;
import org.junit.Test;
import org.junit.runner.RunWith;
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 = RabbitmqDirectProvider.class)
public class RabbitMqHelloApplicationTests { 
    @Autowired
    private Sender sender;
    @Test
    public void send() throws InterruptedException { 
        this.sender.send();
    }
}