千峰老师的《大规模分布式系统架构与设计实战》的第三章讲的是分布式协调的实现,在工头-职介所-工人的模型中,分布式协调实际上就是职介所相关的一些内容,包括领导(职介所)怎么产生的,当前领导宕机了怎么办,领导如何管理各个员工(工人)等等一系列问题。
在fourinone中,选取领导并不像paxos算法一样实行基于抢占的少数服从多数的策略,而是一种谦让的策略,相当领导的人在发出当领导的申请之前先问问别人想不想当领导,如果想,他自己就先忍着,如果没有其他人他才出头。这样就避免了冲突。
当领导确定后,有领导统一发号施令,同步各个机器。
而领导又是如何同步各个机器的呢?fourinone框架通过park进行配置信息管理,park提供创建和修改信息的方法,并支持轮训和监听两种方式获取变化的对象,进步保持分布式系统的配置的一致性。
import com.fourinone.BeanContext;
import com.fourinone.ParkLocal;
import com.fourinone.ObjectBean;
public class GetConfigA
{
public static void main(String[] args)
{
ParkLocal pl=BeanContext.getPark();
ObjectBean oldob=null;
while(true)
{
ObjectBean newob=pl.getLastest("zhejiang","hangzhou",oldob);
if(newob!=null)
{
System.out.println(newob);
oldob=newob;
}
}
}
}
import com.fourinone.BeanContext;
import com.fourinone.ParkLocal;
import com.fourinone.LastestListener;
import com.fourinone.LastestEvent;
import com.fourinone.ObjectBean;
public class GetConfigB implements LastestListener
{
public boolean happenLastest(LastestEvent le)
{
ObjectBean ob = (ObjectBean)le.getSource();
System.out.println(ob);
return false;
}
public static void main(String[] args)
{
ParkLocal pl = BeanContext.getPark();
pl.addLastestListener("zhejiang", "hangzhou", null, new GetConfigB());
}
}
import com.fourinone.*;
public class SetConfig
{
public static void main(String[] args)
{
ParkLocal pl = BeanContext.getPark();
ObjectBean xihu = pl.create("zhejiang", "hangzhou", "xihu",AuthPolicy.OP_ALL);
try{Thread.sleep(8000);}catch(Exception e){}
ObjectBean yuhang = pl.update("zhejiang", "hangzhou","xihu");
}
}
可以看到,应用程序只需要在ParkLocal中做改动,其他的机器就会感知这种变化进而使整个分布式系统保持一致。
同时,fourinone又提供了处理宕机的情况:
import com.fourinone.BeanContext;
public class ParkMasterSlave
{
public static void main(String[] args)
{
String[][] master = new String[][]{{"localhost","1888"},{"localhost","1889"}};
String[][] slave = new String[][]{{"localhost","1889"},{"localhost","1888"}};
String[][] server = null;
if(args[0].equals("M"))
server = master;
else if(args[0].equals("S"))
server = slave;
BeanContext.startPark(server[0][0],Integer.parseInt(server[0][1]), server);
}
}
只需要启动一个领导和多个备用领导就可以了,当领导宕机就会有备用的领导顶上去。
分享到:
相关推荐
NULL 博文链接:https://yizhenn.iteye.com/blog/2102314
文档内容有关于MySQL的主从配置,MySQL读写分离、MySQL集群配置、Redis主从配置、Redis集群配置、kafka单机与集群搭建以及使用、zookeeper单机与集群搭建以及使用、部分夹杂着其他乱七八糟的笔记内容。
大型分布式网站架构设计与实践+笔记.zip 1.Cache缓存 2.持久化存储 3.消息系统MQ 4.垂直化搜索引擎 5.其他基础设施
文是学习大型分布式网站架构的技术总结。对架构一个高性能,高可用,可伸缩,可扩展的分布式网站进行了概要性描述,并给出一个架构参考。一部分为读书笔记,一部分是个人经验总结。对大型分布式网站架构有很好的参考...
分布式系统原理与范例读书笔记
2019年软考系统架构设计师学习笔记.pdf2019年软考系统架构设计师学习笔记.pdf2019年软考系统架构设计师学习笔记.pdf2019年软考系统架构设计师学习笔记.pdf2019年软考系统架构设计师学习笔记.pdf2019年软考系统架构...
Java架构开发大型互联网-架构师必须掌握的分布式技术pdf+视频
第二部分给出了一些实际的分布式系统:基于对象的分布式系统、分布式文件系统、基于文档的分布式系统以及基于协作的分布式系统,介绍了一些实际系统的设计思想和实现技术。全书结构清晰,内容全面经典,系统性与先进...
本人在看《大规模分布式存储系统》这本书的过程中,记录的思维导图笔记,方便学习和复习这本书的重点内容,适合于分布式存储的入门同学。书中实战的部分因为是基于阿里的ocean base,比较具体,处于入门学习的目的,...
分布式系统原理与范式 第二版 2008年版本 与原教材无缝吻合,极好的辅助学习资料
系统架构设计师属于高级工程师的范畴,本学习笔记内容系统全面,要考系统架构设计师的可以参考学习,有帮助的可以来下载学习。
系统架构设计师复习笔记,复习精华,值得参考。。。。。。。。。。。。
软考高级系统架构师经验复习笔记仅供个人学习使用
原来的PDF版有85M,过大。这个是epud版,只有6M,方便阅读和摘抄笔记。
软考系统架构设计师(高级)学习笔记汇总 系统架构设计师考试大纲 系统架构设计师考试大纲和复习指南 系统架构设计师课程大纲 系统架构设计师:浅谈架构 系统架构设计师:软件架构师之路 系统架构设计师复习笔记 系统...
第一章 概述传统存储系统的纵向扩展,即先买小型机,不够再中型机,再不然就大型机,即增加单机的容量。分布式存储系统分为分布式文件系统,分布式键值系统,分布式表格系
系统架构师学习笔记,很好的架构师学习资料,十分详细。
耗时半年研发的生产级项目大课,学完对标一线城市30K以上月薪
分布式锁笔记笔记笔记笔记
系统架构师复习笔记.docx