大规模分布式系统架构与设计实战笔记3

千峰老师的《大规模分布式系统架构与设计实战》的第三章讲的是分布式协调的实现，在工头-职介所-工人的模型中，分布式协调实际上就是职介所相关的一些内容，包括领导（职介所）怎么产生的，当前领导宕机了怎么办，领导如何管理各个员工（工人）等等一系列问题。 

在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);  
    }  
}  

只需要启动一个领导和多个备用领导就可以了，当领导宕机就会有备用的领导顶上去。