redis鎖機制介紹與例項
1 悲觀鎖
執行操作前假設當前的操作肯定(或有很大機率)會被打斷(悲觀)。基於這個假設,我們在做操作前就會把相關資源鎖定,不允許自己執行期間有其他操作干擾。
Redis不支援悲觀鎖。Redis作為快取伺服器使用時,以讀操作為主,很少寫操作,相應的操作被打斷的機率較少。不採用悲觀鎖是為了防止降低效能。
2 樂觀鎖
執行操作前假設當前操作不會被打斷(樂觀)。基於這個假設,我們在做操作前不會鎖定資源,萬一發生了其他操作的干擾,那麼本次操作將被放棄。
3. Redis中的鎖策略
Redis採用了樂觀鎖策略(通過watch操作)。樂觀鎖支援讀操作,適用於多讀少寫的情況!
在事務中,可以通過watch命令來加鎖;使用 UNWATCH可以取消加鎖;
例子
redis鎖工具類
package com.fly.lock; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; public class RedisLock { //初始化redis池 private static JedisPoolConfig config; private static JedisPool pool; static { config = new JedisPoolConfig(); config.setMaxTotal(30); config.setMaxIdle(10); pool = new JedisPool(config,"192.168.233.200",6379); } /** * 給target上鎖 * @param target **/ public static void lock(Object target) { //獲取jedis Jedis jedis = pool.getResource(); //result接收setnx的返回值,初始值為0 Long result= 0L; while (result < 1) { //如果target在redis中已經存在,則返回0;否則,在redis中設定target鍵值對,並返回1 result = jedis.setnx(target.getClass().getName() + target.hashCode(),Thread.currentThread().getName()); } jedis.close(); } /** * 給target解鎖 * @param target **/ public static void unLock(Object target) { Jedis jedis = pool.getResource(); //刪除redis中target物件的鍵值對 Long del = jedis.del(target.getClass().getName() + target.hashCode()); jedis.close(); } /** * 嘗試給target上鎖,如果鎖成功返回true,如果鎖失敗返回false * @param target * @return **/ public static boolean tryLock(Object target) { Jedis jedis = pool.getResource(); Long row = jedis.setnx(target.getClass().getName() + target.hashCode(),"true"); jedis.close(); if (row > 0) { return true; } return false; } }
測試類
package com.fly.test; import com.fly.lock.RedisLock; class Task { public void doTask() { //上鎖 RedisLock.lock(this); System.out.println("當前執行緒: " + Thread.currentThread().getName()); System.out.println("開始執行: " + this.hashCode()); try { System.out.println("doing..."); Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("完成: " + this.hashCode()); //解鎖 RedisLock.unLock(this); } } public class Demo { public static void main(String[] args) { Task task = new Task(); Thread[] threads = new Thread[5]; for (Thread thread : threads) { thread = new Thread(()->{ task.doTask(); }); thread.start(); } } }
輸出結果:
----------------------------------------------
當前執行緒: Thread-0
開始執行: 2081499965
doing...
完成: 2081499965
----------------------------------------------
當前執行緒: Thread-2
開始執行: 2081499965
doing...
完成: 2081499965
----------------------------------------------
當前執行緒: Thread-1
開始執行: 2081499965
doing...
完成: 2081499965
----------------------------------------------
當前執行緒: Thread-4
開始執行: 2081499965
doing...
完成: 2081499965
----------------------------------------------
當前執行緒: Thread-3
開始執行: 2081499965
doing...
完成: 2081499965
去掉redis鎖後,執行結果:
----------------------------------------------
----------------------------------------------
當前執行緒: Thread-2
開始執行: 1926683415
----------------------------------------------
當前執行緒: Thread-1
doing...
當前執行緒: Thread-0
----------------------------------------------
當前執行緒: Thread-3
開始執行: 1926683415
doing...
開始執行: 1926683415
doing...
----------------------------------------------
開始執行: 1926683415
doing...
當前執行緒: Thread-4
開始執行: 1926683415
doing...
完成: 1926683415
完成: 1926683415
完成: 1926683415
完成: 1926683415
完成: 1926683415
Process finished with exit code 0
利用redis這個性質,可以實現分散式鎖,當然設計一定複雜一些!
總結
以上就是這篇文章的全部內容了,希望本文的內容對大家的學習或者工作具有一定的參考學習價值,謝謝大家對我們的支援。如果你想了解更多相關內容請檢視下面相關連結