ConsulClient consulClient = new ConsulClient("localhost", 8500);	// 创建与Consul的连接
CheckTtl checkTtl = new CheckTtl("checkId", consulClient); // session的健康检查，用来清理失效session占用的锁
Lock lock = new Lock(consulClient, "lockKey", checkTtl);
try {
	// 获取分布式互斥锁
  	// 参数含义：是否使用阻塞模式、每次尝试获取锁的间隔500ms、尝试n次
    if (lock.lock(true, 500L, null)) {     	
        // TODO 处理业务逻辑
    } 
catch (Exception e) {
    e.printStackTrace();
} finally {
    lock.unlock();
}

ConsulClient consulClient = new ConsulClient("localhost", 8500);	// 创建与Consul的连接
CheckTtl checkTtl = new CheckTtl("checkId", consulClient); // session的健康检查，用来清理失效session占用的锁
Semaphore semaphore = new Semaphore(consulClient, 3, "lockKey", checkTtl); // 3为信号量的值
try {
	if (semaphore.acquired(true)) {
    	// TODO 获取到信号量，执行业务逻辑
	}
} catch (Exception e) {
    e.printStackTrace();
} finally {
    try {
		// 信号量释放
		semaphore.release();
	} catch (IOException e) {
    	e.printStackTrace();
    }
}