41_SpringBoot整合ActiveMQ之队列消费者

好，同学们，那上一讲给大家完成了spring foot。和MQ整合以后的这个队列的生产者，那么呃，最经典的两个用法哈，第一个呢是触发投送，第二个呢是定时间隔投送，好不多说了，那么接下来我们是不是要看看消费者了，那么老规矩，如果说消费者的话呢，生产者杨哥详细的讲过了，那么队列的消费者我们呢，就可以加快一点点，OK，首先boot MQ的。Consumer，因为微服务嘛，每个端口占用一个服务，那不废话，那么现在所以说我们呢，新建什么第二个微服务的工程好，那么工程名包名OK，那么下课的时候呢，杨哥提前给大家呢写好，那么这些呢，呃，我节约时间。就不让大家再看什么什么新建类新建包了，但是呢，代码呢，我们呢，干嘛重头写哈，那比如说当然像这个我就不会画了，是不是这这个主启动类的话，这个就不会画了啊好，那么来。

第一步那么新建第二步老规矩是配置类，那么泡沫的XL跟我们以前的一一模一样，所以说杨哥呢，直接一张过来，那么老规矩，那么现在这个，然后主要是什么，这个欧了脱，那么这个呢，POS面完火，那么第三步我们粘什么呀，是不是application yama，注意这是谁的消费者的，那么但是消费者的你懂得跟我们的那个。生产者的这个是不是差不了多少啊，那么直接CTRLC弄过来干嘛，直接粘，但是你懂的，这改成8888OK，因为这个是什么生产者的微服务端口号，这个是什么，是不是消费者的微服务端口号啊好，那么我们的什么第三步搞定，那么第四步队列的什么消费者，第五步主体同类，那关键而言就是这个队列的消费者，好吧，那么只要是不同，二话不说。

自顶向下脑袋上干嘛先写好，要么是service，要么是什么我们的component，好吧，那么接下来来吧，我那我们消费者，我们原来我们也在做入门程序的时候讲过，对于消费者要去消费一个队列，是不是有两种方法，一种是receive，一种是什么监听器，那么还记不记得，你看上面是不是讲过。直接通过配置完成干嘛？是不是需要写一个类来实现消息的监听啊一样，我们当时的时候是不是自己写了这么一个类，同学们没有任何问题吧，那么现在这是spring的版本，那么到了我们的spring boot呢？我们这儿是不是也要写这么一个类似于的监听注册啊，但是这个时候呢，就非常爽，那么来，你看spring put给我们整合的非常好哈，那么来吧，那么public void，那么呢，Receive。那么我呢，直接呢是text message，那么text message，那么throws，那么GS的exception，那么这个呢，就是标配了哈。那么这。

我要怎么来写这个东东呢？那么来吧，那么下面out，来看来看。消费者。收到消息，那么来，那么是不是test manager.get contexttest获得那么好了，那么这个时候完火，那么问题是你这个监听。体现在哪呢？那spring put牛就牛在这儿，那么大家请看这有个GMS的listener，然后OK，然后呢。Destination目的地，那么来吧，过来过来谁MYQEE什么意思，是不是说穿了就是还是这个队列呀，那么同一个队列嘛，对不对，我们说过消息的一致性，那么OK，那么在这了以后，那么大家请看我们这搞定，那么接下来搞定，那么如果一切顺利，我们这现在这个队列里面有几条消息，是不是有11条消息，如果我们一运行，那么这个时候我们是不是将会收到我们的。

共计这十条消息，那么主启动类，那么大家请看，这个就不多废话了，是最简单的一个，好吧，那么来吧，主启动类也没有什么其他需要额外添加的，我们来跑一下试试，那么看我们的消费者。消费者为服务启动，如果一切顺利，那么大家请看，那么干嘛呢？那么一二三四五六七八九十十一十一条没问题吧？那么头两条是我们点一下发一条，点一下发一条，后九条是不是我们定时每隔三秒钟发的？那么大家请看，现在是不是生产者和消费者生产多少，消费多少一一对应，而且大家请看在这儿是不是我们的消费者也在这儿实现着监听啊？那么如果现在我们的生产者再发送一条，他马上是不是就会收到，和我们以前的一模一样，那么好，那么说穿了，那么大家搂他一眼。

只有这么一个是新知识，其他的完全和以前照旧，以前我们还需要自己手工的写一个监听器类，那么现在监听谁就监听这个队列，然后干嘛，只要这个队列里面有消息了，马上打出来，那么用我们的一个receive方法就OK好，那么这个就是我们队列的消费者。