import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
public class DistributedLockExample {
private static final String ZOOKEEPER_CONNECTION_STRING = "localhost:2181";
private static final String LOCK_PATH = "/my-lock";
public static void main(String[] args) throws Exception {
CuratorFramework client = CuratorFrameworkFactory.newClient(ZOOKEEPER_CONNECTION_STRING, new RetryForever(1000));
client.start();
InterProcessMutex lock = new InterProcessMutex(client, LOCK_PATH);
try {
if (lock.acquire(10, TimeUnit.SECONDS)) {
} else {
}
} finally {
lock.release();
}
client.close();
}
}
