RabbitMQ之Topic交换器模式开发

Topic交换器，即主题模式，进行规则匹配。

一、Provider

配置文件

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.topic

代码

public class UserSender {
    @Autowired
    private AmqpTemplate amqpTemplate;

    @Value("${mq.config.exchange}")
    private String exchange;

    public void send(String msg) {
        //交换器、路由键、消息
        this.amqpTemplate.convertAndSend(this.exchange, "user.log.debug", msg);
        this.amqpTemplate.convertAndSend(this.exchange, "user.log.info", msg);
    }

    public void send2(String msg) {
        this.amqpTemplate.convertAndSend(this.exchange, "product.log.debug", msg);
        this.amqpTemplate.convertAndSend(this.exchange, "product.log.info", msg);
    }
}

二、Condumer

配置文件

spring.appliction.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.topic
#info 队列名称
mq.config.queue.info=log.info
#error 队列名称
mq.config.queue.error=log.error
#log 队列名称
mq.config.queue.logs=log.all

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.TOPIC
        ),
        key="*.log.info"
    )
)
public class InfoReceiver {
    @RabbitHandler
    public void process(String msg){
        System.out.println(msg);
    }
}

logsReceiver

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