《RabbitMQ系列教程-第四章-05-RabbitMQ工作模式之Topics主题模式》

╰半夏微凉° 2023-01-02 03:24 158阅读 0赞

# 教程说明 #

*  本系列教程目录大纲：[《RabbitMQ系列教程-目录大纲》][RabbitMQ_-]

--------------------

*  本系列教程配套代码：[https://gitee.com/Horizon1024/rabbitmt.git][https_gitee.com_Horizon1024_rabbitmt.git]（码云地址）

--------------------

# RabbitMQ工作模式之Topics主题模式 #

### 4.5.1 简介 ###

在`Routing`模式下，一个`Exchange`绑定`Queues`时可以指定`Routing Key`，但`Routing Key`都是固定的值，如果想要通配符的匹配（类似于模糊匹配）我们就得使用`Topics`模式了，例如`red`开头的`Routing key`我都进行消息路由，以`green`结尾的`Routing key`的我都进行消息路由等；

![在这里插入图片描述][20210104162554687.png_pic_center]

**`Topics`模式强调的是`topic`模式的`Exchange`**，**Topics模式也叫主题模式**，该模式下的`Exchange`在绑定`Queues`时可以指定的一定的通配符，这些通配符指定了路由的规则；

`Topics`模式下有两个符号：

*  符号 `#`：匹配零个或多个词。（0个或多个）
 *  符号 `*`：匹配不多不少一个词。（必须是一个，0个不行）

因此 `red.#` 能够匹配到 `red.green.xxx`，但是 `red.*`只会匹配到 `red.xxx`。

小练习：

red.green.green			1/2/3/4
    green.green				3/4	
    green.red.blue
    green.green.green		3/4		
    green.red.green			3
    
    red.#.green		
    red.green.*			
    #.green	
    *.green.#

> Topics模式官网介绍：https://www.rabbitmq.com/tutorials/tutorial-five-java.html

### 4.5.2 生产者 ###

package com.lscl.rabbitmq;
    
    import com.rabbitmq.client.BuiltinExchangeType;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    
    public class Producer05_Topic { 
    
        public static void main(String[] args) throws Exception { 
            // 创建连接工厂,用于获取频道channel
            ConnectionFactory factory = new ConnectionFactory();
    
            factory.setHost("192.168.40.132");
            factory.setPort(5672);
            factory.setUsername("lscl");
            factory.setPassword("admin");
            factory.setVirtualHost("/lscl");
    
            // 2.创建连接
            Connection connection = factory.newConnection();
    
            // 3.创建频道
            Channel channel = connection.createChannel();
    
            String exchangeName = "test_topic";
    
            //5. 创建交换机
            channel.exchangeDeclare(exchangeName, BuiltinExchangeType.TOPIC,true,false,false,null);
    
            //6. 创建队列
            String queue1Name = "test_topic_queue1";
            String queue2Name = "test_topic_queue2";
            String queue3Name = "test_topic_queue3";
            String queue4Name = "test_topic_queue4";
    
            channel.queueDeclare(queue1Name,true,false,false,null);
            channel.queueDeclare(queue2Name,true,false,false,null);
            channel.queueDeclare(queue3Name,true,false,false,null);
            channel.queueDeclare(queue4Name,true,false,false,null);
    
            //7. 绑定队列和交换机
            channel.queueBind(queue1Name,exchangeName,"red.#.green");
            channel.queueBind(queue2Name,exchangeName,"red.green.*");
            channel.queueBind(queue3Name,exchangeName,"#.green");
            channel.queueBind(queue4Name,exchangeName,"*.green.#");
    
            String body = "topic....";
            //8. 发送消息
            /* red.green.green 1/2/3/4 green.green 3/4 green.red.blue green.green.green 3/4 green.red.green 3 red.#.green red.green.* #.green *.green.# */
    // channel.basicPublish(exchangeName,"red.green.green",null,body.getBytes());
    // channel.basicPublish(exchangeName,"green.green",null,body.getBytes());
    // channel.basicPublish(exchangeName,"green.red.blue",null,body.getBytes());
    // channel.basicPublish(exchangeName,"green.green.green",null,body.getBytes());
            channel.basicPublish(exchangeName,"green.red.green",null,body.getBytes());
    
            //9. 释放资源
            channel.close();
            connection.close();
        }
    }

### 4.5.3 消费者-1 ###

package com.lscl.rabbitmq;
    
    import com.rabbitmq.client.*;
    
    import java.io.IOException;
    
    public class Consumer07_Topic_01 { 
    
        public static void main(String[] args) throws Exception{ 
            // 创建连接工厂,用于获取频道channel
            ConnectionFactory factory=new ConnectionFactory();
    
            factory.setHost("192.168.40.132");
            factory.setPort(5672);
            factory.setUsername("lscl");
            factory.setPassword("admin");
            factory.setVirtualHost("/lscl");
    
            // 2.创建连接
            Connection connection = factory.newConnection();
    
            // 3.创建频道
            Channel channel = connection.createChannel();
    
            // 定义队列
            String queueName="test_topic_queue1";
            channel.queueDeclare(queueName,true,false,false,null);
    
            Consumer consumer = new DefaultConsumer(channel){ 
    
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { 
    
                    System.out.println("body："+new String(body));
                }
            };
    
            // 接受queue的消息
            channel.basicConsume(queueName,true,consumer);
    
            // 不释放资源,让rabbitmq一直监听
        }
    }

### 4.5.4 消费者-2 ###

和消费者-1代码一样，只是队列名换了

String queueName="test_topic_queue2";

### 4.5.5 消费者-3 ###

和消费者-1代码一样，只是队列名换了

String queueName="test_topic_queue3";

### 4.5.6 消费者-4 ###

和消费者-1代码一样，只是队列名换了

String queueName="test_topic_queue4";

### 4.5.7 Topics模式小结 ###

在`Topics`下（`Exchange`类型为`topic`，也叫主题模式），`Routing Key`的用法更加丰富，主要有`#`、`*`两个符号，`#`号可以匹配0个或多个词，`*`号可以匹配任意个词，包括0个；

--------------------

下一篇：[《RabbitMQ系列教程-第四章-06-RabbitMQ工作模式之RPC模式》][RabbitMQ_-_-06-RabbitMQ_RPC]

[RabbitMQ_-]: https://blog.csdn.net/Bb15070047748/article/details/112194912
[https_gitee.com_Horizon1024_rabbitmt.git]: https://gitee.com/Horizon1024/rabbitmt.git
[20210104162554687.png_pic_center]: /images/20221120/dc994826a69e4415b9d8410219d0a6e9.png
[RabbitMQ_-_-06-RabbitMQ_RPC]: https://blog.csdn.net/Bb15070047748/article/details/112184884