43_SpringBoot整合ActiveMQ之主题消费者

来，同学们，我们看一下topic主题的消费者的编码步骤和套路来。首先工程名报名不废话碰不废话application的yama这个说一下，由于我现在呢想更多的给同学们呢，模拟呢是什么多个用户，那么现在请大家看主题的消费者，那么我们呢。POMXL不不说了，那么这个是我们的application叫yama，那么第一个我叫5566，那么这个时候的话呢过来。我们呢，直接占。那什么意思呢？同学们，也就是说我现在最终呢，我要模拟两个消费者在那监听，那么这个时候第一个叫5555，那么其他的这些都一样，那么讲过了，错代表topic皮口，First代表队列，那么待会启动完了第一个5555以后，我会把它改成5566，好吧，模拟两个消费者，那么这个时候呢，是什么呢？我们的什么？

第三步工程没问。BOO的配置第四步，Topic consumer，那么来吧，那么这块呢，就是topic consumer，那么来同学们也就不写了。和刚才的一样，因为已经写过了，好吧，说白了消费者组件让spring boot容器识别，然后呢，Jims listener详细讲过了吧，再写一遍没有任何意义了，所以说这个呢，我们呢就节约时间，不再废话，那么妥了，那么这个呢，就是监听了以后，监听到这个my topic口，那说白了是不是监听着这个队列。监听着我们的这个topic，这个主题不是队列哈。那么监听着我们的这个topic皮卡，那么有问题了，那么直接拉过来消息使用，那么好这个消费者那么模拟两个订阅，那么一个是5555，一个是5566，那么这两个有什么区别呢？那么大家搂一眼。

MAY5555在这叫5555好，也也就是说我们兄弟们，我们都明白，现在第一个是不是叫5555，所以说我这个叫MAY5555好，我们不废话，先直接给他启动。来相当于说这哥们是不是现在是不是就在这监听了。好，那么。灯没有灭。来了，555完成以后，我们这第二个要改成五五多少六六，那么好了，那么这个时候我们要打开5566这个，因为这些呢都是很简单的，我就不再重复的去敲5566，那么这个时候我们再运行5566，那么大家都晓得这个时候干嘛，我们现在是不是相当于说注册了两个。脱口的消费者啊，你看消费者的数量，现在是不是有两个，那么没有消息呢？那么好了，那么接下来。我们呢，老眼测试，我们上一讲讲的这个定时发送的基于主题的生产者，那么现在我呢，每三秒钟发一条好，我们的这个6666这个端口号启动，那么你看6666是不是我们的topic皮口的是吗？生产者那么。

好，同学们，那么往下翻，那么接下来我们呢，来看一眼我们的5565555，那么看怎么样，是不是后台有东洞啦，那么大家再来看偷西口，你看二七十四没错吧，怎么着二八一十六没错吧，两个消费者你看12345678，当然又过了过了三秒钟又发往下发了，那么言下之见，你看。现在什么概念，是不是有三个，有一个是什么topic口的主题发送者有两个，55555566，是不是两个消费者先注册了，然后呢，监听着，只要你这儿有消息推送过来，我马上能够获得，那么大家请看我先把它这块删掉嘛，那么来这块干干净净的删掉，那么来看5555。

ED5254，那么我们是不是六位的一个随机字符串，那么过来这这看，那么ED525469，什么6962BD，那么6962BD有吧，那么6962BDOK，那么这个就是我们的什么东东。Topic的消费者不难，这是最简单的一个，对吧，所以说有些东东的话呢，一说讲到这儿了，大家就应该懂了，好，那么这个就是我们spring boot。和active MQ整合以后的相关的队列和topic口的全部编码的日常工作，API注解和流程，One同学们下去一定要把它操练成熟，工作中就要用这些东东好，那么同学们动手练一下。