05.SpringBoot整合RabbitMQ的TOPIC

05.SpringBoot整合RabbitMQ的TOPIC SpringBoot整合RabbitMQ的TOPIC

Topic 是direct的增强版，让routing支持使用通配符

* 代表可以匹配一个单词，如user.* 能够匹配 user.AAA user.AAABBB

# 代表可以匹配0个单词或者多个，如user.# 能够匹配 user.AAA 、user.AAABBB、user.AAABBB.CCC

交换机配置

@Configuration
class TopicExchangeConfig{
    
    @Bean
    public Exchange topicExchange() {
        return ExchangeBuilder.topicExchange("USER_TOPIC").durable(true).build();
    }

    @Bean
    public Queue userAQueue() {
        return new Queue("userAQueue");
    }

    @Bean
    public Queue userQueue() {
        return new Queue("userQueue");
    }

    @Bean
    public Binding bindingTopicExchange1(Queue userAQueue, Exchange topicExchange) {
        return BindingBuilder.bind(userAQueue).to(topicExchange).with("user.*").noargs();
    }

    @Bean
    public Binding bindingTopicExchange2(Queue userQueue, Exchange topicExchange) {
        return BindingBuilder.bind(userQueue).to(topicExchange).with("user.#").noargs();
    }
}

消费者

@Component
@RabbitListener(queues = "userAQueue")
class UserAQueueConsumer{

    @RabbitHandler
    public void receive(String msg){
        System.out.println("user*：" + msg);
    }
}

@Component
@RabbitListener(queues = "userQueue")
class UserBQueueConsumer{

    @RabbitHandler
    public void receive(String msg){
        System.out.println("user#：" + msg);
    }
}

生产者

@RestController
@RequestMapping("/topic")
public class TopicUserCtrl {

    @Autowired
    private AmqpTemplate amqpTemplate;

    @GetMapping("/addUser")
    public String addUser(String msg){
        String exchange = "USER_TOPIC";
        amqpTemplate.convertAndSend(exchange, "user.AAA", "hi AAA ！");
        amqpTemplate.convertAndSend(exchange, "user.AAABBB", "hi AAABBB ！");
        amqpTemplate.convertAndSend(exchange, "user.AAABBB.CCC", "hi AAABBB.CCC ！");
        return msg;
    }
}

运行打印输出：