RabbitMQ：Topics主题/通配符模式

绝地灬酷狼 2024-04-21 08:08 102阅读 0赞

> #### ✨ RabbitMQ：Topics主题/通配符模式 ####
> 
>  *  1.基本介绍
>  *  2.生产者
>  *  3.消费者
>  *  4.测试
> 
>   
> **?个人主页:[不断前进的皮卡丘][Link 1]**  
> **?博客描述:梦想也许遥不可及，但重要的是追梦的过程，用博客记录自己的成长，记录自己一步一步向上攀登的印记**  
> **?个人专栏:[消息中间件][Link 2]**

## ![2c783e96748a2cf5603b51266281ebe1.png_crop_0_crop_0_crop_1_crop_1_from_url_id_Jpp4w_margin_G_originHeight_324_originWidth_937_originalType_binary_ratio_1_rotation_0_showTitle_false_status_done_style_none_title][]1.基本介绍 ##

![image.png][]

*  Topic类型与Direct相比，都是可以根据RoutingKey把消息路由到不同的队列。只不过Topic类型Exchange可以让队列在绑定Routing key 的时候**使用通配符**
 *  Routingkey 一般都是有一个或多个单词组成，多个单词之间以”.”分割，例如： item.insert
 *  通配符规则:
    
     *  \#:匹配0个或者多个词
     *  \*:刚好可以匹配一个词

## 2.生产者 ##

public class Producer {
        
        public static String TOPIC_EXCHANGE = "topic_exchange";
        public static String TOPIC_QUEUE_1 = "topic_queue_1";
        public static String TOPIC_QUEUE_2 = "topic_queue_2";
    
        public static void main(String[] args) {
        
            try {
        
                Channel channel = ConnectUtil.getChannel();
                //声明交换机(交换机名称，交换机类型)
                channel.exchangeDeclare(TOPIC_EXCHANGE, BuiltinExchangeType.TOPIC);
                //声明队列
                channel.queueDeclare(TOPIC_QUEUE_1,true,false,false,null);
                channel.queueDeclare(TOPIC_QUEUE_2,true,false,false,null);
                //把交换机和队列1进行绑定
                channel.queueBind(TOPIC_QUEUE_1,TOPIC_EXCHANGE,"#.error");
                //把交换机和队列2进行绑定
                channel.queueBind(TOPIC_QUEUE_2,TOPIC_EXCHANGE,"order.*");
                channel.queueBind(TOPIC_QUEUE_2,TOPIC_EXCHANGE,"*.orange.*");
                channel.queueBind(TOPIC_QUEUE_2,TOPIC_EXCHANGE,"*.*");
                //发送消息
                String msg="日志信息:调用了xxx方法，日志级别是error";
                 channel.basicPublish(TOPIC_EXCHANGE,"error",null,msg.getBytes());
                System.out.println("消息发送成功");
            } catch (IOException e) {
        
                e.printStackTrace();
            } catch (TimeoutException e) {
        
                e.printStackTrace();
            }
    
    
        }
    
    
    }

## 3.消费者 ##

消费者1

public class Consumer1 {
        
        public static void main(String[] args) {
        
    
            try {
        
                //获取信道对象
                Channel channel = ConnectUtil.getChannel();
                //消费消息
                DefaultConsumer consumer=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,"UTF-8"));
                        System.out.println("消费者1把日志信息保存到数据库");
                    }
                };
                channel.basicConsume(Producer.TOPIC_QUEUE_1,true,consumer);
    
    
    
            } catch (IOException e) {
        
                e.printStackTrace();
            } catch (TimeoutException e) {
        
                e.printStackTrace();
            }
        }
    }

消费者2

public class Consumer2 {
        
        public static void main(String[] args) {
        
    
            try {
        
                //获取信道对象
                Channel channel = ConnectUtil.getChannel();
                //消费消息
                DefaultConsumer consumer=new DefaultConsumer(channel){
        
                    @Override
                    public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
        
                        System.out.println("消费者2接收到消息:"+new String(body,"UTF-8"));
                        System.out.println("消费者2把日志信息保存到数据库");
                    }
                };
                channel.basicConsume(Producer.TOPIC_QUEUE_2,true,consumer);
    
    
    
            } catch (IOException e) {
        
                e.printStackTrace();
            } catch (TimeoutException e) {
        
                e.printStackTrace();
            }
        }
    }

## 4.测试 ##

![image.png][image.png 1]  
![image.png][image.png 2]  
![image.png][image.png 3]

[Link 1]: https://blog.csdn.net/qq_52797170?spm=1010.2135.3001.5343
[Link 2]: https://blog.csdn.net/qq_52797170/category_12026287.html?spm=1001.2014.3001.5482
[2c783e96748a2cf5603b51266281ebe1.png_crop_0_crop_0_crop_1_crop_1_from_url_id_Jpp4w_margin_G_originHeight_324_originWidth_937_originalType_binary_ratio_1_rotation_0_showTitle_false_status_done_style_none_title]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/21/8322b6d68a9342bea1d93bebb6b63e32.png
[image.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/21/cb43fbd2c53a49deaa45f4e23f260f21.png
[image.png 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/21/b65292e122884cac936c0b889d194331.png
[image.png 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/21/67c2a1aeac8a4a9a9083e50a3260f364.png
[image.png 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/21/a1bc90a6ebfa44f28744003a473a742a.png