54_ActiveMQ消息持久化机制之JDBC配置mysql-下

好，同学们那。接下来我们要进行代码的验证，并且看数据库的情况，那么现在数据库是不是有库有表结构，但是还没有数据啊，那杨哥如果你的代码运行OK，给我们的讲解顺利，那么言下之意是不是应该是出现MQ上面。有对应的记录，数据库里面也有对应的记录，好同学们开工，那么接下来我们来搂搂一眼，由于这个是持久化，要到数据库，我们呢，最好呢，要开启我们的持久化，那么说穿了。Deliver mode OK OK吧，所以说知道为什么前面要讲什么事物持久化签收了吧，那这个呢，是MQ自身带的，那么我们呢，不多废话，那么先从队列开始，再到我们的topic口主题订阅发布，好，那么从生产到消费者来。那么生产者那么注意，我现在已经改回初始状态哈，61616了，那么这边我们假设我们就叫GDBC吧，好吧，那么GDBC0接这么一个队列，那么注意。

我们呢，过来这就叫GJDBC做好这个测试，那么JDBC消息，那么这我们有一个message producer.set deliver mode，那么deliver mode.persist这是持久化，OK，第二步是什么，我们的消费者，那消费者嘛，倒是不用动，那但是呢，那么注意啊。我们这已经改成了叫JDBC了，那么注意IP，还有它这个队列的名字也不一样哈，那么来吧，同学们，我们呢，如果以队列作为模型的话，那么相当于是不是先发送好同学们。来发布消息到MQ完成，那么首先同学们，我们在这儿3030正常吧，MQ正常吧，MQ这侧好，那么发了以后我们来搂他一眼，那么下面叫六和七两步连起来看，那么来看看我们的数据库有什么变化呢？

一旦运行了生产的扣，对于我们的点到点模型，好吧，那么来吧，同学们，我们现在再来看看我们的message这张表，我们现在一刷新。怎么样？是不是已经有了我们对应的数据库的记录啊，那么这个时候大家看MQ上面几条是不是GDBC0线队列的名字啊，那么大家请看这块是不是发布的是个什么发布到队列里面，因为container是容器，但是我们刚才前面介绍过，这个是不是就叫什么目的地啊，那么所以说现在目的地就是队列，这个队列名字叫什么？GBC01，那么这个消息的什么message是IDMQ自动生成的，那么顺序发了几条，三条1233条，那么好，那么过期时间000代表永不过期，消息是一种二进制的字节流，那么最后我们来看一下。

那么这个东东的话呢，干嘛，那么它是这个留的这个信息哈，暂时看不到，那么最终他的这么优先级，还有事物ID等等，那么回答我现在是不是三条记录已经在我们的message这张表里面了呀。这一步同学们没问题吧，好，那么接下来说明什么，我们的配置啊，我们的。CQ的同步，我们的代码没有问题，那么接下来我们要看看什么消费，那么消费又变成什么样呢？那么大家露眼注意，对于我们的MQ而言哈，消费的话呢，这是不是变成三零，三零这是生产。然后我们这儿看一下消费者的代码哈，兄弟们，消费者代码我们这儿等四秒，四秒钟以后是不是这个灯就灭了，那么灯灭了以后，这三个消息是不是从待消费就变成了已出对了，那么来看一下哈，我们这儿的状态我一运行，那么这个时候同学们我一刷新。

还有吗？居然没有了，那么什么意思啊？你看GBC的MESSAGE123。干嘛，是不是全部后台消灭的消灭掉，那么这个时候我们再点队列0033，为什么？因为四秒钟以后，那个消费者灯灭了，他已经走了，所以说连着的消费者退，但是三条进来，三条消费，正三负311对应，那么我们的队列配置成功，好，那么这个时候我们来看看点到点是什么意思呢？如果我们上面是。非持久化的，那么消息将会保存到什么内存当中，如果我们的消息是持久化的，那么将会保存到我们broke的相应文件，比方说以前你用的是DB，或者我们现在说是MYQL数据库，那么现在刚才的话，我们是不是确确实实看到三条那么好兄弟们，那么点对点类型之中，消息一旦被消费掉，消息就要从什么broke，那么也就是我们这些持久库里面。

删除干嘛，证明你已经消费掉了，OK，好，那么这个呢，就是我们对应的。嗯。用代码呢，验证了MQ到MYCQ队列方面的形式，那么先给大家说到这儿，待会儿我们来证明topic口。来，同学们上一讲，我们完成了MQ队列到MYCQ的相关操作，那么各种编码当场给大家演示，那么我们运行了生产code以后，对于点到点的模型，那么要求设置为persistence，那么可以采存到数据库。那。接下来我们看了以后，我们的。队列message这张表是不是差了这么几条消息，那么这个呢，都给大家呢，刚才呢演示过，那么接下来。我们来看一下哈。如果我设置为这个呢。好。同学们。首先。

我们来先看一下啊。清空message，现在是不是里面是空的，刚才是不是有三条一消费掉了以后是不是就没有了，那么现在呢，我们来再来看看我们的队列。干嘛？杨哥故意把它delete了好吗？那么现在就是干干净净的，什么意思啊？回到我们刚才正确的代码，那么弟兄们都懂的，我如果这是持久化。标三条出去，在这儿队列多少数字啊，是不是3030没问题吧，在这对于message这你懂的，是不是应该有三条，那么现在哈，兄弟们，我们来再来一次。再给大家演示一下，然后干嘛我干坏事，我故意把它改成非持久化的，那么同学们请来看一下最后我们的效果，那么来同学们先操作正常的哈，队列又杠了三条，那么在这是不是3030，那么回答我在这一刷新是不是有三条没错吧？好了，那么接下来兄弟们，我们呢，队列消费。

走人，今天BC3条打出来，兄弟们在这儿是不是0133没错吧？那么再来兄弟们一刷新消费完了没有，那么一切符合我们的逻辑和我们的笔记，那么这个时候干嘛进来三条消费完了收工。这个是persistence的，且一旦被消费就从broker删除，那么言下之意，同步嘛，MQ没了，数据库里面也没了，好，MQ是主的MYCQ只是我的持久化方案的一种备份选择机制，那接下来哈，兄弟们，那杨哥干坏事了啊。来吧。我把它干成这个东东。那。那么注意同学们，我们现在。跑到这儿再生产。过去是非持久的啊，大家看Q3063好说非持久的话干嘛只要MQ。没有淡季，没有重启，这都是好说，因为这个我们之前讲过，不再废话了哈，它是非持久的，那么现在呢，是淡消费呢？三条好兄弟们。

老姨，我刷我刷，我刷刷刷。对于我们的message这张表有没有根本就没有进来听懂，那么这个时候的话呢，也就说需要我们把它设置，为什么设置为持久化的，所以说我们在这儿，在笔记上我们在这儿是吧，是不是啊，最好是一定要开启我们的持久化，只要你要干这个事，那么队列还有脱皮口都这么干，那么。又回到我们以前的假设，我们消费呢，那么同学们，我一跑。出来了吧，那么对于我们MQ而言，你看0166都正常的，那么对于我们的MYSQL数据库而言，那么也就是什么非持久化的东西，他刚才呢，你要这么做设置，我就没有给你记录好，那么这是我们单场演示的效果那么好，要注意哈，那么这我们一般是用持久化好，那么队列我们呢，就先给大家介绍到这儿，那么接下来脱皮口呢。

那么点到点，那么发布订阅，那么我们来看看，对于我们的队列，我们动的是这张表message，那么对于我们的topic皮口，我们要会动哪张表呢？那么来老规矩，脱皮口的生产和消费代码走起来，由于前面都写过，我就直接粘了，那么来同学们这些，因为肯定不是到这儿的重点了，对吧？那么一样也是干我们的什么持久化，那么由于消费者和生产者的队列我们讲过，现在呢，这个是带持久化GDBC的，那么主题叫脱皮口GDBC这么一个东东，那么为了保证效果，我们呢，不让它干嘛？出错100%的好13661616，那么好兄弟们，那么这个呢，都见过了哈，下次看ID是不是艾特硅谷零街这么一个人对吧？那么然后它定义的是MQ跟GDBC的这么一个remark对不对？Topic皮那么来吧，主题那么发布订阅那么start等等，好，我们讲过干嘛？对于topic皮口是不是一定要先启动消费者就是有订阅才能有推送，否则没有订阅你去推送就是费消息，强调过很多遍了对吧？那么来兄弟们我这一刷。

咋地脱皮口过来？那么言下之际，那么跟我们有关系的，哎哟，这些什么A开头的看着烦哈，那么这些呢，我们不多废话，那么来同学们这个时候把它删掉，有一个消费者已经在这监听了，那么消息还没有推送，那么来兄弟们在这大家看一下at硅谷零线MQ跟GDBC的，你看这是不是已经开始订阅着激活着持久化的脱皮口的？订阅者有了，那么接下来我们干嘛来看一眼。那么。Topic皮口的话是一定先启动消费者，再运行生产者，然后他是哪张表动AC，那么好，不妨我们在这儿先看看A有没有过来，是不是已经有一个订阅者艾特硅谷零一这个人他订阅了什么，我们的一个脱皮口叫这么的一个主题名字啊，那么他的子名字叫MQJDBC，那么沿下支线对应着来同学们。

我们的topic口的名字是不是叫这货，然后的话呢，谁定的啊，硅谷邻居这个用户，他他这边的子备注和子主题叫什么，是不是叫MQGDBC这样的一篇技术文章，好的，那么同学们我们在这儿啊。易刷新以后一运行。巴啦，那么大家请看，那么生产者搞定，那么今天的这个人呢，是不是123456，为啥我这是不是发了六条啊，听懂哎，那么生产六条消息呢，就给MQ了，那么我们这边MQ先来看咋地。一个消费者进来了六条，消费了六条MQ侧成功，那么我们的发布订阅侧，那么干嘛时间到了人家就离线了，那么进整了六条，OK，那么到我们买CQ呢？那么这个时候我们同学们，我们刷新一下还在不在在因为这个订阅者就是我们的一个，那么再来看看它的一些变化，那么到这。

来这六条，因为他要记录消息，听懂了吗？买色条，那么也就是说你发过的。这六条消息我在这儿都给你存着底单，注意现在变成什么脱皮考，那么所以说ACK我们呢，是记录了，就会记录这个什么我们的。队列的名字啊，我们这个client ID订阅者，但是的message就会进记录，干嘛你topic主题这一波订阅发布的这篇这六篇文章，所以说大家搂一眼，我们呢，先启动消费者，再启动订阅者看看那么再看看ACK的变化，那么大家看ACK跑到这这一步能跟上，那么切记啊，我们在这儿message这强调过什么，确实表明为这个它是队列和topic皮口都存在里面，听不听得懂，只不过我们的队列消费掉就没了，但是topic皮口我可是给你小本本汽车站的那上硅谷的微信公众号，从建号到现在发过哪些文章，你说查不查得到，那肯定嘛，那么所以说有哪些订阅者，我们发布过一些什么，我们都能搞定，那么真是有什么问题了，我们按照message ID再去给他去恢复，在这都写着message内容，那么这个时候是不是也是对我们MQ持久化高可用技术的一种保障和形成手段。OK，那么。

同学们一定要注意，这就是我们的两种什么队列，脱皮口，在MQ和MYCQ上面推送消息，达到高可用和持久化的机制和方案的全部配置编码和细节操作。那么所以说最终你看啊，你架构图好画不就这么个回事吗？你画的再漂亮又怎么样？一步一步的步骤，你能不能跑通，你不能成功，能不能把里面那些坎。避免这儿还没讲呢，听懂，那么所以说待会儿我们来看看我们的小总结，好，那么对于代码验证队列MQ。代码验证脱皮口MQ到数据库的，那么就给大家全部讲完，介绍到这。