這篇“怎么用數(shù)據(jù)庫(kù)的悲觀鎖來(lái)實(shí)現(xiàn)一個(gè)分布式的鎖”文章的知識(shí)點(diǎn)大部分人都不太理解，所以小編給大家總結(jié)了以下內(nèi)容，內(nèi)容詳細(xì)，步驟清晰，具有一定的借鑒價(jià)值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來(lái)看看這篇“怎么用數(shù)據(jù)庫(kù)的悲觀鎖來(lái)實(shí)現(xiàn)一個(gè)分布式的鎖”文章吧。

創(chuàng)新互聯(lián)不只是一家網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司；我們對(duì)營(yíng)銷(xiāo)、技術(shù)、服務(wù)都有自己獨(dú)特見(jiàn)解，公司采取“創(chuàng)意+綜合+營(yíng)銷(xiāo)”一體化的方式為您提供更專(zhuān)業(yè)的服務(wù)！我們經(jīng)歷的每一步也許不一定是最完美的，但每一步都有值得深思的意義。我們珍視每一份信任，關(guān)注我們的網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站質(zhì)量和服務(wù)品質(zhì)，在得到用戶(hù)滿(mǎn)意的同時(shí)，也能得到同行業(yè)的專(zhuān)業(yè)認(rèn)可，能夠?yàn)樾袠I(yè)創(chuàng)新發(fā)展助力。未來(lái)將繼續(xù)專(zhuān)注于技術(shù)創(chuàng)新，服務(wù)升級(jí)，滿(mǎn)足企業(yè)一站式網(wǎng)絡(luò)營(yíng)銷(xiāo)推廣需求，讓再小的成都品牌網(wǎng)站建設(shè)也能產(chǎn)生價(jià)值！

分布式鎖顧名思義是發(fā)生在分布式環(huán)境中的。對(duì)于單進(jìn)程場(chǎng)景，我們可以使用語(yǔ)言和類(lèi)庫(kù)提供的鎖，對(duì)于分布式鎖，我也可以使用分布式鎖。也就是說(shuō)同樣的鎖使用的環(huán)境不同，分布式環(huán)境中用的鎖就叫分布式鎖！

根據(jù)上面的理解，分布式鎖是不是應(yīng)該具備下面的特點(diǎn)：

1. 分布式鎖必須保證在分布式部署的應(yīng)用集群中，同一個(gè)方法在同一時(shí)間只能被一臺(tái)機(jī)器上的一個(gè)線(xiàn)程執(zhí)行；

2. 一個(gè)線(xiàn)程獲得了鎖，其他線(xiàn)程必須等待持有鎖的線(xiàn)程釋放掉才能再獲??；

3. 鎖必須要有超時(shí)機(jī)制（避免死鎖）

基于上面的特點(diǎn)，我們就可以通過(guò)數(shù)據(jù)庫(kù)的悲觀鎖來(lái)實(shí)現(xiàn)一個(gè)分布式鎖。

代碼非常的簡(jiǎn)單，使用 for update 即可。具體如下：

public class XttblogLock {

   private DataSource dataSource;

   private static final String cmd = "select * from xttblog_lock where id = 1 for update";

   public XttblogLock(DataSource ds) {
       this.dataSource = ds;
   }

   public static interface CallBack{
       public void doAction();
   }
   public void lock(CallBack callBack)  {
       Connection conn = null;
       PreparedStatement stmt = null;
       ResultSet rs = null;

       try {
           //try get lock
           System.out.println(Thread.currentThread().getName() + " begin try lock");
           conn = dataSource.getConnection();
           conn.setAutoCommit(false);
           stmt = conn.prepareStatement(cmd);
           rs = stmt.executeQuery();
         
           //do business thing
           callBack.doAction();
           
           //release lock
           conn.commit();
           System.out.println(Thread.currentThread().getName() + " release lock");

       } catch (SQLException e) {
           e.printStackTrace();

       } finally {
           
           if (null != conn) {
               try {
                   conn.close();
               } catch (SQLException e) {
                   e.printStackTrace();
               }
           }

       }
   }
}

該鎖的調(diào)用也非常的簡(jiǎn)單，具體代碼如下：使用數(shù)據(jù)庫(kù)悲觀鎖實(shí)現(xiàn)分布式鎖主要用了數(shù)據(jù)庫(kù)的 for update 命令，執(zhí)行改命令后，對(duì)應(yīng)行記錄會(huì)被鎖住，其它線(xiàn)程會(huì)被阻塞主，直到獲取到這行記錄的線(xiàn)程提交了事務(wù)。這里需要注意要把自動(dòng)提交設(shè)置為 false。

該鎖的調(diào)用也非常的簡(jiǎn)單，具體代碼如下：

final XttblogLock xttblogLock = new XttblogLock(dataSource);
xttblogLock.lock(new CallBack() {
                       
   @Override
   public void doAction() {
       System.out.println(Thread.currentThread().getName() + "beging do somthing");
       try {
           System.out.println("業(yè)余草：www.xttblog.com 歡迎你！");
           Thread.sleep(2000);
       } catch (InterruptedException e) {
           e.printStackTrace();
       }
       System.out.println(Thread.currentThread().getName() + "end do somthing");

   }
});

雖然數(shù)據(jù)庫(kù)的 for update 悲觀鎖可以用來(lái)做分布式鎖，但實(shí)際的生產(chǎn)過(guò)程中采用這種方法的非常少，因?yàn)樗阅懿皇呛芨摺?/p>

以上就是關(guān)于“怎么用數(shù)據(jù)庫(kù)的悲觀鎖來(lái)實(shí)現(xiàn)一個(gè)分布式的鎖”這篇文章的內(nèi)容，相信大家都有了一定的了解，希望小編分享的內(nèi)容對(duì)大家有幫助，若想了解更多相關(guān)的知識(shí)內(nèi)容，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。