总之，topics模型就是比direct模型多了一个通配符。

提供者

public class Provider {
   

    public static void main(String[] args) throws IOException {
   
        Connection connection = RabbitMqUtils.getConnection();
        // 创建通道
        Channel channel = connection.createChannel();
// 将通道声明指定的交换机 参数1：交换机的名称 参数2：交换机的类型
        channel.exchangeDeclare("topics","topic");
/// 发送消息
        String routinkey = "user.save";
        channel.basicPublish("topics",routinkey,null,("这个是路由key发送的消息").getBytes());
        // 释放资源
        RabbitMqUtils.closeConnectionAndChannel(channel,connection);

    }
}

创建了一个topic类型的交换机，并且往这个交换机里面放了一个 加了路由键 的消息

消费者

public class Customer {
   

    public static void main(String[] args) throws IOException {
   
        Connection connection = RabbitMqUtils.getConnection();
// 创建通道
        Channel channel = connection.createChannel();
        // 将通道声明指定的交换机 参数1：交换机的名称 参数2：交换机的类型 fanout 广播类型
        channel.exchangeDeclare("topics","topic");
// 创建临时队列
        String queue = channel.queueDeclare().getQueue();
// 绑定交换机和队列,意思是交换机里面信息有error这个路由，队列里面也有这个error路由，消费者才可以消费
        channel.queueBind(queue,"topics","user.*");
// 消费消息
        channel.basicConsume(queue,true,new DefaultConsumer(channel){
   
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
   
                System.out.println("消费者1："+new String(body));
            }
        });
    }
}

在消费者里面绑定了交换机和队列，并这个队列里面是有通配符的路由键。

以后消费者在队列里面拿消息的时候，只可以拿这个路由键匹配的消息。