过滤消息的两种方式|学习笔记

简介: 快速学习过滤消息的两种方式

开发者学堂课程【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 的条件。下面是一个例子:

image.png

相关文章
|
3月前
|
网络协议 网络虚拟化
如何对接收和发布的路由进行过滤?
如何对接收和发布的路由进行过滤?
|
6月前
|
消息中间件 SQL RocketMQ
RocketMQ-初体验RocketMQ(10)-过滤消息_SQL92表达式筛选消息
RocketMQ-初体验RocketMQ(10)-过滤消息_SQL92表达式筛选消息
146 0
|
消息中间件 SQL 存储
解析 RocketMQ 多样消费功能-消息过滤
在消息中间件的使用过程中,一个主题对应的消费者想要通过规则只消费这个主题下具备某些特征的消息,过滤掉自己不关心的消息,这个功能就叫消息过滤。
302 0
解析 RocketMQ  多样消费功能-消息过滤
|
消息中间件 存储 网络协议
大厂都是如何处理重复消息的?
消息消费失败,很多框架会自动执行重试,而重试就产生了重复消息。 MQTT协议给出三种传递消息时能够提供的
280 0
|
消息中间件 SQL 存储
解析 RocketMQ 多样消费功能-消息过滤
在消息中间件的使用过程中,一个主题对应的消费者想要通过规则只消费这个主题下具备某些特征的消息,过滤掉自己不关心的消息,这个功能就叫消息过滤。
解析 RocketMQ 多样消费功能-消息过滤
|
消息中间件 存储 SQL
RocketMQ 5.0 多样消费功能详解消息过滤|学习笔记(一)
快速学习 RocketMQ 5.0 多样消费功能详解消息过滤.
398 0
RocketMQ 5.0 多样消费功能详解消息过滤|学习笔记(一)
|
消息中间件 SQL 缓存
RocketMQ 5.0 多样消费功能详解消息过滤.|学习笔记(二)
快速学习 RocketMQ 5.0 多样消费功能详解消息过滤.
279 0
RocketMQ 5.0 多样消费功能详解消息过滤.|学习笔记(二)
|
存储 消息中间件 Linux
多类型业务消息专题-顺序消息 | 学习笔记
快速学习多类型业务消息专题-顺序消息
多类型业务消息专题-顺序消息 | 学习笔记
|
消息中间件 Java 开发者
消息类型-顺序消息|学习笔记
快速学习消息类型-顺序消息
122 0
消息类型-顺序消息|学习笔记
|
消息中间件 存储 RocketMQ
【视频】顺序消息| 学习笔记
快速学习【视频】顺序消息
【视频】顺序消息| 学习笔记