080-顺序消息代码举例

好，那么下面我们来看代码啊。代码order就是游信息。大家看。这前面的不用多说了是吧，然后紧接着我这儿生产100条消息。是吧？呃，大家注意啊，大家看我这儿来了一个order ID啊，这个older ID我我。我是。这是我们就为了演示，仅是为了为了示简单一些。简单啊，这个。使用整形。嗯。整形。呃，作为。我们生产环境下啊，这个OID实际上不是整形的啊，不是整形的。啊，然后我就用用这个I了啊，然后紧接着啊，就我们消息体这消息是吧，然后紧接着。

肾的，大家注意肾的。这算里边加了一个什么。Messageq letter。你们来不来？对不对。这就是我们定义的这个选择器。然后具体的选择算法在哪。嗯。具体的。对吧。所以。那我们这个选择算法啊，我看一下这里面都是什么东西，不过呃，在说这个选择算法啊的时候啊，我们大家需要注意注意什么呢？你看一下它。算的方法啊，有几个参数三个啊，第一个message，第二个我们选择题，第三个在这。

我这放了一个ORD，这这个你放什么都行啊，我这放了一个O的RD，我们看一下啊。我们看一下啊，一个两个三个第三个参数啊二。这A。是谁？A。是吧，啊这个啊，这个参数啊是什么呢？呃。他他他和谁和我们的消息队列选择器什么啊，一同工作。也就是说啊。也就是说我们这里边儿这这个order ID这个。和这和消息选择器里边这个A是同一个值。那这是我们大家需要。需要需要了解到的啊，需要了解到的。呃，这个。肖。这样写吧。

的第三个。参数。啊。第三个参数。呃，会。第三个参数群会。传递给。呃。选择器。Select。三个。就会会把它传递给他。所以这个APP指的谁？Order ID？就我们这儿传过来这个order ID啊，所以你要知道它是干嘛的。对吧。呃，另外呢，我们大家再注意啊，我现在写这个方法。呃，他是。同步。我们前面不是刚说了吗？呃，这个发送有同步发送和异步发送。是吧，还有单向发送吧，这个是什么？这个是同步发。

三对。他有有有个了，哎，他有没有义务发送。呃，同时也能定义我们的这个。消消息的有，当然有啊。你看一下是冲载你看。是吧，显得性。是吧，你看选择器加上这个set back，只要有set back的，那肯定就是异步的。对不对啊，所以这完全是可以的啊，我们就没有写它，你知道啊，怎么怎么样定义那个，那和我们前面，我们前面定义的。这个里边这个异步的是一样的，我就不说了。那我们看啊，我们的选择算法是什么。我的选择算法啊，这也也就是这个是我们的order ID ID和谁。这个是我们的是不是Q。是吧？Q，列表点size，我取模。

啊，驱魔结果。我是从它里边去选，就是选出来的。对不对，这就是选出来的。那么我问大家，你说我现在。这里边儿的选择K。是谁？这边选择K是谁，其实这个选择K，我现在用的就这个ID，就我的order ID。就他。他是做过我的选择题出现的。对吧，但是我们说了这种，就是你老来给大家演示这个意思就是说。你可以用。其他数据作为选择题。是吧，其实选择K啊，确实说这个选择K就是他。这个东西叫选择K。这道选择题你通过它可以传进来，或者用它就行了。但这个老师刚才给大家说，它存在的问题是什么，有可能会出现重复，出现了重复。

呃，就是不同的选择，可最后选出来的我们的Q是相同的，所以我们我们的consumer端需要对。需要获一道这个选择题，那这时候我们这种写法其实就不好了。那怎么办？其实我们可以这样做。我在这儿。就message不是有了吗？M点。Sat kiss。是吧，我让谁让order？OLDID。啊，太阳字符串是吧。然后再。啊，将order ID作为什么消息消息。对吧，Order ID作为消息。然后我这里边儿选的时候怎么选。那我就不这样写了。为了不这样写了。嗯，我怎么给大家。

两个注释呢。啊，以下是呃使用。Show。嗯，他作为。选择题。选择。是吧？你给我把下边注释掉，那那我现在这个呢。现在这个，那这不是有消息吗。Get。Key kiss。是吧？That kiss啊，这个kiss是什么？其实就是就我们这个。ID。直播他现在是字符串。是吧，他现在字符串那。嗯。其实其实吧，然后我我可以这样。呃，你家不是用那个ID吗。

听下第二。Value of。Cheese。I。是吧？以下是使用谁使使用消息key作为选择题的。选择。是吧，就这这两个里边你选择一个。是吧，然后。给注释掉，你这样的话大家看一下。是我这个我我我使用我使用这个消息K啊作为选择K，而我这个消息K是不是这边也传过去了。对不对，那这种就可以了。是吧，这样的就可以了。

那就这样，我们简单跑一下就行了，只要能运行起来就可以啊呃，我这这个是topic a啊，用的topic a t a。OK，成功了对吧。啊，这就这就可以了啊，这就可以了，你想看一下，我们可以简单在这看一下它。他A。是吧，啊，这这肯定肯定没问题啊，啊刷新再看一下。WA。是吧，消息。嗯。Topic。哎。是吧？TA，肯定没问题啊，这肯定没问题，OK。

嗯哦，错错，这这这这里边儿有一个地方啊，咱们没有注意，你现在把消息都。发到哪了？呃，发发到四，这现在四个队列啊，你注意现在现在我们做这个其实有个问题，有个问题啊。嗯。是不是我们顺序消息啊，那肯定不能这样写。是吧，我们这说点。晒。Before q numbers。我必须得写上它一。对不对，这这这步很重要啊。是吧，这步很重要，哎，也不也不见得是吧，呃，或或者说不是不见得是不用不用不用不用，就突然想到不用啊。因为我们。

我们这个有选择算法。是吧，我们属于分区。顺序分区顺序啊，分区有序。对吧，我们不是全局有序啊，我们可以指定可以不指定，那这用不着指定，我们不是全局的。写上它啊。若为全局。呃，需要需是需要设置。但是我们现在这个是不是不用管。OK。那我们这个代码就写到这儿。