00:00
那么同学们再来哈,别着急啊,一开始的入门案例,杨哥是要给大家整很多东西的,你们不要觉得干嘛,会编就行了,重要是案例好。同学们接下来。我们现在呢,直接过来啊。现在请看我们是不是先生产学生提问了,跑到这儿好吧,那么懂的,那么你懂的,3030,我相信同学们都明白吧,那么现在我的问题是大家看,那么现在啊,呃,如果说消费到了我们就这么干哈,没的话呢,就这么着,我现在呢。干什么意思呢,乘?两个。消费者这么说能跟上,那么现在我们这种情况啊,现在的话就是这个消费者入门这块了哈,那么请同学们呢。消费者情况哈,啊,算了,别写在这了,还是先写到写到我们的代码里面吧,在代码里面呢,痛快点好看。
01:04
第一种情况。那么。先生产,然后。启动一号消费者。然后再启动二号。消费者。问题,那么就是二号消费者。还能消费消息吗?好,这个问题同学们没问题吧,首先我们先说啊,先生产,然后启动一号消费者,一号消费者能不能消费100%能这个大家演示过对吧?那么这个时候大家请看,那么现在我直接过来生产了三条,那么大家请看现在干嘛?你看6060什么意思啊啊是不是以。
02:00
上面有三条,这次又来了三条,总共六条了,但是没有消费者对吧,那么现在我们来看一眼我们的消费者,那么第一种情况,那么假设哈,就是这样吧,再给同学们。只启动一号消费者,那么呢,这是第一种情况哈,那么这个是这种情况。第二个呢,是。先启动一号消费者,那么再启动二号消费者,那么。大家看,只启动一号消费者没问题,一号消费者。能消费吗?那么同学们这个怎么打100%是不是yes啊,那么大家请看一下啊,我们这儿呢,消费者只有一个好吧。过来。那么现在MQ里面没有消费的消息总共有六条,那么两次,123123妥了,那么这个时候同学们请看队列,0166欧巴,那么现在我们呢,为了好看继续删除,那么干干净净的啊,那么现在呢,大家请看这点硬干嘛,灯是不是一直亮着呢?好,我先把它关闭,那这个消费者我们也不废话了。
03:14
那么现在第二种情况干嘛,我。先生产,没问题吧,那么大家请看队列里面3030O吧,那么好,那么接下来我们要完成的任务和工作是第二种情况,先生产,先启动一号消费者,再启动二号消费者好吗?那么好,同学们,那假设啊,我这儿呢,直接过来吧。我是一号。消费者。同学们,这一步没问题吧?现在请看消息队列里面几条消息,三条哈,那么大家请看,我是一号消费者。
04:00
过来。消费,消费到一号能够消费。好,那么这个时候。下面的问题是二号。可以消费吗?那么大家请看,我现在改吧改吧,我是二号消费者,这么说能理解,我再启动一次,听懂了吧?那么这个时候请看一号消费者消了以后数字应该多少,是不是0133 0133,现在消费者有几个,一个11号消费者,好,这个时候同学们请看,严格启动二号消费者。我是二号消费者回答,我有没有消费,没有,这个时候大家请看队列变成多少,0233,为啥?因为第一个消费者进来,是不是把这个队列里面的三条消息全吃光了,那么所以说第二个消费者,就算你挤进来了,不好意思啊,我也只是在这儿是吧,默默的监听,我什么都吃不到,所以说这种情况下干嘛能不能游戏,这种情况下怎么样,没戏,因为消息已经被消费掉了,干嘛带出来的消息数量是减零,所以说就算你再再来第三个消费者什么东东都没有了,那么好,那么接下来继续。
05:24
干嘛呢?先启动什么?两个消费者注意,顺序反了干嘛?再生产。比方说六条消息。那么请问。消费情况如何好,那么第三种情况非常重要,好,那么这我们先下课休息一下,待会儿回来再给大家讲第三种情况。各位亲,我们继续那前两种情况整完了,那么下面我们来看第三种情况,反过来啊,先启动什么两个消费者,再生产几条六条消息,请问消费情况如何?那么是这样啊,3.1那么。
06:14
两个消费者。都有六条。3.2干嘛呢?就是先到先得。那么。眼下直线,比方说我先启动一号消费者,再启动二号消费者,好那么现在先一号二,那么干嘛。六箱全部给一个。3.31个简单一句话就是一人一半。好,同学们思考一下。好,各位同学能能理解我这个意思吧,比如说哈,现在呢,杨哥先启动两个消费者,我就在这候着了,哎,跟前面的两种情况反过来了啊,所以说你看杨哥讲课不是教你一个简单的hello的编码,这个就是实际工程落地的时候,先启动谁,后启动谁,生产消费怎么个情况,咱们是要有讲究的。
07:20
消息中间键非常重要,启动的顺序,消费的顺序,订阅发布的顺序,都会影响到你程序,你不要只会编码,我们这真不需要初级编码选手,而且你也不要去看什么书了,哎呀,坦白讲了,干嘛你呢,基本上呢,你也没有时间去看,你呢就在这儿跟着杨哥学,因为到最后你会发现干嘛你看书。和跟我学作用是不一样的,基本上你现在的感觉是不是都是工作了以后,包括到后面都有很多老学员反馈回来干嘛,是不是书到用时方恨少,钱到月底不够花呀?好,那么接下来同学们搂一眼。
08:02
先其中两个在这耗着了,那么假设我生产六条,那么言下知甲啊,那么这消息变成六条。好,那么两个消费者,那么123456。第一种两个人都能得到六条,那么就是一,那么就是相当于说雨露均沾,阳光普照,一号消费者六条,二号消费者六条能跟上。第二种先到先得,六条全部给一个,那么一号消费者先启动,二号消费者后启动,这六条先来后到队列嘛,我就只给一号消费者,二号消费者干嘛?就是拎第三个,一人一半。不用六除以二等于多少,一人几条小学数学不用我多废话,那么好,同学们请看,现在我们呢?上一个0233还没停呢,好,我们现在先停下来,Stop,那么O了,现在同学们刷一下,干脆删掉没问题吧,那么现在又是干干净净的了,那么注意我现在呢,重新来啊,我是一号消费者,同学们请看。
09:06
启动了吧,是不是在这候着监听了,好,那么接下来我是。二号消费者我再启动,再来一个进程,那么这个时候大家请看一号二号,那么注意现在是第三种情况对吧,你看一个hello的程序,各种情况先让同学们熟悉和。深弱,由浅入深,步步递进,那么下面我的问题是对于三,那么同学们请看一号二号两个消费者在这候着了,现在一生产这六条怎么分,大家再思考一下。好,那同学们。买定离手咱们开了,那么这个时候大家请看,先说从一号看啊,一号是先启动的,那么当然我们这大家请看0200什么意思啊,是不是有两个消费者在这候着了,没错,跟这儿你看灯。
10:00
干嘛?是不是两个消费者在这候着,Stop process,那么stop all2个都停,那么言下之见,0200哈,那么同学们,各位观众搂他一眼,我跑。消息发布到MQ完成,那么这个时候大家请看一号消费者多少135,二号消费者多少246,那么这个时候干嘛沿下直线,我们来猜猜这个数字应该是多少,如果两个人都是六条,这个数字是应该是二六一十二啊,那么这个时候大家请看多少0266什么情况我们就会明白。原来假设第三种案例,两个消费者,后者对于生产者发出来的消息,假设我们是同一个队列,所有消息我们怎么样平均AA分配,所以说这个时候我们选择哪一个,是不是一人一半,这个才是我们的yes,那么从这我们就可以得到消息消费者默认是不是有点负载均衡轮询,这样的话一人一个一人一个左右,左右是不是天生就带着一种有点像什么负载均衡轮巡的?
11:14
种味道和思想啊,好,那么同学们,那么大家请看0200那么回答我,我现在已经把灯是不是全灭了,你跟我讲这个消费者既然。能理解好,那么这个就是我们的是吗?突破好先给大家介绍的最基本入门的三种情况,好,那么最后那么大家呢,可以看一下我们的第二种是不是消费者这种情况,那么消费者这种情况呢,也给大家呢。干嘛做好了笔记,那么它是通过异步非阻塞的方式干嘛?监听器on message,那么干嘛巴拉巴拉,我就不念了,注册一个消息监听器,以后来看我们这儿呢,都给大家讲过那么好,那么方法。
12:02
监听方法还有消息的三种案例。入门级别helloard对于。同学们都做了详细的解释啊,那么下面要求大家按照严格的方法流程和步骤,我呢把这个东东发给大家,大家呢来进行一下课堂练习,当场给我编代码,写成功写出来。
我来说两句