1.什么是分布式鎖，為什么需要分布式鎖？

答：隨著互聯(lián)網(wǎng)的發(fā)展，單機(jī)項(xiàng)目已經(jīng)遠(yuǎn)遠(yuǎn)不能滿足市場(chǎng)的需求，許多項(xiàng)目開始使用基于springCloud和dubbo的分布式解決方案，但是由于許多項(xiàng)目采用集群方案部署，導(dǎo)致jvm自帶的synchronized、Lock等不能滿足項(xiàng)目的需求，例如當(dāng)實(shí)現(xiàn)商品秒殺時(shí)，前端的高并發(fā)請(qǐng)求會(huì)同時(shí)訪問不同的服務(wù)器，當(dāng)你使用synchronized或者Lock的時(shí)候，只能鎖定本臺(tái)服務(wù)器的某個(gè)方法或代碼塊。這時(shí)候分布式鎖就顯得尤為重要。

2.分布式鎖有哪幾種結(jié)局方案？

答：基于zookeeper解決方案、基于redis解決方案、基于數(shù)據(jù)庫的解決方案

3.zookeeper方案是如何解決的，原理是什么？

答：zookeeper官網(wǎng)數(shù)據(jù)結(jié)構(gòu)圖

image

這個(gè)是官網(wǎng)的zookeeper數(shù)據(jù)圖，從圖中就可以看出zookeeper是一種樹形的數(shù)據(jù)結(jié)構(gòu)，它存貯數(shù)據(jù)的地方就是它的節(jié)點(diǎn)，zookeeper分布式鎖也是基于此來做的，當(dāng)某個(gè)程序獲得鎖之后，創(chuàng)建一個(gè)臨時(shí)節(jié)點(diǎn)，其它并發(fā)請(qǐng)求獲取鎖的時(shí)候，先判斷一下，該節(jié)點(diǎn)存不存在，若存在則等待并監(jiān)聽，不存在，創(chuàng)建臨時(shí)節(jié)點(diǎn)獲取鎖。當(dāng)程序運(yùn)行完斷開連接，或者刪除臨時(shí)節(jié)點(diǎn)來進(jìn)行鎖釋放。

4.zookeeper如何使用代碼來實(shí)現(xiàn)分布式鎖？

答：pom.xml文件

        <!--zookeeper客戶端-->
        <dependency>
        <groupId>com.101tec</groupId>
        <artifactId>zkclient</artifactId>
        <version>0.11</version>
        </dependency>

接口

/**
 * @author oumiga
 */
public interface ZookeeperLock {
    /**
     * 獲取鎖
     */
    public void lock();

    /**
     * 釋放鎖
     */
    public void closeLock();
}

抽象類

import org.I0Itec.zkclient.ZkClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.util.StringUtils;
import java.util.Objects;
import java.util.concurrent.CountDownLatch;

/**
 * @author oumiga
 */
public abstract class AbstractZookLock implements ZookeeperLock {

    @Value("${zookeeper.LockIp}")
    protected String zookeeperIp;

    protected ZkClient zkClient;

    protected String elementName = "/lock";

    protected CountDownLatch countDownLatch;
    @Override
    public void lock() {
        boolean lock = tryLock();
        if(!lock){
            waitLock();
            lock();
        }
    }

    /**
     * 關(guān)閉連接，釋放鎖
     */
    @Override
    public void closeLock() {
        if(Objects.nonNull(zkClient)){
            zkClient.close();
        }
    }

    public abstract boolean tryLock();

    public abstract void waitLock();

    /**
     * 獲取Zkclient對(duì)象
     * @return
     */
    public ZkClient getZkClient(){
        if(zkClient == null){
            if(StringUtils.isEmpty(zookeeperIp)){
                new ZkClient(zookeeperIp);
                return zkClient;
            }
            zkClient = new ZkClient("127.0.0.1");
            return zkClient;
        }
        return zkClient;
    }
}

抽象實(shí)現(xiàn)類

import org.I0Itec.zkclient.IZkDataListener;
import org.I0Itec.zkclient.ZkClient;
import java.util.Objects;
import java.util.concurrent.CountDownLatch;

/**
 * @author oumiga
 */
public class ZookLockImpl extends AbstractZookLock {


    /**
     * 嘗試獲取鎖
     * @return
     */
    @Override
    public boolean tryLock() {
        try{
            ZkClient zkClient = getZkClient();
            if(!zkClient.exists(elementName)){
                return false;
            }
            zkClient.createEphemeral(elementName);
            countDownLatch = new CountDownLatch(1);
            return true;
        }catch(Exception e){
            return false;
        }

    }

    /**
     * 等待鎖釋放
     */
    @Override
    public void waitLock() {
        ZkClient zkClient = getZkClient();
        IZkDataListener iZkDataListener = new IZkDataListener() {
            //監(jiān)聽數(shù)據(jù)的改變
            @Override
            public void handleDataChange(String s, Object o) throws Exception {

            }

            //監(jiān)聽數(shù)據(jù)的刪除
            @Override
            public void handleDataDeleted(String s) throws Exception {
                if(Objects.nonNull(countDownLatch)){
                    countDownLatch.countDown();
                }
            }
        };
        //監(jiān)聽節(jié)點(diǎn)
        zkClient.subscribeDataChanges(elementName,iZkDataListener);
        if(zkClient.exists(elementName)){
            try {
                countDownLatch.await();

            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        zkClient.unsubscribeDataChanges(elementName,iZkDataListener);
    }
}

工具使用類

/**
 * @author oumiga
 */
public  class zookLockUtils {
    private static ZookeeperLock zookeeperLock = new ZookLockImpl();

    /**
     * 獲取鎖
     */
    public static void lock(){
        zookeeperLock.lock();
    }

    /**
     * 釋放鎖
     */
    public static void closeLock(){
        zookeeperLock.closeLock();
    }
}