ZooKeeper 笔记(4) 实战应用之【消除单点故障】
关键节点的单点故障(Single Point of Failure)在大型的架构中,往往是致命的。比如:SOA架构中,服务注册中心(Server Register)统一调度所有服务,如果这个节点挂了,基本上整个SOA架构也就崩溃了,另外hadoop 1.x/2.x中的namenode节点,这是hdfs的核心节点,如果namenode宕掉,hdfs也就废了。ZooKeeper的出现,很好的解决了这一难题,其核心原理如下:
1. 关键节点的运行实例(或服务器),可以跑多个,这些实例中的数据完全是相同的(即:对等设计),每个实例启动后,向ZK注册一个临时顺序节点,比如 /core-servers/server0000001, /core-servers/server0000002 ... ,最后的顺序号是由ZK自动递增的
2. 其它应用需要访问1中的核心服务器里,可以事先约定好,从ZK的这些临时节点中,挑选一个序号最小的节点,做为主服务器(即master)
3. 当master宕掉时,超过一定的时间阈值,临时节点将由ZK自动删除,这样原来序列最小的节点也就没了,客户端应用按2中的约定找最小节点的服务器时,自动会找到原来次最小的节点,继续充为master(老大挂了,老二顶上),即实现了故障转换。如果原来出问题的master恢复了,重新加入ZK,由于顺序号是一直递增,重新加入后,它将做为备胎待命。
示例代码如下:
上面是类图,CoreServer类对应核心服务器,ClientServer类对应客户端应用服务器,SPOFTest为单元测试类
CoreServer代码:
package yjmyzz.test;
import org.I0Itec.zkclient.ZkClient;
public class CoreServer {
private String hostName;
public CoreServer(String hostName) {
this.hostName = hostName;
}
public void start() {
ZkClient zk = ZKUtil.getZkClient();
if (!zk.exists(ZKUtil.CORE_SERVER_NODE_NAME)){
zk.createPersistent(ZKUtil.CORE_SERVER_NODE_NAME);
}
zk.createEphemeralSequential(ZKUtil.CORE_SERVER_NODE_NAME + "/server", hostName);
System.out.println(hostName + " is running...");
}
public String getHostName() {
return hostName;
}
}
ClientServer类:
package yjmyzz.test;
import org.I0Itec.zkclient.ZkClient;
import java.util.Arrays;
import java.util.List;
/**
* Created by jimmy on 15/6/28.
*/
public class ClientServer {
private String getCoreServer() {
ZkClient zk = ZKUtil.getZkClient();
List<String> servers = ZKUtil.getZkClient().getChildren(ZKUtil.CORE_SERVER_NODE_NAME);
if (servers.size() <= 0) {
return null;
}
for (String s : servers) {
System.out.println(s);
}
Object[] arr = servers.toArray();
Arrays.sort(arr);
String data = zk.readData(ZKUtil.CORE_SERVER_NODE_NAME + "/" + arr[0].toString());
System.out.println("node:" + arr[0].toString() + ", data:" + data);
return data;
}
public void run(){
System.out.println("客户端应用运行中,正在调用:" + getCoreServer() + " 上的服务");
}
}
SPOF测试类:
package yjmyzz.test;
import org.junit.Test;
import java.util.concurrent.TimeUnit;
/**
* Created by jimmy on 15/6/28.
*/
public class SPOFTest {
@Test
public void startCoreServer1() throws InterruptedException {
CoreServer server1 = new CoreServer("server1");
server1.start();
while (true) {
TimeUnit.SECONDS.sleep(5);
}
}
@Test
public void startCoreServer2() throws InterruptedException {
CoreServer server2 = new CoreServer("server2");
server2.start();
while (true) {
TimeUnit.SECONDS.sleep(5);
}
}
@Test
public void testSPOF() throws InterruptedException {
ClientServer clientServer = new ClientServer();
clientServer.run();
//此时,手动停止coreServer1
TimeUnit.SECONDS.sleep(60);
//再次运行
clientServer.run();
}
}
测试步骤:
1. 先启用startCoreServer1()、startCoreServer2() 由于这二个方法中,最后用死循环阻止了程序退出,所以这二台server会一直运行下去,除非手动kill 进程
2. 再启用testSPOF(),在45行这里可以打个断点,进入断点时,可以手动把startCoreServer1()对应的进程kill掉,即:模拟server1挂掉,然后继续执行,观察输出。
运行结果:
zookeeper state changed (SyncConnected) server0000000007 server0000000006 node:server0000000006, data:server1 客户端应用运行中,正在调用:server1 上的服务 ... zookeeper state changed (SyncConnected) server0000000007 Disconnected from the target VM, address: '127.0.0.1:64788', transport: 'socket' node:server0000000007, data:server2 客户端应用运行中,正在调用:server2 上的服务
-------------
从测试结果看,客户端访问的核心服务器,自动从server1切换到了server2上。
- RxJS速成
- 会HTML/CSS就可以轻松创建网站
- 区块链银行应用探索(Hyperledger fabric)
- mysql之基本语法
- mysql之索引的工作机制
- Mysql之锁与事务
- 独家 | 教你实现数据集多维可视化(附代码)
- NoSQL | Redis、Memcache、MongoDB特点、区别以及应用场景
- cf--------(div1)1A. Theatre Square
- 离线网页制作器(beta1.0)
- uva---(11549)CALCULATOR CONUNDRUM
- CF---(452)A. Eevee
- MySQL排序内部原理探秘
- Uva----------(11078)Open Credit System
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 蓝桥杯-基础练习 数列排序
- 无线网络-何为ISM频段?
- 蓝桥杯vip测试题系统试题-算法提高 矩阵转置
- 蓝桥杯vip测试题系统-数组求和(解题思路以及解题代码,手画思路图虽然丑丑的)
- 蓝桥杯vip测试题-找零钱(解题思路以及解题代码)
- 剑指Office-二进制中1的个数
- 剑指Office-旋转数组的最小数
- Mysql调优你不知道这几点,就太可惜了
- Mysql快速导入数百万条数据,亲测有效
- [面试题06]从未到头打印链表(LeetCode-剑指Offer)
- SpringBoot集成RabbitMQ-三种模式的实现
- Centos7-Docker卸载旧的更新到新版本
- vue vuecli3 前端解决跨域问题
- 求求你,不要再纠结指针了(1) ——万能转化公式
- 求求你,不要再纠结指针了(2)——函数指针