Java語言如何正確實現Redis分布式鎖？

和大家分享我的經驗，如何用redis提供的一個簡單接口，輕松實現redis分布式鎖。

在開始之前，我先簡單介紹下redis的性能。

高效的Redis

Redis本身是單線程的，這樣帶來的好處是能夠提高讀寫效率。多線程通常來說會有上下文切換帶來的時間損耗，而redis通過綁定單個CPU到某塊內存，實現了上下文切換的最小開銷，因此這種場景反而比多線程還要高效。

不安全的Redis

但是，如果有不同的節點同時要對Redis中的同一個數據進行操作，由于是來自不同Redis服務器，就會發生線程不安全的情況。

舉例有兩個功能函數X和Y（也可以看做是兩個服務器節點），二者功能相同，都要執行讀取Redis中變量P，并且對其加一的操作。如果是線程安全的，那么X和Y分別執行完之后，P的值應該比原來增加2，但是由于函數XY互相獨立，那就可能發生下面這種情況：

1 X讀取P

2 Y讀取P

3 X將P+1寫回Redis

4 Y將P+1寫回Redis

執行結束后，P的值卻變成了P+1，而不是P+2。

這就是線程不安全導致的結果。

redis的分布式鎖

那么如何用Redis來避免上面的情況呢。

Redis對外開放了一個非常厲害的api，目前經常被大家用來做分布式鎖，是絕對的線程安全，這個函數就是SET key field value加上NX參數。這個NX參數可是了不得，通常來說，set函數是不管field字段是否存在，只要寫入成功就會返回1，但是如果增加了NX參數，那么如果field值在redis中已經存在，就會返回nil，否則才返回1。因此可以通過這個函數來執行加鎖操作，如果返回值不為nil，則加鎖成功，否則代表有其他線程在操作數據，當前請求需要等待。

不僅如此，為了避免死鎖，SET還有一個參數為EX，即EX毫秒后，field會自動清空。

此外，還有PX，XX參數，具體含義見如下文檔。

以上就是我在工作中總結的防止redis并發的方式，如果你有其他想法，歡迎在下方評論區與我溝通。

我是蘇蘇思量，來自BAT的java開發工程師，每天分享技術見聞，歡迎關注我，與我共同進步。