00:04
好,那那咱们这样啊,咱们把这个顺序呃,调整一下啊,我们因为因为这个刚才没出来啊,我们看一下这到底成功了没有是吧,成功是肯定成功了,就是他这儿为什么没有没有出来,我们先看一下这个,呃,消费者对于消费者啊。那定义消费者,那我们直接看。看这个。就看这个啊。哎,我再看一下啊。再看看。你看还是不行是吧,我看其实时间。这个时间这个事儿,我我看一眼,我调一下。换到五号是吧,这是肯定是我们今天的东西是吧。哎呀,看老板。没问题吧,对吧,啊,这是这是没问题的啊。是不是啊,我们这消息。
01:03
对吧,是没问题的啊。哎。呃,那好,这个没问题。这个没问题。那没问题,那咱们还是按照这个顺序来吧,按这个顺序来吧,那我们看这个。呃,这这个消费者啊,我们一会儿说他。那其实到这儿以后啊,呃,我还想给大家说,因为我刚才看到这儿了,这有个K啊,这K这是空的,其实我们也可以给他指定K。你注意可以给他指定key,那指定key怎么指定啊,也很简单啊,你发送的时候,比如在这儿发送之前啊,你这个message。嗯,七点。Sat。小case。看到吧,Set case啊呃,比如说呃,我这啊指定这个,比如它它就叫K杠。
02:07
加上I是吧。呃,为消息指定。呃,我我们这样啊,我再给你来一个,比如这个some topic是吧,呃,我来一个some。A。换了啊,主题换了。是吧?其实你换不换都行啊,不换也行啊,咱们还还用这个也可以。无所谓了。走。只不过他又又来了100条而已。那这里边儿我们看不到这个P是吧,然后我们从这看。刷新。你看这次是不是又K了。对吧,我们就看到了啊,里边有一部分是没有没有K的,你看这一部分是没有K的啊。
03:05
这是可以指定K啊。嗯,那这样吧,把这个。大家更新一下。是吧?把这个更新一下。好,那现在我们来看这个异步消息,呃,这个这个发送圣山角啊。异步同步,这是一步。呃,这个异步这这不说了是吧,然后这个不说了啊,这都都都不说了啊,这都不说了,那么我们这里边儿呢。说一些什么呢?说一些这个它异步和同步不一样的地方啊。呃,我们。
04:03
嗯。大家看这也是十条,这十条什么也是100条吧,啊这都不用,不用管它,不用管它,你看那不一样,这不一样。Send。是吧,我这儿也是剩的。Send,然后这样放了什么?这个这个啊,就是我在这指定的么。指定了。这个这个。回调。是吧,指定回调啊,这是异步发送啊,这个是异步。就是E不发。那这个我们这儿。对比着它来看。这是什么同步?第一对比呃,就能出来,这是同步,这是异步。那这里面有个on on success是吧,就是呃,当。啊当呃,这个我们我们。
05:04
呃,接单我们现在是客户端啊。接收到呃,MQ8送来的这个。At。这是什么?Result啊,这就是呃,到这个后,呃。居委会出发。呃,出出出,出发,呃。该。回调。就行。来回调方法的这些。是吧,啊,这个是发生异常了对不对,我们不用管它了啊,然后紧接着。往下。到这儿,这是for。
06:04
所结束是吧。注意啊。这一步很重要,让它休眠一下。这一步休眠很重要啊。这个休呃是。那个等一会儿。Sleep一会儿。为什么啊,因为这是异步发送的。所以这里边会出现一个什么问题呢?如果你这不休眠的话。他是。这边异步发送,然后紧接这关了,你那边还没有发送完的,这边已经都关掉了。就会出问题。我们先正常跑一下啊,先正常跑一下,呃。我这大家看我这换了个啊,我这换了个叫什么叫MY,刚才some啊,这个叫MY好。走起。
07:09
没问题吧,现在这是发送啊,发送过了,那当然我们可以看这。大家看是不是my topic对吧。然后。我们从这。直接刷新。啊,我可以把这个语言再换一下是吧。我刷新是吧。找谁呢?MY。他这个时间是就是刚刚。你看就刚刚这个时间这个这个这个这个这个很不好是吧,我们给大家指定一下他。亚瑟。
08:01
可以了吧,是吧。对不对。这就这就过来了啊,这就过来,这是没问题的,然后大家看一眼啊,我现在把这个。你干掉我们再来一个。你看。是报错了。对不对。就报错了,就你你这边没有发送的啊,那100个呢,太太多了,他也不显啊。你这边没发送的,这样还还把还把它关了。是不是,所以这个sleep啊,呃,就是。在里边一会是吧,啊写上啊。由于呃采用的是异步。发送。Oh。呃。
09:05
的,呃,消息。还未发售。嗯。就。行。OK,完毕。嗯,然后。对吧,哎,他就报这个错啊。好。那么这个我们清楚了,这里边儿呢,呃,再再可以给大家往里边设设置点东西啊。设置个什么呢,就是。我让他发送失败以后,比如说不进行重试是吧,不进行从试呃。Producer点。Of a set。
10:00
大家看啊,这个是set reres when send。啊,这是同步发送,下边这个是异步发送,看到了吧,这是异步发送啊零。啊领,那我这就指定,呃呃指定啊,异步发送失败后不进行。充实。对吧。另外还有一个啊,呃,大家看。我们看这。看。嗯,我们看这。My public就是默认它是不是都是分四个Q。对吧,默认分四个Q。那那我能不能指定呢。可以啊,在哪指定在这儿。
11:00
点set default numbers,比如说我指定几个,两个。对吧。啊,就是呃指令。这个这个新创建。的。嗯。Topic的。Q。数量为二。29。末是四对吧,那我们现在换一个啊,换一个,比如说换一个,呃,就我刚才写的比。是吧,这肯定是没有的啊,肯定是没有的。你看一眼呗。是吧,My topic a是没有的啊,当然我们从这就是不是就已经看到没有啊,那现在跑一下呗。
12:02
大家从这可以看到。你看QID是不是要么0.1。是吧,然后我们。嗯,然后我们看一下MY。两个对吧。刷新。呃,包皮克A。Have a。啊。呃,这这这这这个这个上面我们。我们我们从这看。还能看到什么东西呢?A状态路由。Consumer配置。
13:04
你看。是不是?咱们说过这个246啊,六六是什么?读写的是吧?呃二是只读,呃这个这个四是止血,然后六是读写的是吧,你看。这个数量一般是一样的。对不对啊,OK。也就是说,我们。呃,这个是。也是考虑一下啊。异步。消息。身份证。OK。
我来说两句