095-消息过滤代码举例

好，那下面我们看一下代码啊，这代码呃，有这样的两种是吧，Tag的producer和consumer circle producer consumer，好，我们。The。先看太啊。Producer这个都是我们以前见过的代码，大家看这里边是吧，Tag啊，我我我这定了my tag AC是吧，然后我的消息啊，十条十条消息是吧？啊，然后这十条消息里边啊。是吧，呃，十条消息里边啊，我我给给这些消息啊，给他们tag tag是什么呢？呃，Tag就是呃。我让当前这个I和这个曲模，然后作为它的索引啊，这这个比较简单，我们不说不说那么多啊，就这样我把这消息发过去了，所以这这些消息里边啊，他肯定都有态度。

然后。直接这边。消费是吧，这这边消费啊，那这个消费消费的时候你看我订阅。我我定给定给谁就听这个和这个我没有那个谁。我就建议啊。订阅。他，嗯。他。的。点订阅tag。他一他。消息。对吧，啊不包含谁。是不是C呀。是吧，那这这里边儿这个消息啊。就是呃，发送的消息，呃，发送的消息呃。包含。

Tag。是吧？都包含这样这样的三三种啊T之一啊啊。T，呃，为下三者。是吧？好了。就这吧。就这我们跑一下，呃，这个topic topic叫my topic，然后我们这样吧。Topic我们不是，嗯，那个C这边没有那个C是吧，我们就用那个C啊。它C好。啊，十条消息是吧。然后我这边其实我们完全可以先运行消费者是不是。

你看。这里边儿T。在哪在这呢，看A。B。是吧，没有C。对吧，很简单，这就是相信过滤了。是不是OK？呃，然后我们再看一下谁呢，看一下这个circle啊。看一下这个circle circle上上表。是吧，生产者，那这生产者其他的啊，这都一样，呃，这里边儿我们上传下，你看这。看到没？这什么提前买入的。这啊，是事先。来。买入啊。用户属性。Eight。我们用数，这这这不是属性A吗？是它的值是吧？键值字的啊，你看一下啊，这个我放到哪了。

这不是name value吗？给它放哪？放到它里边是吧？Name value给它放它，它是放哪的。Properties。是不是就放到就这个里的properties里。是吧，这message一开始message里边不是。是吧，Properties这properties除了这些用户属性以外，还有我们说其他的属性啊，因为嗯，它真正发送的时候，并不仅仅是发送这个message啊，啊不是发送了它这个序列化以后的，我们前面不是说了嘛，是吧？啊不太多说了，呃，那这个有了以后，我们。再看谁呢？再看他。笑一笑。是吧，消费者，呃。这样啊。Po。嗯。特别愿意。

表一是吧，诶看到这啊，首先这是push。对吧，我从头开始消费，然后关键点就在这儿。这是什么？我这有个message选择器。By circle，我通过circle进行选择的，这个circle是什么？A减零。到六。你看这里边这就是这个circle表达式，它里边这是什么between转服啊，你看。Between。是吧，啊，然后呃，这是常量零六还有个and。是吧，And。啊，零六是不是常量。是不是这这就是这个这个SQL啊，这个这个表达式啊，我们可以用这些，呃，常量也可以用这些运算符。那也就是说这里边啊，要从呃，Op的消息中。

呃，过滤出呃，被解在呃零。零。六。点的。消息。是吧，OK，那就是其他没有啥变化啊，其他没有啥变化。