RabbitMQ：SpringAMQP Topic Exchange（主题交换机）

---

TopicExchange与DirectExchange类似，区别在于RoutingKey可以是多个单次的列表，并且以.分割。

Queue与Exchange指定BindingKey时可以使用通配符：

• #：代指0个或多个单词。
• *：代指一个单词。

生产者源码
消费者源码

一、案例需求

1. 在RabbitMQ控制台中，声明队列topic.queue1和topic.queue2。
2. 在RabbitMQ控制台中，声明交换机mt.topic，将两个队列与其绑定。
3. 在生产者服务中，利用不同的RoutingKey向mt.topic交换机发送消息。
4. 在消费者服务中，编写两个消费者，分别监听队列topic.queue1和topic.queue2。

二、基础配置

首先创建两个队列topic.queue1和topic.queue2。

创建一个主题交换机mt.topic，需要注意的是，在创建交换机的时候需要修改交换机的类型topic主题交换机。

交换机创建之后，点击交换机的名称，绑定交换机与队列之间的关系。

三、代码实现

生产者

/*** 给交换机发送消息（主题交换机）* @throws InterruptedException*/
@Test
public void topicExchangeTest() throws InterruptedException {String exchangeName = "mt.topic";String message = "黄色警报 ......";
//        rabbitTemplate.convertAndSend(exchangeName, "china.news", message);
//        rabbitTemplate.convertAndSend(exchangeName, "japan.news", message);rabbitTemplate.convertAndSend(exchangeName, "china.weather", message);
}

消费者

@RabbitListener(queues = "topic.queue1")
public void listenTopicQueue1(String message) throws InterruptedException {System.out.println(String.format("消费者1，收到了topic.queue1: %s", message));
}@RabbitListener(queues = "topic.queue2")
public void listenTopicQueue2(String message) throws InterruptedException {System.err.println(String.format("消费者2，收到了topic.queue2: %s", message));
}