开发者学堂课程【RocketMQ知识精讲与项目实战(第一阶段):过滤消息的两种方式】学习笔记,与课程紧密联系,让用户快速学习知识
课程地址:https://developer.aliyun.com/learning/course/702/detail/12386
过滤消息的两种方式
内容介绍:
一、根据 TAG 过滤消息
二、根据 SQL 语法过滤消息
一、根据TAG过滤消息
生产者在发送消息到 MQ 之后,对于消费者来讲,它可以根据一些条件过滤,需要
对哪些消息过滤,哪些不需要。
过滤的方式有两种,第一种就是根据 TAG,因为在进行消息发送的时候,可以指定
第二个参数 tag,所以在消费的时候也可以根据这个 tag 来进行过滤。
二、根据SQL语法过滤消息
RocketMQ 还提供了 SQL 语法的这种过滤方式,比如说,发送消息的时候,发送了额外的指定参数,这里可以看到参数的名称、参数的值可以是任意的,在消费的时候就可以根据这个 a 和这个值的一个范围,去进行一个消费,可以去按照熟悉的SQL 语法去写,上面的例子写的就是 a 这样一个表达式,条件是 a>5 AND
b=’abc’,因此左边的这个消息就可以被消费,而下面的消息不能被消费,因为不
满足 SQL 的条件。下面是一个例子: