- Zookeeper
- Java 8
<dependency>
<groupId>com.jiuxian</groupId>
<artifactId>theone</artifactId>
<version>1.4.1-RELEASE</version>
</dependency>
- Process
- 进程
- Competitive
- 进程的可竞争性实现,用于保证进程在集群中只有惟一一份实例在运行
public class SimpleProcess implements Process {
@Override
public void run() {
System.out.println("This is a process example.");
}
@Override
public void close() throws Exception {
System.out.println("Close resources");
}
}
String zks = "localhost";
Process process = new SimpleProcess();
Competitive competitive = new ZookeeperCompetitiveImpl(zks, "group1");
CompetitiveProcess guard = new CompetitiveProcess(process, competitive);
guard.run();