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

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

开发者学堂课程【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

相关文章
|
4月前
|
网络协议 网络虚拟化
如何对接收和发布的路由进行过滤?
如何对接收和发布的路由进行过滤?
|
前端开发
前端学习笔记202303学习笔记第五天-使用全局过滤器过滤时间
前端学习笔记202303学习笔记第五天-使用全局过滤器过滤时间
54 0
|
SQL 存储 消息中间件
RocketMQ的TAG过滤和SQL过滤机制
写作目的 项目中各个中台都使用同一个DB。而DB下会使用中间件监听binlog转换成MQ消息,而下游的各个中台去MQ去拿自己感兴趣的消息。
401 0
RocketMQ的TAG过滤和SQL过滤机制
|
消息中间件 存储 网络协议
大厂都是如何处理重复消息的?
消息消费失败,很多框架会自动执行重试,而重试就产生了重复消息。 MQTT协议给出三种传递消息时能够提供的
292 0
|
消息中间件 存储 RocketMQ
【视频】顺序消息| 学习笔记
快速学习【视频】顺序消息
【视频】顺序消息| 学习笔记
|
存储 消息中间件 Linux
多类型业务消息专题-顺序消息 | 学习笔记
快速学习多类型业务消息专题-顺序消息
多类型业务消息专题-顺序消息 | 学习笔记
|
消息中间件 Java 开发者
消息类型-顺序消息|学习笔记
快速学习消息类型-顺序消息
124 0
消息类型-顺序消息|学习笔记
|
消息中间件 RocketMQ 开发者
顺序消息分析|学习笔记
快速学习顺序消息分析
顺序消息分析|学习笔记
|
消息中间件 RocketMQ 开发者
顺序消息原理|学习笔记
快速学习顺序消息原理
顺序消息原理|学习笔记
|
网络协议 测试技术 Go
服务端转发消息思路分析|学习笔记
快速学习服务端转发消息思路分析