Zookeeper是什么?
ZooKeeper是一个分布式的,开源的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。其主要满足CAP原理中的CP(及一致性和分区容错性)原理。
Zookeeper从设计模式角度来理解:是一个基于观察者模式设计的分布式服务管理框架,它负责存储和管理大家都关心的数据,然后接受观察者的注册,一旦这些数据的状态发生变化,Zookeeper就将负责通知已经在Zookeeper上注册的那些观察者做出相应的反应。
Zookeeper=文件系统+通知机制
Zookeeper主要作用为协调。
zookeeper的算法了解
Paxos算法
paxos-made-easy学习资料
目的:通过算法,让参与分布式处理的每个参与者逐步达成一致意见。
大致可以理解为,一个提议者、一个接受者身份。提议者向接受者发出"提议",同时带上自己的权重;接受者在接受到提议时,检测下之前是否已接受提议,如果有提议,比较权重,将权重大的留下并记录,反之则驳回。这里有一个少数服从多数的理论,比如:有三个接受者,其中已经有两个接受了a提议者的提议,此时再收到b提议者的提议时,即是b的权重更大,b在接受到接受者的反馈,也会将自身的提议改成a的提议。
从上面的理解其实就可以看出很多方面的疑问:少数服从多数是否会造成重要信息的遗失?如果提议者提交的顺序不同是否会影响最终一致性的数据?(真让人头秃。。。)
这边笔记只是对算法初步了解了下。更详细的理论,还有完美的数学推理有兴趣的可以看下paxos-made-easy这个github上的项目,学习下。(后面有时间我也要再去全面学些下)
Zookeeper特性
Zookeeper:一个领导者(Leader),多个跟随者(Follower)组成的集群。
集群中只要有半数以上节点存活,Zookeeper集群就能正常服务
全局数据一致性:每个server保存一份相同的数据副本,Client无论连接到哪个Server,数据都是一致的。
更新请求顺序进行,来自同一个Client的更新请求按其发送顺序依次执行。
数据更新原子性,依次数据更新要么成功,要么失败
实时性,在一定时间范围内,Client能读到最新数据。
Zookeeper数据模型
zookeeper的数据节点可以视为树状结构(或目录),树中的各节点被称为ZNode。每一个ZNode默认存储1MB的数据,每个ZNode都可以通过其路径唯一标识。
ZNode结构
节点数据:即znode data的关系就像是java map中的关系
节点的子节点children
节点的状态stat:用来描述当前节点的创建、修改记录,包括cZxid、ctime等
Zookeeper安装与部署
注意:需要提前安装java8,我所安装的zookeeper版本为3.6.1,必须在jdk8以上的环境。
注意这里的clientPort=2181指zookeeper的端口为2181
通过zookeeper bin目录下的bzkServer.sh脚步启动zookeeper
jps命令——查看java进程,并显示类名。这是jvm自带的命令
注意这里我们的zookeeper部署的是单机版
通过zkCli.sh 脚本进入zookeeper客户端,这里可以查看zookeeper的存储数据。就像mysql自带的工具一样。
这里我们查看下zk里面的数据。注意:如上面的zookeeper数据结构所说,zk是以文件目录存储和辨识数据的。所以命令后面必须以/开头。
至此一个简单的单机版zk好了,如果是集群的话只要修改zoo.cfg文件配下就行
使用zookeeper做服务注册中心
这里我们实际用下,zk大多是用在大数据方面,微服务方面多用来取代euraka做服务注册中心。
添加zookeeper 依赖和配置(注意我这里的spring-cloud版本是Hoxton.SR1)
pom.xml
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
</dependency>
application.yml
spring:
application:
name: cloud-payment-service
cloud:
zookeeper:
connect-string: *.*.*.*:2181
搞一个简单的zkController
@RestController
@RequestMapping("/pay")
public class PaymentController {
@Value("${server.port}")
private String serverPort;
@RequestMapping("/zk")
public String paymentZK() {
return "springcloud with zookeeper: " + serverPort + "\t" + UUID.randomUUID().toString();
}
}
看下运行结果
我们看下zk里面的数据有没有
当然这只是简单的应用!
参考资料:
https://www.bilibili.com/video/BV1M741137qY?from=search&seid=882517582830375081
https://zhuanlan.zhihu.com/p/62526102
个人经历感叹:
上上篇笔记还信誓旦旦的说要一周搞一遍笔记,然后我就被外包了。。。嗯,做了人力外包的人力外包,我擦!!!虽然都在南京,但光上班的路程就等赶一个多小时,每天8点半到晚上8点,星期六强制加班,内网环境百度都不让用;外派的公司是组的场地,4个人挤在一个小房间,没有空调,每天得喝4L水,天天大汗淋漓。。。我确实有些顶不住了,6月1号辞职了,老板打感情,我给顶到8月份了,8月10号交接完,走人。周围有很多人劝我说应该找好下家再找工作,确实,我也觉得应该这样搞,但没办法,通过同事私密了解,回去后估计得继续外包。。。算了算了,好好准备准备换家出卖肉体。
2020-8-13 这几天面了华为od,我给广大程序员盆友丢脸了。过了机考,心理测试没过。。。这他妈完全没想到,估计最近心里压力有些大。