3）用zookeeper實現分布式鎖

在我們的專案當中，可能有許多元件在並行的執行。這些元件可能需要更新我們的資料儲存。所以這些元件應該有解決衝突的能力，避免髒資料。但是這些元件往往執行在不同的伺服器上，甚至程式語言，檔案系統結構都是不同的。這些差異給我們的分布式協作帶來困難。

zookeeper給我們提供了解決方案。那麼如何借助zookeeper來管理我們的分布式系統，達到系統之間的協作呢？我們可以通過zookeeper來實現分布式鎖的概念，從而達到系統之間的協作目的。

public class distributedlock 
public void lock() throws ioexception 
}});
collections.sort(nodes); // zookeeper node names can be sorted lexographically
if (lockpath.endswith(nodes.get(0))  else }}
} catch (keeperexception e)  catch (interruptedexception e) 
}  public void unlock() throws ioexception  catch (keeperexception e)  catch (interruptedexception e) 
}}

構造方法

public distributedlock(zookeeper zk, string lockbasepath, string lockname)

需要給構造方法提供三個引數，zk 表示可以連線到zookeeper伺服器的客戶端。lockbasepath 準備將節點建立在那個目錄路徑下。lockname指建立的子目錄名稱。

建立節點

lockpath = zk.create(lockbasepath + "/" + lockname, null, ids.open_acl_unsafe, createmode.ephemeral_sequential);

這裡注意的地方就是節點的型別是ephemeral並且是sequetial的。也就是說我們可以在lockbasepath下面可以建立多個名為lockname的多個臨時節點，這些節點時有序的。sequetial節點的名稱可以相同，因為zookeeper將transactionid字尾到節點路徑後面以用於區分。這也是實現分布式鎖的關鍵。另外這些節點時臨時的，保證當申請鎖的程式失去session以後，可以由zookeeper自動去除該節點。

申請鎖

final object lock = new object();
synchronized(lock) 
}});
collections.sort(nodes); // zookeeper node names can be sorted lexographically
if (lockpath.endswith(nodes.get(0))  else 
}}

因為watcher 裡面的process()是有外部執行緒觸發的，所以為了保證兩次時間上相近的觸發操作能夠同步執行使用兩層的synchronized block。

3）用zookeeper實現分布式鎖

zookeeper分布式操作的實現（3）

Dubbo基於Zookeeper實現分布式服務

Zookeeper實現分布式鎖

3）用zookeeper實現分布式鎖

zookeeper分布式操作的實現（3）

Dubbo基於Zookeeper實現分布式服務

Zookeeper實現分布式鎖

相關推薦