52_ActiveMQ消息持久化机制之JDBC配置mysql-上

来，同学们，接下来我们给大家介绍我们的GDBC消息存储这样的方式。好。不多说，只要有GDBC，那么必然是不是要牵扯到我们的数据库啊？那么同学们思考一下。就是我还没有讲，你们觉得我们这些步骤应该有哪一些。非常不错哈，有几位同学呢，很有灵气，呃，比方说他说的，既然有数据库，那么需要建表，很好，非常不错，因为很简单嘛，我们以前只是把消息推送到我们的这个active MQ的这个。服务器上面，那么现在是什么？一发送了以后对应着MQ上。会，原来有的该该，原来该有的肯定要该该有，对吧，不会少另外一个是不是部分消息也会在数据库里面，那么同理，数据库上面是不是需要先见表见库啊，对吧？至少有一些约定俗成的一些表来保存我们的消息，非常不错哈，那两位同学能够回答出这样的呃，本质的问题，那么这就是我说的，你看不是让大家呢，干嘛天天记这个答案，背好，同学们照着操作手册把这个操作成功了一遍，我现在什么都没讲。

那么需要要求同学们去猜。因为有些时候技术就是靠联想，就是靠设想，诶那假设我现在来设计这个东西呢，给的课题叫MQ，保存消息到JDBC，说穿了就是保存到我们的MYSQL数据库里面，那么我就是还没讲没打开那哪些步骤。好，那么第二个，那么同学们。我们呢，来看一眼官网上对于我们的这个东东有哪些建议和描述，描述，那么来吧，同学们。完了以后这是不是有个GDP的持久化，那么without journey，那么这个是个什么东西，我们。干嘛呢？在这再跟大家聊，现在大家就只认一个东西叫GDBC持久化。好，那么呢，我们开始第一个。

二话不废话。那么。生产MQ消费者这是不是有个持久化方案？只不过我们现在持久化方案干嘛从可汗DB过渡到了我们的什么MYSQL数据库很好，那么这边呢？理论知识不废话。开打第二步，由于我们要从MQ。自动传输同步消息到我们的MYSQL数据库，那言下之意是我们是不是需要添加MYSQL数据库的驱动包到我们的什么内部文件夹？这一步能跟上，那么所以说同学们，我们要干些什么事呢？那言下之意啊，同学们请看一下，我首先呢。找到我们的这个路径下面是不是有个立文件夹，第一次介绍active MQ安装的时候。我介绍了粗略的给大家介绍了一下各个文件夹的是吗？这个使用情况，那这个时候跟大家讲过。

命令配置文件activity MQ消息存放的一些数据，Docker是文档，例子，案例，Case case这个利是不是就是第三方架包？那么言下支线兄弟们，我们干嘛呢？跑到我们的OPT下面，那么这个时候同学们请看一眼哈，我们这就有一个my SQL connect Java的五点幺点三八点这么一个架包，这么说能理解，那么言下之意就是说我们现在需要买CMQ跟买CQ。大勾搭上，就好比以前是Java跟MYSQ勾搭上，我们要填GDBC的驱动包，那么现在是MQ跟MYCQ勾搭上，也一样要填驱动包，所以说我们要做的事就把这个夹包拷贝到我们的内部的文件夹下面，那么命令也很简夹，那么杨哥刚才下课的时候呢，就已经给大家呢拷贝好了，那么这个时候我们看一下。那么。Copy这个命令不用我执行了吧，太简单了，OK，我节约时间，My active MQ阿帕奇这个那么干嘛呢？立下面，那么大家看一下我们这儿是不是完成了第二步。

把。买的夹包已经拷贝到当前的消息中间件的内部文件夹下，OK，那么驱动先不要有问题，好，这是我们的。第二步，那么第三步呢，做GDBC持久化的配置，那这是什么意思呢？那兄弟们大家都知道，根据杨哥刚才的讲解，我们都清楚，在我们的看目录下面是不是有我们的active active mq.XL配置文件，是不是这个东东，OK，那么这个东东兄弟们都清楚，这个里面是不是就记录了我们的消息中间间的配置啊，那么来。过来。大家都清楚，我们来找找找找找，那么现在干嘛呢？好，为了给同学们好看好说哈，我们先显示个行号，在我们的第81行到83行之间，那么杨哥讲过干嘛？

默认的出厂的时候是不是我们现在即便是5.15.9，那么我们用的是可看DB，那么现在我们要用的是什么东东，是不是要用我们的GDBC的持久化。那么言下之际，那么大家。可以看一下，根据我们的官网上的建议和要求，那么是不是要把它从GDP从可看DP换成我们一个新的GDBC的持久化适配啊，那么这步怎么操作呢过来。在当前这个下面，按照下面这么做，修改前是可看DB，也就是说当前默认的这一步OK，那么修改以后我们就会变成这么一个东东，我们先把它粘出来。好，那么来同学们这个时候的话呢。

我们可以看到，我们就把这一步呢，从可看DB好我们对比一下哈，这样的话呢，可能让同学们看着好看一点，这些配置呢，非常重要哈，那么千万不能配错，那么最好能一次性成功，那么这个是出厂默认配置啊，没问题吧，从可看DB换成什么GDBC持久化的适配器，那么呢，目落。原以前是不是以文件数据库，现在是不是要引用一个是吗？MySQL DS MySQL data source数据源，这么说能理解同学们没问题吧？那么这是我们的第一步，第二个，那么在这儿我们来看一眼，现在呢？红红色部分就是我们今天要修改的，我这儿。给大家说了一点说明，Data source是指定将要引用的，那么也就是说这个叫引用符，类似于我们什么spring里面，如果一个病里面包含另外一个病，在配置里面是不是有个东西叫RGF叫瑞，只不过在MQ里面不叫瑞了，叫井号。

说明在本次配置这个文件里面，下面会有一个叫MYSQLDSMYSQL数据源的这么一个，并配置一个病一样的配置，也说白了也就是对XM的配置啊，然后呢，在这用井号引用，这一步能跟上好下一步create tables on startup，那么这个呢，干什么呢？同学们请听我来说。来。相当于啊，我们现在呢，要从默认的可看DB换成我们的GDBC答案那么改了以后呢，要常用的要有两个参数，其实你用这个也行哈，我们干嘛呢？这个多source data source是数据源，刚才讲过了，以井号开始引用下面一个叫MYDS的一个东东，那么这还可以加这么一个东西叫。Create table on startup，那么这个时候什么意思呢？同学们，它是这样的，默认只是错，也就说你不写，那么这就是错，什么概什么意思啊，就是说你一运行这个东东，买MQ，一开始就会去创建一张表，刚才不是有同学在思考的时候说过，说老师我们要把MQ的消息保存进我们的MYSQL数据库，MYSQL数据库上面是不是要建表啊，那么一样同学们能想到，那么阿帕奇肯定也想到了，所以说它默认就有这么一个参数，设为处代表你启动MQ就给你新建一套表，注意不是一张是一套。

来保存MQ到MYCQ的消息，那么如果说你不想让它每次重启都要重建，那么你就把它设置成false，那么一般我们首次使用错，然后我们再把它改成false，这一步能跟上，那么这老师做教学演示图简单，因为我很少会去重启我的MQ，那么这我就没有加这个参数啊，待会儿我们就直接粘这么一段哈，这些千万不要去手写听懂。好，那么过来，那么怎么改呢？就把原来的可看DB兄弟们，咱们把它注释掉，然后加上我们的这段配置即可，好，这是我们的第三步，一步一步来哈，跟着杨哥细细认认真真的搞定，不要怕那么胆大心细，好吧，那么这个时候呢，我们把什么呢？

这个默认的哈。全部拿掉，那么这个时候亲各位亲，那么大家搂他一眼，我们这个时候呢。一张贴。那么大家。看一下。还是跟官网的对齐哈，那么我这儿是不是就完成了我们的这的什么第三步，实现了GDBC的配置啊，那么当然讲过了啊，这儿有个什么create的这么一个create table的这么一个属性，你想加那么你就加，但是第一次啊是错，第二次要设成false，那么这儿呢，不是重点，也有点繁琐，我呢这儿就没写好吧，那你要想写的话呢，你把它写上没问题，不写相当于这个后面就是一个create tables on start等于错哈，每次呢就会重建表好，那么你要加了以后，第一次是初二，那么成功了以后就要进来再把它改成负好么？这个是我们的什么呢？

第三步，那么接下来同学们请看我们的第四步，那么第四步是干什么呢？来，兄弟们。这是不是有个东东叫数据库的引用啊，那么换句话说，我这有个data source，你引用什么，我引用一个MYSQ减号DS这么一个名字啊，那说穿了，我这是不是应叫就应该提供一个数据源叫MYSQDS啊，那我得给他有啊，那么言下支线这个呢，就是我们自己的。过来。那么这个时候同学们。我们的第四步哈，那么大家请看这杨哥写了，那么这个时候你看这是不是叫MY色QDS啊，这一步能理解了吧，上面问上面是不是就有一个井号MYCQDS啊，说白了也就说GDBC的持久化配置啊，我就要引用一个数据源，那么很简单吧，起码你得告诉我你这个数据库是MYCQ还是Oracle数据库的服务器地址在哪，用户名是什么，密码是什么，所以说在这我们呢，直接把这段一粘就OK，那么切记。

自己的数据库用户名，自己的数据库密码，那杨哥你这段会不会粘错，哪来的你们你们懂的。OK，那么我们跟尽量跟官网一样，什么意思呢？就把这段一张，我也是参考最权威的官网，那么注意官网上的意思就是说让你去连，你看local host对不对，那么你的数据库如果也装在Linux上面，那么就OK，但是杨哥尽量的模拟实战，我们现在呢，一定要实现。MQ服务器和数据库服务器肯定是在生产，当是物理上分开了，应该是两台机器，所以说我这就没有去连我本机的Linux数据库，我去连Windows的数据库，那么言下之意什么是不是MQ服务器是我的Linux，我的MYSQ服务器是我的WINDOWS12个机器听懂模拟，那么第二步呢，来注意。

这个是叫什么？是不是要连的数据库啊，那么说明什么？我们的MYSQL里面是不是要建一个叫active MQ的这么一个数据库，专门存放这些表，这一步听懂。那么第三个细节，由于官网上默认的是用的是DBCP这样的一个数据库连接池啊，那你说那杨哥啊，我们公司用的是C3P0，我们公司用的是阿里巴巴的这个德鲁伊。那么这个时候可不可以呢？完全可以，那么这段代码大家在学spring的时候绝对是见过，但是当你换这个的时候请注意，因为杨哥是严格按照官网来去，这么来给大家进行分享哈，那么如果说你生产上你说老师我要换成这个，呃，C3P0或者德鲁伊，那么在这块听好了。这个驱动包就不只是。连买CQ的了，你有可能你要再加一个是吗？德鲁伊或者C3P0以及对应数据库连接池的架包，那么这儿杨哥这儿是只考了一个架包，那么你有可能要考两个，一个是连买SQL的，一个是跟数据库连接池相关的，OK，那么C3P0是人家默认带着的，哦，不抱歉，DBCP是人家默认带着的，所以说我就只考了一个假包，那么这个细节同学们要了解好，那么接下来我们数据库连接池的配置，那么就是这么一个东东，那么它配在哪啊？

那么首先这啊，红色的自己的听懂了吧，见到你就待会我们要在数据库里面建个库，叫active MQ。干嘛？保存这些表，那么什么呢，自动提交啊什么的这些呢，就不废话，那么同时放在broke标签之外，然后呢，再放在我们的这个import标签里面，就是在这两个标签之间，你给我粘贴，OK，那么在这块的MYSQLDS啊，那么讲过了，就是前面引入的这个东东好。那么接下来我们呢，直接来进行粘贴，那么严格的Windows的机器的IP是11.1，那么这个时候呢，我们呢，将会改改改成什么呢？192.168.111.1，那么我的用户名，那么就是root那么。

密码呢，是我们的123456妥了，那么这个时候同学们，我们将其。复制不要去写哈，不要手写哈，那么到了第四步，那么我们直接回到我们的active MQ，那么干嘛呢？找我们讲过了，你看这个是不是BS啊，那么刚才杨哥讲过了，好，要在这个标签之后，这个标签以前那么好了，那么言下之意我们在这儿。给他。弄进去OK，那么好，现在就是用我们的MQ的服务器，111.136去写到我们的11.1Windows的机器上面啊，自己的用户名和密码，那么这个时候同学们过了。

那么上面要注意。一定一定要加这个井号啊，而且是从可汉DB换成了我们GDBC，这个好，那么这个就是我们的什么第四步完活好，那么接下来第五步，那么这个呢，开始呢，慢慢的从MQ过渡到了我们的MYCQ，那么害怕大家呢，学习负担过重，我先录一集。