更新時間:2023-07-11 來源:黑馬程序員 瀏覽量:
Consul是HashiCorp公司推出的開源工具,用于實現(xiàn)分布式系統(tǒng)的服務發(fā)現(xiàn)與配置。 Consul是分布式的、高可用的、可橫向擴展的。它具備以下特性 :
服務發(fā)現(xiàn):consul通過DNS或者HTTP接口使服務注冊和服務發(fā)現(xiàn)變的很容易。 健康檢查:健康檢測使consul可以快速的告警在集群中的操作。 鍵/值存儲:一個用來存儲動態(tài)配置的系統(tǒng)。提供簡單的HTTP接口,可以在任何地方操作。 多數(shù)據(jù)中心:無需復雜的配置,即可支持任意數(shù)量的區(qū)域。
一句話概況:Consul既可以用于注冊中心和配置中心,也可以做keyValue存儲。使用Consul做分布式鎖的底層原理就是keyValue存儲。
基于consul的分布式鎖
ConsulClient 是一個比較核心的類(consul客戶端),keyvalue存儲要用。
private ConsulClient consulClient; @PostConstruct public void init(){ consulClient = new ConsulClient(consulLockConfig.getHost(),consulLockConfig.getPort()); }
createSession方法用于創(chuàng)建一個會話并返回sessionId,ttl是過期時間。我們在釋放鎖的時候會用到這個sessionId。
/** * 創(chuàng)建一個sessionId * @param lockName * @param ttlSeconds * @return */ private String createSession(String lockName,int ttlSeconds){ NewSession session = new NewSession(); //session.setBehavior(Session.Behavior.DELETE); session.setBehavior(Session.Behavior.RELEASE); session.setName("session " + lockName); session.setTtl(ttlSeconds + "s"); return consulClient.sessionCreate(session, null).getValue(); }
加鎖的實現(xiàn):
/** * 獲取鎖 * @param lockName 鎖的名稱(key) * @param ttlSeconds 鎖的超時時間 * @return */ private boolean tryLock(String lockName,int ttlSeconds){ try { PutParams putParams = new PutParams(); String sessionId = createSession(lockName, ttlSeconds); SessionIdHolder.setSessionId(sessionId); log.info("consul加鎖開始(線程:{},鎖名稱:{},sessionId:{})",Thread.currentThread().getName(), lockName,sessionId); putParams.setAcquireSession(sessionId); //2.將構(gòu)件好的LockContext存儲在consul中 String key = consulLockConfig.PREFIX+lockName; //加鎖成功 Boolean value = consulClient.setKVValue(key, sessionId, putParams).getValue(); if(value){ //開起一個新的線程去執(zhí)行鎖續(xù)命--調(diào)用看門狗的方式實現(xiàn) if(consulLockConfig.isRenewal()){ //如果續(xù)期 new ConsulWatchDog(consulClient).watchSession(sessionId,ttlSeconds);//啟動看門狗 } log.info("consul加鎖成功(線程:{},鎖名稱:{},sessionId:{})",Thread.currentThread().getName(), lockName,sessionId); return true; }else{ //將sessionId刪除 //consulClient.deleteKVValue(key); log.info("consul加鎖失敗(線程:{},鎖名稱:{},sessionId:{})",Thread.currentThread().getName(), lockName,sessionId); return false; } }catch (Exception e){ e.printStackTrace(); return false; } }
解鎖的實現(xiàn):
/** * 釋放鎖 */ public boolean unLock(String lockName){ //log.info("consul釋放鎖開始(線程:{},鎖名稱:{})",Thread.currentThread().getName(),lockName); String sessionId = SessionIdHolder.getSessionId(); try { //先根據(jù)鎖名稱找到對應的sessionId session 是需要進行存儲的 現(xiàn)在我們是通過一個lockContnt 假如說業(yè)務上不在一個微服務里釋放鎖 對應的 其他微服務如何獲取到這把鎖呢 String key = consulLockConfig.PREFIX+lockName; Response<GetValue> kvValue = consulClient.getKVValue(key); if(kvValue==null) return false; GetValue value = kvValue.getValue(); if(value==null) return false; //log.info("consul釋放鎖開始(線程:{},鎖名稱:{},sessionId:{})",Thread.currentThread().getName(),lockName,sessionId); PutParams putParams = new PutParams(); putParams.setReleaseSession(sessionId); consulClient.setKVValue(key, sessionId, putParams); //String sessionId = value.getDecodedValue(); consulClient.sessionDestroy(sessionId, null);// key value也會被刪除 是使用的DELETE //刪除對應的 sessionId存儲 //consulClient.deleteKVValue(key); log.info("consul釋放鎖成功(線程:{},鎖名稱:{},sessionId:{})",Thread.currentThread().getName(),lockName,sessionId); return true; }catch (Exception e){ e.printStackTrace(); log.info("consul釋放鎖出錯(線程:{},鎖名稱:{},sessionId:{})",Thread.currentThread().getName(),lockName,sessionId); return false; } }