分布式协同是分布式应用中不可缺少的,通常担任协调者的角色,或者说是将多机协同的职责从分布式应用中独立出来,以减少系统的耦合性和增强扩充性。Apache的Zookeeper, google的Chubby都是分布式协同的实现者。fourinone实际上可以单独当做Zookeeper用,它使用最少的代码实现了Zookeeper的所有功能,并且力图做到功能更强但是使用更简洁。

一、实现原理
fourinone对分布式协同的实现, 是通过建立一个domain,node两层结构的节点信息去完成,domain可以是分类或者包,node可以是具体属性,domain和node都是自己根据需求设计命名,比如可以将domain命名为“a.b.c...”表示一个树型类目。
一个domain下可以有很多个node,每个node只指定一个domain,可以通过domain返回它下面所有的node。
domain不需要单独建立,通常在建立node时,如果不存在domain会自动创建。
如果domain下没有node了,该domain会自动删除。
如果删除domain,该domain下面node也都会删除。
每个node下可以存放一个值,可以是任意对象。
所有的节点信息存放在parkserver里,parkserver提供协同者的功能。如下图所示:

从上图可以看到,其他分布式进程可以通过parkserver的用户接口ParkLocal,对节点进行增加、修改、删除、指定心跳、指定权限等操作,并且结合parkserver提供同步备份、领导者选举、过期时间设置等功能,共同来实现众多分布式协同功能,比如:
1、分布式配置,多个机器的应用公用一个配置信息,并且挂掉能够领导者选举,详细见指南和demo
2、分布式锁,多个机器竞争一个锁,当某个机器释放锁或者挂掉,其他机器可以竞争到锁继续,详细见指南和demo
3、集群管理,集群内机器可以互相感知和领导者选举,详见指南和demo

二、核心API
ParkLocal核心api说明:
//创建node,可以根据是否需要权限和心跳属性调用不同方法
public ObjectBean create(String domain, Serializable obj);//自动创建node
public ObjectBean create(String domain, String node, Serializable obj);
public ObjectBean create(String domain, String node, Serializable obj, AuthPolicy auth);
public ObjectBean create(String domain, String node, Serializable obj, boolean heartbeat);
public ObjectBean create(String domain, String node, Serializable obj, AuthPolicy auth, boolean heartbeat);

//更新node
public ObjectBean update(String domain, String node, Serializable obj);

//获取node
public ObjectBean get(String domain, String node);
//获取最新node,需要传入旧node进行对照
public ObjectBean getLastest(String domain, String node, ObjectBean ob);
//获取最新domain
public List<ObjectBean> get(String domain);
//获取最新domain下所有node,需要传入旧的node集合对照
public List<ObjectBean> getLastest(String domain, List<ObjectBean> oblist);
//删除node
public ObjectBean delete(String domain, String node);
//强行设置domain可删除
public boolean setDeletable(String domain);
//删除domain及下所有node
public List<ObjectBean> delete(String domain);
//添加node的事件监听
public void addLastestListener(String domain, String node, ObjectBean ob, LastestListener liser);
//添加domain的事件监听
public void addLastestListener(String domain, List<ObjectBean> oblist, LastestListener liser);

三、权限机制:
public ObjectBean create(String domain, String node, Serializable obj, AuthPolicy auth);
通过上面方法创建node时,可以指定一个权限参数,有只读(AuthPolicy.OP_READ)、读写(AuthPolicy.OP_READ_WRITE)、所有(AuthPolicy.OP_ALL)三种属性,默认为AuthPolicy.OP_ALL

注意:这里的权限属性是指创建进程对其他使用进程的权限约束,而不包括它自己。也就是对node的创建进程来说,它拥有对该node和domain所有操作权限(读写删,只要它不退出或者中止)

建设现在创建了一个domain为d,node为n的节点, 对于其他使用进程来说,操作权限如下表所示:

从上表可以发现,当创建进程指定node的权限为AuthPolicy.OP_ALL时,其他使用进程可以删除该node,但是不能删除其domain,这是为什么呢?
因为domain下通常还有其他node,它们的权限并不都是AuthPolicy.OP_ALL,比如还有一个n1的node权限为AuthPolicy.OP_READ,按照正常操作,该使用进程无法删除n1,假设它可以删除domain,那么它最后间接删除了n1,于是发生了悖论,因此,为了避免风险,所有的使用进程只能根据权限删除node,但是无法删除domain。

不过你允许承担这样的删除风险,也可以在创建进程里强行指定该domain可删除,通过在domain创建后,调用:
public boolean setDeletable(String domain);
该方法只能被domain的创建进程调用,其他使用进程没有权限调用。
强行指定可删除后,其他进程可以直接删除该domain及所含node并忽略后果。

四、相对于zookeeper的优势
Zookeeper无疑是一款成功的开源产品,并拥有广泛的信任者和应用场景,和以往一样,老外作者在apache网站上发布了一款产品,我们的工程师马上会虚心的学习和忠心的捍卫,而国产原创的产品往往会遭到百般质疑,因为我们的原创更多是抄袭和粗制滥造,我们的国产更多是框架集成而不是架构设计,所以这种情感上的倾向性不是一天能改变。
做产品对比和列举优势往往容易引起激烈争论,会被认为是在宣传和引导产品使用,实际上在都能满足功能需求的情况下,选择使用哪款产品更多的是个政治问题,而不是技术问题,领导意志及工程师本身的熟悉程度和爱好等等都是决定因素。

这里我们仅仅从技术角度阐述几点优势,Zookeeper做为一个chubby和paxos模仿品,缺乏创新型的设计改进,它仍然存在以下缺点:
1、树型配置节点的繁琐复杂,性能低下。为了保证这种结构,Zookeeper需要维持一套虚拟文件结构的开销,对于目录结构深的树节点,造成性能影响,而配置信息结构实际上往往不一定需要树结构。

2、“观察”(watch)机制的僵化设计:zookeeper没有获取最新版本信息的方法支持,它只能粗暴的在每次写入更新等方法时注册一个watch,当这些方法被调用后就回调,它不考虑信息内容是否变化,对于没有使信息内容发生改变的更新,zookeeper仍然会回调,并且zookeeper的回调比较呆板,它只能用一次,如果信息持续变化,必须又重新注册watch。而fourinone的事件处理则可以自由控制是否持续响应信息变化。

3、领导者选举机制实现的太过局限,集群只有两个节点,zookeeper无法进行领导者选举,zookeeper的领导者选举必须要奇数节点的奇怪限制。另外,ZooKeeper的领导者选举实现虽然比原始的Paxos要简化,但是它仍然存在领导者(Leader)、跟随者(Follower)、观察者(observer)、学习者 (Learner)等众多角色和跟随状态(Following)、寻找状态(Looking)、观察状态(Observing)、领导状态 (Leading)等复杂状态。相对于fourinone的领导者选举,zookeeper仍然不够直观简洁,难以用较少配置和代码演示。

4、Windows系统上几乎不支持,需要安装linux壳,并且仅建议用于学习研究。Fourinone支持windows、linux集群混合使用。

Fourinone提出一种新的分布式协同系统设计,在满足zookeeper所有功能下,并克服了以上缺点,提出了新的配置结构、变化事件机制、简化的领导者选举实现,能更好的满足分布式协调需求。

五、演示demo
下面是一个操作节点的演示demo,请留意各自节点的权限范围,程序说明:
1、 ParkServerDemo: 启动parkserver(它的IP端口已经在配置文件的PARK部分的SERVERS指定
2、 ParkSet:往parkserver里创建了d1n1、d2n2、d3n3、d4n4共4个节点,分别对应只读、读写,所有,所有+强行删除权限
3、 ParkGet:依次对d1n1、d2n2、d3n3、d4n4进行读、写、删除、删除domain操作,观察结果输出,如果没有权限操作,parkserver会输出信息,并且操作返回的结果对象为空

启动命令和顺序:
Javac –classpath fourinone.jar; *.java
Java –classpath fourinone.jar; ParkServerDemo
Java –classpath fourinone.jar; ParkSet
Java –classpath fourinone.jar; ParkGet

如果没有fourinone.jar,可以到以下地址下载:
http://www.skycn.com/soft/68321.html

附件是demo源码

转载于:https://blog.51cto.com/3503265/1058623

fourinone分布式协调设计解析相关推荐

  1. 一举拿下高可用与分布式协调系统设计!

    前言 在上文中我们了解到, canal 可以通过订阅 binlog 日志来提供增量数据订阅和消费,通过这种方式可以实现数据库的实时备份,实时索引构建等 我们再来详细看看它的工作原理 如图示,每个 se ...

  2. 分布式计算原理之分布式协调与同步(1)——分布式选举

    1:分布式选举的概念 一般来说,集群有两个或两个以上的服务器组件而成,其中,每个服务器都是集群中的一个节点.对于一个节点来说,多个节点是如何做到协同工作?比如数据库集群,如何保证数据库写入集群在每个节 ...

  3. 数据库架构设计——分布式数据库设计

    摘要 现在互联网应用已经普及,数据量不断增大.对淘宝.美团.百度等互联网业务来说,传统单实例数据库很难支撑其性能和存储的要求,所以分布式架构得到了很大发展.一定要认识到数据库技术正在经历一场较大的变革 ...

  4. Kafka设计解析(五): Kafka Consumer设计解析

    Kafka设计解析(五)- Kafka Consumer设计解析 大数据架构(郭俊_Jason) · 2015-09-18 08:24 点击上方 大数据架构   快速关注 Kafka Consumer ...

  5. 分布式文件系统HDFS解析

    分布式文件系统HDFS解析 设计目标 Namenode 和 Datanode HDFS HA HDFS Federation 读写流程 Replication 元数据 副本均衡 元数据磁盘错误 快照 ...

  6. Kafka设计解析(八)- Exactly Once语义与事务机制原理

    本文转发自技术世界,原文链接 http://www.jasongj.com/kafka/transaction/ 写在前面的话 本文所有Kafka原理性的描述除特殊说明外均基于Kafka 1.0.0版 ...

  7. 详解分布式协调服务 ZooKeeper

    这篇文章主要会介绍 Zookeeper 的实现原理以及常见的应用 在 2006 年,Google 发表了一篇名为 The Chubby lock service for loosely-coupled ...

  8. 亿级流量 | 蚂蚁金服分布式事务实践解析

    <SOFA:Channel/>,有趣实用的分布式架构频道. 本文根据 SOFAChannel#12 直播分享整理,主题:蚂蚁金服分布式事务实践解析.回顾视频以及 PPT 查看地址见文末. ...

  9. ZooKeeper:分布式应用程序的分布式协调服务

    ZooKeeper--动物园管理员 ZooKeeper:分布式应用程序的分布式协调服务 设计目标 数据模型和分层命名空间 节点和短暂节点 有条件的更新和手表 担保 简单的API 履行 用途 性能 可靠 ...

最新文章

  1. linux的QQ浏览器里微信,移动端微信内置浏览器(或QQ浏览器)无法识别onclick事件的问题解决...
  2. spring+mybatis事务的readonly属性无效
  3. VB随笔 -基本语句之循环语句
  4. Java中的NIO非阻塞编程
  5. 云计算将会让数据中心消失?
  6. 华为鸿蒙系统和苹果系统哪个更好,华为鸿蒙OS和安卓、IOS相比有哪些特色 关于鸿蒙OS不得不知的十个问题...
  7. VAssistX使用
  8. 路由表原理以及数据包进入路由器,路由器的处理
  9. sql还原mysql_如何还原sql数据库
  10. 机器学习实战——xgboost股票close预测
  11. pgsql timestamp without time zone > character varying解决方案
  12. 多多情报通:拼多多数据分析工具在哪?
  13. Fluent非稳态工况模拟中固定时间步数据输出
  14. 雷电模拟器(去广告绿色版)
  15. 06年十大盗版软件排行
  16. 百望股份获评中国企业服务产业独角兽 赋能企业数字化变革!
  17. 相关性检验–Spearman秩相关系数和皮尔森相关系数
  18. 毕业设计 油罐检测爬壁机器人结构设计(说明书+CAD图纸+开题报告+任务书+外文翻译+英文文献)
  19. 为您讲述交流变频电源的基本原理和发展史
  20. 【06 Plugin】

热门文章

  1. springcloud项目的启动顺序_spring boot/cloud 启动方式说明
  2. mysql 正则匹配 捕获组_常用正则表达式 捕获组(分组)
  3. mysql三高讲解(一):1.1 客户端怎样连接mysql数据库
  4. linux动态ip 搭建什么服务,怎么给Linux系统配置动态IP服务
  5. 数据库级联操作mysql_Oracle数据库中的级联查询、级联删除、级联更新操作教程...
  6. 计算机系统的组成doc,计算机系统由(组成.doc
  7. python行数据切片_通过切片访问DataFrame行
  8. pytorch utils.data.DataLoader
  9. A Comprehensive Introduction to Torchtext
  10. matlab 预测值一样,matlab BP神经网络建造如下,预测时,预测值反归一化报错,求大神指教!!!!!...