62_Replicated LevelDB集群故障迁移和验证

好，同学们，那么上一讲，我们已经成功搭建完了我们的这个。呃，集群，那么现在那么大家呢，都应该呢，可以看到是吧，我们的零号机。这个select这不为空，它是什么主机，那么就是我们的63631，那么三幺这台机器按照我们的集群规划什么意思啊，那么是不是就是你看哈，我们这是不是63631按照我们的集群规划，是不是就是我们的组keep的话是2191，那么言下之见，那么再来。一号机器这是那那么再来二号机器这儿也是，那没有被选中，那么注意，我们这要开始进行集群的可用性测试啊，那么来吧，兄弟们，MQ的客户端只能访问master的broker，其他处于silver的broker不能访问。所以客户端连接的卡应该使用flavor over故障迁移，那么这这个是什么东东？待会说，至少同学们先给我整明白，现在说明什么client能访问谁只能访问master，听懂了吧，那么哪个是master？那么根据刚才我们的讲解，我们现在呢就要来判断。

你们干嘛呢，来？现在呢，我们的这个MQ来吧，同学们，那么杠EF竖线group active。MQ，竖线grape-v grape，那么大家请看。一。二。三那么好，那么言下之意，哪一台呢？List of-I，那么首先8161兄弟们有没有有六二有没有没有六三，有没有没有说明什么能访问监听的只有在8993这个线程里面的是吗？8161这个端口能访问，那么大家请看。这个是不是。Home，大家看这个是不是叫ZZYYMQ，你没改的时候，这个地是不是就叫什么呢？Local host，那么现在看8161能不能访问来，那么大家看我现在刷新六二能不能访问不能，那么请看，再来看，请问六三能不能访问不能，为什么？因为根据官网的要求，我们只认一个master，听懂这两个只是数据上跟我同步，乖乖的别跟我抢，主角是master master只有他好了，那么这个呢，玩活，那么接下来我们就要怎么做测试呢？怎么来保证它高可用，就说白了，死了一个，另外一个能不能活，那么接下来请看。

当一个节点挂掉，或者一个zoo keepper节点挂掉了，MQ服务依然正常运转，如果仅剩一个的时候，由于不能选master，所以不能听到。那么言下之意所说为什么至少要三个法定节点吗？好，同样的，如果keepper节点也仅剩一个节点的活动，那不管这个也不能提供，好吧，他们这种集群加集群都是三台以上哈，那么接下来我们要干什么事呢？干掉一个FTMQ节点，它会自动切换到另外一个活着的能跟上，那么接下来我们先说代码，先说正常情况，那么我们的代码的正常情况，注意生产者和消费者都要改。

那么来吧，现在就不再像以前那样喽，又复杂了，兄弟们。来这一块我们拿队列来作为测试。那么。老爷。这一块我们拿队列来进行测试搂眼，那么兄弟们，我们要干一些什么事呢？来吧，我们的生产者现在就是要故障迁移，往集群里面写了，以前是一台单台，现在是61616。617618没问题吧，那么现在就跟我们以前配的161718是不是都干过，说明是不是三个TCP都OK，那么现在那么队列的集群，那么其他的通通不。说话，那么这我们就集群的消息哈，那么假设兄弟们现在至少我们master这ZYYMQ对吧，我们配的你看队列里面现在是不是没有，我们先检测一下正常情况，那么可能第一次稍微有点慢啊，那么由于是集群了，来请看。

后台是不是都不一样啊，For那个提示successfully，那么这个是不是世界上最美丽的单词啊，对程序员而言，连接到了111.1366116端口那么好，那么这个时候兄弟们我们一刷新，大家看是不是三条3030没问题吧，说明集群环境的配置成功代码。验证成功那么好，别着急，兄弟们，那么消费端呢，那么来。有没有收到你看集群的message，你们一看，我们从这拿到了，那么老规矩你懂得，是不是零零散散OK，一切和谐，像大自然一样自然欧啦，那么这块打完收工，正常情况下演示通过，正常使用集群OK啦，那么接下来兄弟们，杨哥要干坏事了，要干掉一台activity节连，那么言下之际，我们就立死我府一号。三台机器中MQ只会有一个MQ可以被客户端连接使用，现在正常情况讲过了，8161是正常的，干嘛八二啊，不不8162163，我们两个等着他死了，他们两个是不是二选一一个谁选出来谁上位，那么在测试的时候我们就要把master关掉，然后在重试客户端消费，看还可不可以说明集群搭建正常，那么好兄弟们，那么这个时候我们干什么呢？我们选一下，那么上一次我的。

备课的时候的案例是选出了8163，那么这次以后，那么兄弟们，我们看了，我们是几啊？是不是8161对应的PID是谁？8993，那么我现在干一件烂事，那么T要干九。八。993把他干死，听懂了吧，那么这个时候你懂的，也就是说我把这个进程编号一刷，那么相当于我们的8161，这个是不是就会淡机啊，那么好，那么这个时候看同学们三台机器我也会撤。好，这个进程灭了，那么这个时候你看我们的8161就死了，这个时候我1.home。啥情况？这哥们是不是就挂了？那么来吧兄弟们，那么等他慢慢组keep，后面的学会选出来谁呢？刷新一下，那么。

In的in我登录，那么这边呢，我也刷新一下哟，都不用说，那么是不是选出来了我们的另外一台机器8163这台机器啦，那么。来吧，哦，选出来我们的什么8162这台机器，OK，那么这个时候不管它，那么我们的，你看现在故障迁移了以后这哥们死了，现在反而他是不是就挂了，那么好，那么我们回到我们的zoo keepper去看看，那么兄弟们我们的zoo keepper哈，那么假设我们现在get，那么以前是零号机器，它是你看现在这个节点没了，我是不是干掉了，那么一号机器，大家看一号机器选出来了，它是多少？是不是63632，那么再来我们再看二号机器现在有没有是那那么是不是只有两台机器选从二选里面选出的这哥们是新的，那么杨哥我们代码没动是吧？你看上一次是谁，我们那是我们假设这个是我们的什么东东，我们的consumer的这个是。

嗯，61616对吧，那么现在么，兄弟们，我们的队列OK，我们再来他一次，你看上一次是61616，这次我们故障迁移，再试试二我们又发消息了。怎么样，是不是变成61617了，消息发送完成，那么在这块我们点一下队列，3030是不是又进来了，那么来同学们，我们来看看我们的消费，那么一样我们来跑是不是又变成。接收到了集群的消息，是61617啊，OK，那么至此我们呢，一套带走，打完收工，那么切记这个代码要带故障迁移的，支持TCP协议的多节点集群部署。那么你看看我们的MQ，没那么容易，没那么简单，真不是跟面试官说一个什么哎呦解O，哎呦异步，哎呦cell phone，然后你就会一言不合，如K加可复制功能的level dp store主从集群，你说说怎么配的？

你说你不跟着杨哥把这些深层次的知识学会，来一个面试官分分钟问的，你别说回答人家问你的问题，你都听不懂人家问的是什么。OK，那么一样举一反三，有没有可能这个第二换成是吗？Rocket m rabbit和卡夫卡呢，也要做这样对应的主通集群，听懂了吧？那么所以说如何保证高可用，现在听懂了吧，那么当场演示干死了他一个，是不是当场也演示了集群的什么故障迁移啊等等，好，那么这个就是我们的主通复制ZK加replic的level DB。我们就给大家介绍到这儿。