【RabbitMQ笔记06】消息队列RabbitMQ七种模式之Topics主题模式

这篇文章，主要介绍消息队列RabbitMQ七种模式之Topics主题模式。

目录

一、消息队列

1.1、主题模式（Topics）

1.2、案例代码

（1）引入依赖

（2）编写生产者

（3）编写消费者

---

一、消息队列

1.1、主题模式（Topics）

前一篇文章介绍了Routing路由模式，它是根据消息的唯一标识routing key路由键，将其分发到不同的Queue队列里面，这篇文章介绍的Topics主题模式，也是需要依赖与routing key路由键来进行分发消息，但是不同的是，Topics主题可以采用通配符的方式来指定routing key。

Topics主题模式下，它要求【routing key路由键】必须采用【多个单词】来表示，每一个单词采用点好【.】分割，例如：【xxx.yyy.zzz】，这就是三个单词，分别是：xxx、yyy、zzz，路由键的最长长度是255bytes。

Topics主题模式支持两种通配符：

• 星号【*】通配符：只能够匹配1个单词（Topics主题模式下，按照点好【.】号来判断单词）。
• 井号【#】通配符：匹配0个或者多个单词。

Topics主题模式大致如下所示：

主题模式下，每一个Queue队列能够接收到的消息类型就非常多了，只要消息满足routing key的格式，就会被分发到这个Queue队列里面。Topics主题模式和Routing路由模式有什么区别呢？？？

• Routing路由模式：需要指定具体的routing key。
• Topics主题模式：可以采用通配符来指定routing key，如果Topics主题模式中没有使用通配符，那么这个时候就相当于Routing路由模式，所以Topics主题模式比Routing路由模式更加的灵活。

1.2、案例代码

（1）引入依赖

<!-- 引入 RabbitMQ 依赖 -->
<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.16.0</version>
</dependency>

（2）编写生产者

• 生产者发送消息时候，设置routing key是采用【spring.xxx】格式的。

package com.rabbitmq.demo.topics;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;/*** @version 1.0.0* @Date: 2023/2/25 16:23* @Copyright (C) ZhuYouBin* @Description: 消息生产者*/
public class Producer {public static void main(String[] args) {// 1、创建连接工厂ConnectionFactory factory = new ConnectionFactory();// 2、设置连接的 RabbitMQ 服务地址factory.setHost("127.0.0.1"); // 默认就是本机factory.setPort(5672); // 默认就是 5672 端口// 3、获取连接Connection connection = null; // 连接Channel channel = null; // 通道try {connection = factory.newConnection();// 4、获取通道channel = connection.createChannel();// 5、声明 Exchange，如果不存在，则会创建String exchangeName = "exchange_topics_2023";channel.exchangeDeclare(exchangeName, "topic");// 6、发送消息for (int i = 0; i < 10; i++) {// 路由键唯一标识String routingKey = "spring.error";if (i % 3 == 0) {routingKey = "spring.info";} else if (i % 3 == 1) {routingKey = "java.warn";}String message = "这是Topics模式，发送的第【" + (i+1) + "】条【" + routingKey + "】消息数据";channel.basicPublish(exchangeName, routingKey, null, message.getBytes());}} catch (Exception e) {e.printStackTrace();} finally {if (null != channel) {try {channel.close();} catch (Exception e) {}}if (null != connection) {try {connection.close();} catch (Exception e) {}}}}
}

（3）编写消费者

• 消费者消费消息的时候，采用Topic主题模式，并且只消费routing key满足【spring.*】的消息。

package com.rabbitmq.demo.topics;import com.rabbitmq.client.*;import java.io.IOException;/*** @version 1.0.0* @Date: 2023/2/25 16:30* @Copyright (C) ZhuYouBin* @Description: 消息消费者*/
public class Consumer {public static void main(String[] args) {// 1、创建连接工厂ConnectionFactory factory = new ConnectionFactory();// 2、设置连接的 RabbitMQ 服务地址factory.setHost("127.0.0.1"); // 默认就是本机factory.setPort(5672); // 默认就是 5672 端口// 3、获取连接Connection connection = null; // 连接Channel channel = null; // 通道try {connection = factory.newConnection();// 4、获取通道channel = connection.createChannel();// 5、声明 Exchange，如果不存在，则会创建String exchangeName = "exchange_topics_2023";channel.exchangeDeclare(exchangeName, "topic");// 6、指定需要操作的消息队列，如果队列不存在，则会创建String queueName = "queue_topics_2023";channel.queueDeclare(queueName, false, false, false, null);// 7、绑定 Exchange 和 Queue, 接收 routingKey = "spring.*" 的消息channel.queueBind(queueName, exchangeName, "spring.*");// 8、消费消息DeliverCallback callback = new DeliverCallback() {public void handle(String s, Delivery delivery) throws IOException {// 接收消息System.out.println("这是接收的消息：" + new String(delivery.getBody()));}};channel.basicConsume(queueName, true, callback, i->{});} catch (Exception e) {e.printStackTrace();}}
}

运行结果如下所示：

到此，RabbitMQ消息队列中的Topic主题模式就介绍完啦。

综上，这篇文章结束了，主要介绍消息队列RabbitMQ七种模式之Topics主题模式。