内容简介：

写作目的
项目中各个中台都使用同一个DB。而DB下会使用中间件监听binlog转换成MQ消息，而下游的各个中台去MQ去拿自己感兴趣的消息。

TAG 如果使用TAG去获取自己感兴趣的消息，那么对于一条学生表变更binlog，最少要插入三条消息，比如TAG=学生表，比如TAG=UPDATE修改操作，比如TAG=学生状态为1，等等。想到的就三种。。。 所以上面这种方式缺陷还是挺明显的。
SQL过滤 如果使用SQL过滤的方式，我们可以对某些属性进行过滤，自己拼接SQL，灵活性就上来了。

但是我好奇的一点是SQL怎么加到TAG里呢？并且TAG只能支持一个属性值呀。所以接下来从源码和原理的角度进行分析和探讨。
总体来说Tag过滤和SQL过滤如下图所示

代码展示
本着简单的原则出...

查看原文

? RocketMQ的TAG过滤和SQL过滤机制