53_ActiveMQ消息持久化机制之JDBC配置mysql-中

来，同学们，我们继续那前四步，从理论到MQ的配置基本上暂告一段落，那接下来我们来慢慢的来到第五步，那么。MQ的完了，那么我们现在是不是MQ到MYSQLMQ的配完了，那么接下来要聊聊数据库了。好，那么。第一个SQL建仓和建表，那言下之意呢，那不多说别的哈，同学们就说刚才这个我们这儿是不是要需要你通过买SQL的DBCP的连接池，连接到我们的MYSQL数据库。IP端口号，注意，这有个东西叫什么active MQ的数据库，没错吧。所以说第一步。需要大家连上MYSQL以后干嘛呢？建一个名为active MQ的数据库，好，那么当然啊，同学们。这块是他官网推荐叫X5MQ，那你能不能改，你假的假设你要把它改成abcd行不行，完全可以哈，怎么配怎么改那。

过来，那么这个建数据库的q create database active MQ，那不用我多废话是吧，一执行了以后，在这一刷新，那么在你的买QL数据库，这就会有一个active MQ的这么一个数据库，这是第一点，那么第二点，那么建完数据库以后。同学们，那么干什么呢？你一更新，所谓的一更新就是你的MYSQL服务器一重启，那么将会在你的MYSQL的active MQ的这个数据库下面会有三张表。这需要和大家唠唠。那么前面我。停止录屏课堂提问的时候，我问大家说那么你们觉得MYSQL要做什么配置？那同学说的很好哈，就是说你要把MQ的消息同步给MYSQL，那么自然而然MYSQL是不是要先要有库，有表，库有没有有了叫active MQ，那么表呢？哪些表要放什么？该有哪些表该放些什么？那么这个时候来默认官网给我们设置了三张表，叫active MQ messages a和look，那么一看这个名词，消息签收还有什么锁定，OK，那么主要是这两张表，那么我们简简单单的来给大家呢，痛痛快快快的做一下。

深度的讲解，那么言下之意什么概念哈，那么这三张表怎么来的？大家还记不记得我们这儿是不是有一个叫create table of start，我讲过了，我们配的时候我们这没写，也就相当于默认这有个错，也就是说你到时候待会我把active MQ服务器把配置文件改完了，这么一重启，如果一切顺利，你的驱动你的。数据库都OK的话，连着套。啊，再次强调啊，连得通哈，我讲过了哈，要Windows和Linux互访两台机器，这个网络拼通没问题哈，那么联通的前提下，那么在这儿刷就会自动的生成三张表，那么这三张表干嘛？如果新建数据库OK了，上面的NMQ也OK了，代码运行也OK，那么三张表会自动生成，听懂那么好，那么我们来看看这三张表，首先MSGS啊，啥意思呢？那么它的字段是有这些ID。

Container，你看它是不是叫容器，就是消息的destination，目的地说穿了，这个字段就是存队列还是topic。那么messaged发送消息者的主见那是哪个人发的？有点像发送是吗？这这条短信是哪一个手机号发给。哪一个手机号就跟打电话，主叫号码和被叫号码是谁，那么message队列发送消息的顺序，那么过期时间，Message消息本体Java序列化对象的二进制数据，还有优先级，那么大家搂眼123456，那么常用的就是这个，这个叫消息表，确认表明为这个。

队列和脱皮口都存在里面，它的结构如下，那每一个字段是什么意思啊？在上面都会有详细的解释啊。那么言下之线，待会我们演示，假设我们以队列发了两条消息，三条消息，那么在这张表里面就会有体现。好，那么下面是A。那们过来搂一眼，全部的字段是在这儿，那么主要用于存储什么关系啊？订阅关系，那么如果是持久化的topic皮口订阅者服务器的订阅关系就会保存这个表，那么字段如下。那么由于哪一些呢？分别是容器，那么还是消息的目的地，对吧？那么又是什么？如果是使用网络，有种配置叫静态集群，集群我们后面讲哈，那么会有这个集群的其他信息，如果现在我们是单机版的，那么也就没有就没有了，那么这个就是集群环境，就记住不是就是个空，那么client idea，那么每个订阅者都必须要有个唯一的客户端，那么讲过了，前面是不是有我们讲过什么set client ID那个API啊，有印象吧，我还是不是还写了个什么张三李四啊，然后呢，他们呢，干嘛呢，全部是不是就在我们在这这个订阅者，这还记不记得client ID有张三李四啊对吧？那么再来订阅者的名称等等等等这些，那么好，每一个字段是什么，这都有，好，那么第三张表洛，那么它主要是在什么地方？集群环境中只有一个broker可以获得消息，那么称为是吗？主broker，那么其他的都是备份的，那么主要用于记录这张表用于记录哪一个broker是当前的master，那么你看ID是吗？Broker。

母OK，那么它也是做后面的这个集群主从的时候来做记录的，好，那么同学们这三张表。如果都OK了，我说的OK就是待会儿我们会演示哈，那么现在你看大家看啊，这个这个。库下面是不是表还没有，因为我们配了以后还没有重启，我们MQ还没有给他激活，所以说配完他还不知道，那么假设哈，万一情况应急，我们手动建表circleq，但是强调啊。

由于我们这儿有这么一个默认的配置啊，代表的意思就是什么。网络联通的前提步骤正确，价包都不缺少的前提下，它要自动生成，尽量你不用手动听懂，但是假设应急的情况下，那么我就是缺这几些表，那么杨哥也把这个色给大家整理好，你一张也能够手动建表成功，好那么这个呢，就是我们的什么建仓色和建表说明，那么接下来咱们是不是要建表完成以后来看看我们的代码运行啊好那么接下来那么同学们我们来看一下。干嘛呢？我们改完了，我们MQ了以后，我们现在需要的是不是要把我们的。Active MQ干嘛呢？进行关闭并重启一下，好，那么同学们先把它停了，那么停了以后再次重启，相当于是不是就可以激活我们刚才的那一大堆堆配置啊，好，那么如果一切顺利，我们来看看我们的active MQ能不能启动，那么大家看start，那么这个时候呢，停完了以后，那么稍微要等一会儿时间哈，由于配了这个MYSQL数据库，那么它呢，稍微会有点慢，我们呢，稍微等他一会儿。

好，因为它首次啊，它要需要去连从MQ通过Linux去连我Windows的网络，再需要建库，再需要建表，稍微有点慢，好，那么重启以后，首先我们来看看后能不能反问了，现在OK，那么应该是正常情况下起来了，那么来同学们你看现在这是不是没有表啊，那么这个时候我们一刷新，如果一切顺利，同学们look。没问题吧，这个时候大家看一下我们这是不是有三张a look message3张表啊，那么跟我们刚才的一样，如果说我X。

那么。Active MQ，好，那么原下是message a，我们来看看这三张表，现在那么大家看它的表结构是不是就是刚才我们所介绍的，那么大家漏一眼，现在每一张表结构是什么，它的信息，它的表还没有这个结果，那么它的信息是些什么，我们都OK，好，那么同学们我们来查询一下，那么大家看现在消息没有肯定嘛，没有什么队列，大家看这些呢，通通都没有，但是表结构是不是我们已经成功的建表成功啊。OK，那么言下之意就要激动人心的时刻来了。待会儿我们就要用代码验证我。把队列的消息一发送，那么MQ上面要有一份如果持久化顺利的话，我们的active message。这张表里面是不是也应该记录下来我们发送了一些什么样的东东，那么每一个字段是什么，按照我们的大纲和刚才的笔记，那么大家呢，可以进行查阅和对照，好，那么我们最MQ到MYSQL，那么第二大步算式完成，那么待会儿我们上代码再给大家进行验证。