40_SpringBoot整合ActiveMQ之队列生产者间隔定投

那同学们，那上一讲我们呢，完成了spring boot和MQ整合以后的队列的生产者，那么通过单元测试类的。运行我们已经明白，我现在是不是点一下就发一条，点一下就发一条so easy，那么全部的套路那么就过来了。那么当然哈，最后那个第一步啊，那么基本上哈，我们来捋捋。首先那么肯定就是我们的什么建一个maven工程，这就不多废话了，那么第二步先把maven的泡鸟XL搞定，第三步application给yama搞定，那么说白了是不是工程配置，然后再是编码，那么接下来con病，那么我们配了一些什么呢？就告诉人家我们这个队列的名字啊，叫什么？当然我们这个队列的名字啊，最终在这定义了是不是其实是active MQ。这个类在用啊，那么我们是不是把它配置进了这个里面，当然你要把它写死啊，是不是不大好啊，说穿了这个是不是有点像我们以前在那个基础入门程序的那个什么public static final string。

Active我就不写了，能跟上是不是就是那个常量的那个名字啊，那么所以说这个呢，是我们的第三步，那么言下之见，用这样的方法就可以从application yama里面获得我们的TV建筑队的配置值啊，然后我们这因为是spring boot嘛，都是用注解了容器给它管起来，那么所以说脑袋上标这个，每一个B脑袋上标这个，那么我们在这儿就告明确的告诉。Spring，我们是要一个active MQ的Q，然后呢，重点。我们要开启enable界面S，那么这是一个新的注解标签哈，是spring boot跟MQ整合以后，那么接下来第四步，那么生产者。

依旧容器管起来，然后干嘛呢？我们用的是GS啊，Messaging template，其实说穿了跟那个GS temp都差不多，只不过有些功能细化的方法不一样，这个在boot里面。功能更强大一些，那么大家看我们这儿呢。生产，生产目的地到哪，到队列里面，那你这个队列哪来的我这个队列，那么大家看是不是在这儿啊，那么OK，也通过著作获得，然后来生产我们的消息，那么模板转换并发布，那么。往这个队列里面发这么一条消息，OK，然后大家看，那么这个呢，启动主启动类，不废话，那么最后我们写了，大家写了一个单元测试，然后巴拉巴拉，那么这三坨是什么？不讲了哈，杨哥在讲spring put的时候给大家详细说过了，那么我们这个相当于我们一个controlrler controltrler去调我们的一个service，那么这个service里面哪个方法生产消息的方法，我们点了一下生产了一条，那么我们点一下生产一条，那么你看同学们，我们再点一次，相当于在7777这个端口上启动了一个微服务，然后你看现在执行完毕，那么如果一切顺利，这个队列里面你看。

待消费的消息是不是两条啊，2020好，那么这个呢，就带着大家。做完了队列生产者，那么接下来在提升新需求，那么刚才我们讲的呢，是什么东东呢？就是。我点一下发一条，我点一下发一条，那么现在我们要求什么呢？来了个新需求，要求你间隔定时推送，也就是说每间隔三秒钟就要往MQ上面推送一条消息。那么。以下定时发送的case啊，那么案例呢，就要进行一下修改，那么首先就要增加一个什么定时投递的方法，建这个呢，就俗称什么呢？间隔定投，那么什么意思呀，就是以间隔三秒钟，然后呢，这样的一个频次定时投放，那么好，我们首先要修改队列生产者，那么怎么改呢么这一步啊，同学们，你们大家看一眼，这哥们就是一个普通的业务逻辑方法对不对，那么你。

我就在这等着，你吊我一下，我发一条，你吊我一下发一条很干净，那么接下来我们就要有一个定时投递，那么这个时候大家看。Public那么干嘛呢？VO，那么跟这个方法呢，我也还是叫这个名字吧，就偷个懒。然后干嘛呢，Schedule。那么这个时候就是带定时轮巡功能投递的，那么注意那么这块。有一点这个要注意一个细节，那么干嘛呢。我们这儿由于这个功能是叫什么，是不是间隔时间定投啊，那么间隔时间。

三秒钟。定投，那么所以说这个时候要开启一个新的注解标签叫schedule。那么来。在这儿，那么OK。过来。我们这儿有一个属性叫fixed，什么delay。来干嘛呢，写个3000。那么言下之意就是每。三秒钟自动调我一下，这个方法我就往MQ上面传递消息，好，那么其他的我们这儿一样。那么OK了，那么这边了不起，我这就写这么一个东西，Schedule的，那么代表的话，它是定时投放过来的，好，那么在这如果说我们这儿呢，如果一切顺利，那么就OK，好。开启了这么一个，那么接下来我们的主启动类。

我们的这个业务逻辑类新增了定时间隔间隔定投的方法，那么接下来我们要修改主启动类什么意思啊？那你在这儿加了这么一个动作，那么主体在启动的时候你这儿配置了，那么同学们以前杨哥在讲spring cloud的时候讲过哈，Spring还是非常的规矩，什么意思呢？你添加了一个新的注解标签，那么这是添了，那么用不用呢？用不用谁说了算，是不是主启动类的时号，你要把这个功能给我开启啊，那么怎么开？那么是不是enable干嘛你看。是不是说明是什么，你要把这个功能开启啊，如果你要想那个第一个这个是是否有没有，那么第二个就是有了以后是否激活没问题吧，好比说这儿你们家这儿添了一部空调，有空调了，但是开不开遥控器在你手上好了，那么所以说在这儿呢，就要有这两个小细节和步骤，那么。

来了，那么为了给大家好看哈，那么它调用一次哈，我干脆也就在这儿，那么。干什么呢？写一句话，那么这个时候来吧。Send OK，好吧，那么假设啊，我们三秒钟。往这个消息中间键投送一条消息，那么反过来讲，后台是不是应该看到这个话，对吧？每三秒钟就应该打出来这么一句话，那么OK，改完了以后，那么直接开启什么东道主启动内间隔发消息，那么来吧同学们，我现在直接开始来试试看。好。大家看。大家看没问题吧，这个灯没灭吧，是不是不像以前那样的话呢，是点一下。我就调用一次完成收高，你看现在是不是每三秒出一次啊，那么大家请看我们的队列里面，你看七。

八。等三秒九。还是九还没过来，12，那么OK，这个呢，就是我们是吗？队列生产者的间隔时间定时投放的一个案例，那么非常的重要，日常工作中这两种穿插着用，足以解决你。大部分的消息发送的功能，要么就是我点一下放一次，我点一下放一次，要不然就是什么我时间间隔定时投放，我每隔几秒钟发送一次，每隔几秒钟发送一次，那么从我的工作经验，我个人而言的话，这两个是要求大家掌握的，一个就是点一下头发颜色，就是触发投递，第二个叫间隔定投好，那么这个时候要求这两种同学们都必须给我拿下。