Barrier
在分布式系统中常使用Barrier来阻塞进程,当满足一定条件后再恢复进行后续操作。Barrier在Zookeeper中可以通过设计一个Barrier节点来实现。Barrier 节点存在时会进行阻塞,下面是伪代码:
1.客户端调用exists方法来检查Barrier节点是否存在,并设置watch为true。
2.如exists返回false,表示Barrier条件满足,继续运行。
3.如exists返回true,客户端等待Zookeeper的节点上的watch事件。
4.当watch触发后,返回第一步继续进行检查exist直到节点被删除。
双重Barrier(Double Barrier)
双重Barrier让客户端同步地开始和结束进程。当进程数满足Barrier需求,就开始运行,并在运行完后释放Barrier,下面介绍如何使用Zookeeper的节点创建一个双重Barrier。
在本例的伪代码中创建一个节点b作为Barrier。每个客户端p注册在Barrier节点上并在离开时注销。一个节点通过下面的注册流程进行注册,直到x个客户端注册后再继续运行。(x可以由你自己系统决定)
注册 | 注销 |
---|---|
1.定义n = b+"/"+p 2.设置watch进行判断是否存在:exists(b + "/ready", true) 3.创建子节点create( n, EPHEMERAL) 4.获得存在的子节点L = getChildren(b, false) 5.如果L的个数比x小则等待watch事件 6.否则创建create(b + "/ready", REGULAR) |
1.获得存在的子节点数L = getChildren(b, false) 2.如果没有子节点则退出 3.如果p是唯一子节点,则删除n并退出 4.如果p是L中最小的子节点,等最大的节点注销 5.否则delete(n),并等待最小的节点删除 6.返回第1步 |
在注册时,所有进程监视ready节点并在Barrier节点下创建一个ephemeral节点。除了最后注册的节点,每个进程在第5步等待ready节点创立,最后一个进程会看到所有x个子节点并创建ready节点,从而唤醒其他进程。
在注销时,由于需要监视的是节点的删除,就无法使用ready标志了。注册时,使用ephemeral节点,就算进程在触发Barrier之后报错也不会影响其他正常的进程。当进程准备退出,他们需要删除自己的进程节点并等待其他进程全部删除。
当b下没有进程子节点时,进程退出。然而,为了提高效率,你可以使用最小的进程节点作为ready标志。所有其他进程准备删除时,watch最小的进程节点删除,而最小的进程本身,监视其他任何一个节点(为了方便可以取最大的那个节点)。这意味着,每个节点删除最多只会唤醒一个进程,只有最后一个节点在删除时会唤醒所有进程。
使用Curator
Barrier
public DistributedBarrier(CuratorFramework client,String barrierPath)
/** client 客户端实例
barrierPath barrier节点的路径**/
public void waitOnBarrier() 阻塞进程
public void setBarrier() 设置Barrier
public void removeBarrier() 移除Barrier
双重Barrier
public DistributedDoubleBarrier(CuratorFramework client,String barrierPath,int memberQty)
/** client 客户端实例
barrierPath barrier节点的路径
memberQty 期望节点的数量**/
public void enter() 注册
public void leave() 注销