00:00
同学们,我们接下来该写什么了?接下来该写这个是吧,生产者了,我们上节课呢,把这个C1和C2消费者啊,消费方已经写完了,该写生产者了。对,我们绑定关系啊,包括交换机的主题模式以及两大队列,以及他们之间的绑定K键值是吧,绑定K叫ROK啊,都已经写好了。那么就差一个生产者该发消息,那怎么发呢?当然是按照我们文档来发了。我们文档上这呢,已经给同学们演示过了,说你看。说这么发谁能收到啊,这么发谁能收到啊?哎,这么发谁收到啊?诶,这些都是案例,对,你把这些作为发送方发送一遍,就能够得到结论,看看这结论跟我们现在写在文档上的结论是否是一模一样?
01:01
好,那我们一起来。发一下是吧,好,既然发的话呢,我们这张图呢,就暂时呃藏起来了啊,也不着急看了,接下来我们。回到这里。把我们的生产者再写一个是吧,来写个生产者。生产者的名字呢?我们就叫e mitit了,E mitlo表示发送日志完topic主题模式啊,就这么个意思。进来。完了,这个属于呃,生产者。生产者对吧,生产者好。完了,接下来呢,我们再去。打一个main函数,交换机都一模一样啊,所以把这边的交换机咱直接粘过来就行了,因为他们共用的是同一个交换机,对吧,好来了。接下来开始发消息,首先第一波不用想,肯定是又获取这个叫信道对吧,信道。信道解释咱曾经都解释过了,叫消息的通道,简称信道嘛。
02:02
完再往下信道直接发消息就可以了。发什么消息对发什么消息,发的就是这段消息这儿呢。啊这啊,无非就是发这种东西。他们之间的一个一个关系,来我粘过来啊,你看。无非就是发这个消息,咱们把这个图呢拿过来啊,这呢,哎放这儿。嗯,这。完之后紧接着咱们看一下。这个Q1绑定,这呢Q1的绑定中间是orange,完了带了两边带两个星吧,完了Q2绑定的是另外两个是吧,一个是以rabbit结尾的三个单词,一个是lazy是吧,Lazy的多个单词,那这个咱们都按照这个图一模一样啊,所以说这句话就是形容的是这张图好。把这张图拿走来,拿走。干什么呢?咱们把下面的需求粘过来。咱们要发什么东西呢?发这一堆东西。
03:03
对,发这一堆。这一堆东西呢,作为发送方发送,那么就是说我要写一个呃循环便利,对第一次循环发它,第二次循环发它,以此类推,将他们所有都发完,那么为了循环便利,而且呢,他们东西呢,是KY6格式镜啊k value6 k value6KY6对不对,属于是一个KY6格式,所以最后怎么。创建一个map。对,创建一个漫画。创建一个map的话,这呢,这就来了一个map是吧,Map完了呢,字符串类型的和字符串类型的完,这来一个叫帮顶是吧。ID是吧?Bonding k卖了我就再扭一个哈,卖了。这就完成了。完了,紧接着Bing map.put完了呢,里面呢,就是串是吧,空串总共多少个呢?非常的多。
04:03
有多多啊,就就这么多,对,你得把这一堆都粘过来完往里放一放是吧,因为我们要发这一堆嘛。这么的,我我先粘过来啊,粘过来的目的就是我打算这么的,哎,这个叫。粘贴。粘贴。粘贴。粘贴不行,不够了。完之后呢,你就下面眼睛要好使啊,不要不要写错呀。粘贴。眼神不够了啊,完了之后呢。粘贴。完了还有谁了?还有第这个吧,完了再来,再来两个。粘贴。还有最后一个。粘贴好完了把后面的对应上啊,这个要放到Y6值上,对。
05:08
没什么技术含量啊,就是在这粘的啊。别给粘错了。好。还有最后一个吧。行了,来上面这个呢,占完就可以不要了。去掉不好,就来了一个我们的一个发送任务是吧,就来了,对发送任务来了之后呢,紧急,我们下面就开始正式发送呗。那得需要便利是吧,对,需要便利。便历的话呢,我们便历什么呢?其实便历K就行了,没有便历并没有必要遍历Y流,而Y6呢,并不是发送的内容,对不对,你可以理解为是发送内容,那么前方这个是真正要发送的东西,我们怎么发送,怎么发呢?这么发是吧,用的是信道点上basic,点这个PA要求你填写的东西是来看。
06:00
交换机。揉配。属性消息体。对吧,咱们就四个参数呗,完了呢,交换机呢,拿过来啊,交换机的名字上面粘着呢,是吧,交换机的名字完了再加上下面是什么呢。是roting k是吧?Roting k不正是谁呀?正是这段不就是ROK吗?是吧,完之后紧接下一个呢,第三个呢,是没有值呗,那没有值就是捺直。对吧,啊,那那直就那直吧,完了紧接再往下呢,消息本身消息的内容,我们可以拿Y柳值就当消息,例如它叫ROK,哎,它就是。消息。是这道理吧,是啊,所以这两个值就在这里面了,你把这个对,把这个M进行遍历就可以,可以调取它的这个nt set点上。For for each,当然可以直接点上,应该点上。For each。
07:01
N推set,点上it高级透循管,对,就这样。完之后呢,紧接着我们把这个呢小写一下好。这个名字呢,就叫绑定K的一个实体吧。完之后呢,紧接着每次便利我们可以通过这里拿到它的这个K值是吧,点get。实体没粘着粘实体啊。点get。K值,而K值就是我们的roting k是吧?所以我们可以写叫rolling k,对,完了呢,Value值再来。Y6值就是我们的消息,所以改名叫message,消息完了之后呢,你再把发消息这件事挪进去发消息。完了,把这个肉丁K呢粘到这个位置,把消息呢再粘到这个位置,再进行二进制转换。
08:01
对吧,二进制转换转的时候要小心啊,这次可是中文的,一定要写utf。杠八。防止乱码了。完之,紧接回来。这个发完之后呢,你打印一句话,对打印什么呢?打印生产者发消息了是吧,诶生产者。啊,发出。发出消息,对,完了呢,冒号当然没有冒号,加上消息的内容。完了之后呢,你这块冒号隔开一下最好一点啊。好,到此就发送了呗。是吧,就按照这个写的呗。所以这就不要了啊,不要了,好,我们就完成了。
我来说两句