RabbitMQ交换机-4. Topic交换机

通配符规则：

• #：匹配一个或多个词
• *：匹配不多不少恰好1个词

举例：

• item.#：能够匹配item.spu.insert 或者 item.spu
• item.*：只能匹配item.spu
  

2.1 声明队列和交换机

添加队列direct.queue1
添加队列direct.queue2
添加交换机harry.direct
绑定队列

2.2 发送消息

@Test
public void testSendTopicExchange() {
    // 交换机名称
    String exchangeName = "harry.topic";
    // 消息
    String message = "发送消息到routingKey: china.news!";
    // 发送消息
    rabbitTemplate.convertAndSend(exchangeName, "china.news", message);
}

2.3 接收消息

@Component
public class FanoutConsumer {
    @RabbitListener(queues = "topic.queue1")
    public void listenTopicQueue1(String msg) {
        System.out.println("消费者1接收到topic.queue1的消息：【" + msg + "】");
    }

    @RabbitListener(queues = "topic.queue2")
    public void listenTopicQueue2(String msg) {
        System.out.println("消费者2接收到topic.queue2的消息：【" + msg + "】");
    }
}