RabbitMQ之Direct交换器模式开发

Dirtct交换器，即发布与订阅模式，匹配规则为完全匹配。

　

一、Provideer

配置文件

spring.application.name=provider
spring.rabbitmq.host=192.168.50.30
spring.rabbitmq.port=5672
spring.rabbitmq.username=rabbit
spring.rabbitmq.password=rabbit
#设置交换器的名称
mq.config.exchange=log.direct
#info 路由键
mq.config.queue.info.routing.key=log.info.routing.key
#error 路由键
mq.config.queue.error.routing.key=log.error.routing.key
#error 队列名称
mq.config.queue.error=log.error

代码

@Component
public class Sender {
    @Autowired
    private AmqpTemplate amqpTemplate;
    
    @Value("${mq.config.exchange}")
    private String exchange;

    @Value("${mq.config.queue.error.routing.key}")
    private String routingkey;

    public void send(String msg) {
        this.amqpTemplate.convertAndSend(this.exchange, this.routingkey, msg);
    }
}

二、consumer

配置文件

spring.application.name=consumer
spring.rabbitmq.host=192.168.50.30
spring.rabbitmq.port=5672
spring.rabbitmq.username=rabbit
spring.rabbitmq.password=rabbit
#设置交换器名称
mq.config.exchange=log.direct
#info队列名称
mq.config.queue.info=log.info
#info路由键
mq.config.queue.info.routing.key=log.info.routing.key
#error队列名称
mq.config.queqe.error=log.error
#errot路由键
mq.config.queue.error.routing.key=log.error.routing.key

1，InfoReceiver

/*
@RabbitListener bindings:绑定队列
@QueueBinding value:绑定队列的名称
            exchange：配置交换器
@Queue value:配置队列名称
        autoDelete：是否是一个可删除的临时队列
@Exchange value:为交换器起个名称
        type:指定具体交换器类型
 */
@Component
@RabbitListener(
    bindings=@QueueBinding(
        value=@Queue(
            value="${mq.config.queue.info}", 
            autoDelete="true"
        ),
        exchange=@Exchange(
            value="${mq.config.exchange}",
            type=ExchangeTypes.DIRECT
        ),
        key="${mq.config.queue.info.routing.key}"
    )
)
public class Consumer {
    @RabbitHandler
    public void process(String msg) {
        System.out.println("info received:" + msg);
    }
}

2，ErrorReceiver

/*
@RabbitListener bindings:绑定队列
@QueueBinding value:绑定队列的名称
            exchange：配置交换器
@Queue value:配置队列名称
        autoDelete：是否是一个可删除的临时队列
@Exchange value:为具体交换器起个名称
        type:指定具体的交换类型
 */
@Component
@RabbitListener(
    bindings=@QueueBinding(
        value=@Queue(
            value="${mq.config.queue.error}",
            autoDelete="true"
        ),
        exchange=@Exchange(
            value="${mq.config.exchange}",
            type=ExchangeTypes.DIRECT
        ),
        key="${mq.config.queue.error.routing.key}"
    )
)
public class ErrorReceiver {
    public void process(String msg) {
        System.out.println("error recevied:" + msg);
    }
}