Topic交换机是RabbitMQ中最灵活和强大的一种交换机类型。它根据消息的路由键（Routing Key）和绑定键（Binding Key）之间的模式匹配，将消息发送到与之匹配的队列。通过使用通配符模式，Topic交换机可以实现精确匹配或模糊匹配的消息路由。
Topic交换机的基本概念
Topic交换机根据消息的路由键和绑定键之间的模式匹配，将消息发送到与之匹配的队列。路由键和绑定键都是由一个或多个单词组成的字符串，以句点（.）分隔。其中，绑定键中可以使用通配符进行模式匹配。
Topic交换机的通配符有两种形式：
*（星号）：表示匹配一个单词。#（井号）：表示匹配零个或多个单词。
例如，路由键为com.example.service，可以使用绑定键com.example.service、com.example.*或com.#来匹配。
Topic交换机的关键特点如下：
- 模式匹配：Topic交换机根据消息的路由键和绑定键之间的模式匹配将消息发送给匹配的队列。
- 灵活性：通过使用通配符模式，可以实现精确匹配或模糊匹配的消息路由。
- 队列绑定：队列需要将自己绑定到Topic交换机上，并指定绑定键，以接收与之匹配的消息。
使用Java代码创建Topic交换机、绑定队列并发送消息的示例：
代码语言：javascript复制import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeoutException;
public class TopicExchangeExample {
private static final String EXCHANGE_NAME = "topic_exchange";
private static final String ROUTING_KEY = "com.example.service";
public static void main(String[] args) throws IOException, TimeoutException {
// 创建连接工厂
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
// 创建连接
Connection connection = factory.newConnection();
// 创建信道
Channel channel = connection.createChannel();
// 声明Topic交换机
channel.exchangeDeclare(EXCHANGE_NAME, "topic");
// 声明队列
String queueName = channel.queueDeclare().getQueue();
// 绑定队列到交换机，指定绑定键
channel.queueBind(queueName, EXCHANGE_NAME, ROUTING_KEY);
// 发送消息
String message = "Hello, RabbitMQ!";
channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY, null, message.getBytes(StandardCharsets.UTF_8));
System.out.println("Sent message: " message);
// 关闭信道和连接
channel.close();
connection.close();
}
}在这个示例中，我们首先创建了一个名为"topic_exchange"的Topic交换机。然后，我们创建了一个队列并将其绑定到Topic交换机上，绑定键为"com.example.service"。这意味着只有带有路由键为"com.example.service"的消息才会被发送到该队列。
最后，我们使用channel.basicPublish方法发送一条带有路由键"com.example.service"的消息到Topic交换机。该消息将根据绑定键的通配符模式进行匹配，并发送到与之匹配的队列。
