广东网站建设企业,音乐摄影网站建设宗旨,手工做衣服网站有哪些,无版权图片做网站一、消息过滤#xff1a;消息者在进行消息订阅时#xff0c;除了可以指定要订阅消息的Topic外#xff0c;还可以对指定Topic中的消息根据指定条件进行过滤#xff0c;即可以订阅比Topic更加细粒度的消息类型。对于指定Topic消息的过滤有两种过滤方式#xff1a;Tag过滤与S…一、消息过滤消息者在进行消息订阅时除了可以指定要订阅消息的Topic外还可以对指定Topic中的消息根据指定条件进行过滤即可以订阅比Topic更加细粒度的消息类型。对于指定Topic消息的过滤有两种过滤方式Tag过滤与SQL过滤。
1、Tag过滤通过consumer的subscribe()方法指定要订阅消息的Tag。如果订阅多个Tag的消息Tag间使用或运算符(双竖线||)连接。
2、SQL过滤SQL过滤是一种通过特定表达式对事先埋入到消息中的用户属性进行筛选过滤的方式。通过SQL过滤可以实现对消息的复杂过滤。不过只有使用PUSH模式的消费者才能使用SQL过滤。默认情况下Broker没有开启消息的SQL过滤功能需要在Broker加载的配置文件中添加如下属性以开启该功能
enablePropertyFilter true
在启动Broker时需要指定这个修改过的配置文件。例如对于单机Broker的启动其修改的配置文件是conf/broker.conf启动时使用如下命令
sh bin/mqbroker -n localhost:9876 -c conf/broker.conf SQL过滤表达式中支持多种常量类型与运算符。
1支持的常量类型
数值比如1233.1415
字符必须用单引号包裹起来比如‘abc’
布尔TRUE 或 FALSE
NULL特殊的常量表示空
2支持的运算符
数值比较BETWEEN
字符比较IN
逻辑运算 ANDORNOT
NULL判断IS NULL 或者 IS NOT NULL
二、
