38_Spring整合ActiveMQ之监听器配置

同学们，最后一个我们来看看哈，Spring整合active MQ，我要求在spring里面实现消费者不启动。直接通过配置监听完成即可。更简单，那什么意思呢？同学们，就是前面这些哈。有点类似于我们之前讲过的这个消费者这个程序的这个receive方法类似是同步阻塞，那么你别忘了，我们这是不是还有一种方法叫set message listener。是不是设置监听器啊，而这是第一步，第二步是什么呢？我们再来看第二个问题，就是说我们队列还好说主题是不是有时候总要让你先启动消费者，然后再启动生产者，说白了就是先订阅，先注册，才能收到人家发布的对应主题的消息，好，那么接下来我们呢，重新来想达到一个什么样的目的和效果呢？也就是说。哥们儿，你不用再启动这个消费者。

我永远在这儿监听着，只要你生产者来消息了，我马上对应的订阅可以收到。好，那么这个时候我们应该怎么做呢？那么说穿了是不是就是把这一坨。变成我们的spring的版本呢？那么言下之意，是不是需要一个message listener这么一个类的实现啊，OK，走起，那么来吧。我们干什么呢？说明刚刚给大家说了，那么spring的配置文件我们要怎么个修改？那么来，刚才是加了个队列，这是加了个topic主题，那么现在我们是不是还要加一个监听器啊，那么这个时候请大家看。前面大家看啊，Jimmy factory队列。Tokamy。那么这。新增了一个配置监听程序。跑到这儿。

过来叫Jim container，那么这个时候大家请看他说了，我这个里面要引name，就叫什么message listen是这个类里面现在是不是有这么一个属性，那么这个属性说穿了我就跟以前一样，我需要引入一个这么一个实现类，针对于这个接口的，那么杨哥呢，给大家呢做了配置啊，相当于这个我们这就需要有一个什么东东，那么。My message lessoner，你看这是不是要实现一个message lessoner这么一个接口啊哦了，那么所以说呢，同学们过来，那么我们在这呢，不废话，Spring，这直接过来整个class，那么OK，那么这个class就是要配置我们的监听器，那么这个监听那么就是它实现一个什么东东呢？那么是不是实现了我们的这么一个东东，好，那么来吧，导入包和类，那么来吧，我们干嘛实现我们未实现的方法，那么这个方法里面那么。

热闹了，那么言下之意，是不是还是我们那些熟悉的配方，熟悉的味道，那现在做一个判断。那么如果说。不等于messages啊。你们干嘛？并且我们的什么东东呢？这个嗯，Message instant of test message，对吧？那么当然我们现在是不是就是拿text串来做测试啊，对吧？那么这个时候干什么呢？如果一切顺利那么好了，那么在这个里面我们是不是才可以text message，那么text message等于。干嘛？我们的message，然后你懂的是不是强制类型转换，那么转换完了以后，那么来吧兄弟们，那么再得到我们的test message.get。Test好了，那么由于有这个有异常往外抛，注意，那么现在那么复习一下spring，我要让这个容器识别我们的这个类有。

哪些方法，那么第一个，那么你看我们现在这种器是不是还错误着呢，那么言下之意，我们干嘛第一种我们呢，在这写一个并那么。I idea，那么这个I idea你看，因为这红色嘛，说明ID检语法检查器说过，那么挂了，那么来I idea I idea，那么class啊，那么这个class是什么，是不是就是我们的这个的完整的包名加类名，这一步同学们能跟上，那么扔过来，那么来同学们，那么这个时候相当于说我们现在是不是用这种XL。配置的方法就把这个病搞定，那么你看他告诉你了，我们这个接container，那么default message listen监听器需要有这么一个实现了message listener的这么一个接口的实现类，好，那么杨哥写了一个这个东西叫my message listener OK，那么怎么把它引入，我们是不是用BID啊，这个是spring的基础知识啊，这一步没问题吧，那么。

那两个要是这么配的话，是不是就配的，那假设又有别的类，那么每次是不是配的越来越多啊，那么干脆我们是不是一不做。二不修，那么同学们都明白，现在是不是慢慢的从XL的配置变成了注解呀，那么干嘛二话不说，这个时候是不是脑袋上COMPONENT1洗，你看马上是不是从红色变成绿色的键康了？那么眼下支线这么干了以后是不是我们就不少写这这一行的配置啊，我们用注解就替代了它，那么从这我们再复习一下容器里面的。Component，那么当然你要识别这个，是不是应该把这个写在首行？OK，好了，这些基础知识啊，不多废话，那么接下来我们要干什么呢？

需要编写一个类来监听，搞定了，那么只需要启动生产者，消费者不用启动，自动会监听记录，那真的有那么神奇吗？那么兄弟们，我们呢，来看一眼。好。那么现在托。大家看什么都没有吧，那么欧拉只需要启动什么生产者，好，那么生产者我们来看一眼，那么这个时候，呃，这个时候呢，是PHOTO22，那么这个时候呢，我们是由于是监听器，对吧，我们改吧改吧，那么这个时候监听器，那么我把它改成什么呢？333好吧。那么来同学们，那么消费者收到的消息跟以前一样，那么来注意啊，以前我们是不是要先启动消费者，然后再对由于对于这个主题而言，是吧，但是现在。我们看一眼，对于我们的主题而言，我们现在呢，还是用topic皮口，那么脱皮口我们说过以前是要先消费，先订阅，消费注册才能生产，那么现在我们没有启动这个，那么来看一下我们运行我们的消息的生产者，如果没有什么意外，我们现在是不是没有启动这个，消费者直接生产就能监听到，自动打出来。

好，同学们请看一眼，生产者已经发送完成了，但是回答我是不是消费者并没有打出这句话，消费者收到的消息，那么最终我们是不是应该把这个333打出来呀？那么干嘛？那么问题出在哪呢？别着急，好，那么程序应该没有什么太大问题，那么杨哥检查一下我们的配置文件。好，我们的队列在这儿没问题，我们的topic皮口，哎，你看同学们马上也就是说我们在配置监听的时候，我们现在是不是要监听啥，是不要监听我们的一个topic皮口啊，你看。这是脱皮口，这是队列是不吻合啊，那么所以说我们要监听我们的脱皮口弄过来，那么刚才的时候这是不是个队列，所以说呢，错位了，那么再来看看现在呢，我们呢，定义的topic皮口叫spring active MQ topic皮口那么好这些哈，我先给它全部删掉。

干干净净的再来一次啊，那么大家请看脱皮口脱口脱口，那么我们想达到的效果是什么？不启动消费者，然后只要有生产来了，333，那么我马上自动而然自动自发的能够获取收到，我们来试试，那么这个时候我一跑。来怎么样，同学们没问题吧，你看只要生产者send task over，马上消费者监听到，那么你看这个时候是不是就是我们的333啊，OK，那么言下之间，这种情况下呢，就是什么不用再启动我们的消费者先，然后直接只启动我们的生产者，随时给你监控着，这么说同学们没问题吧？那么言下之见是达到了我们的效果，在spring里面可以实现消费者不启动，直接通过配置监听完成。

好，那么这个呢，还是很重要同学们掌握一下。