消费者订阅的时候可以使用多Tag过滤

来源：5-4 消费端广播模式讲解

慕丝614951

2019-07-30

老师,您好,消费者可以使用多个Tag来进行过滤吧?我在我自己本地测试是可以过滤消费的,不知道是版本差异吗?我使用的是4.5.1版本生产者发送的消息

消费者订阅消息使用Tag过滤

打印消费的消息

写回答

2回答

懂渊

2021-03-22

哪怕广播模式（集群模式肯定支持）下也是支持某个消费者设置只消费某些 tag 的（或也是支持的）。这里确实说错了。

String group_name = "test_model_consumer_name1";
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(group_name);
consumer.setNamesrvAddr(Const.NAMESRV_ADDR_MASTER_SLAVE);

// 集群支持  或( || )  TagA || TagB  这种方式  。
//      consumer.subscribe("test_model_topic2", "TagA || TagB");
//      consumer.subscribe("test_model_topic3", "*");
consumer.subscribe("test_model_topic3", "TagB || TagA"); // 广播模式支持选择某个主题, 或者 选择
//      consumer.subscribe("test_model_topic2", "*");
//      consumer.setMessageModel(MessageModel.CLUSTERING);
consumer.setMessageModel(MessageModel.BROADCASTING);
consumer.registerMessageListener(new Listener());