redis使用watch秒殺搶購實現思路
阿新 • • 發佈:2020-01-09
本文例項為大家分享了redis使用watch秒殺搶購的具體程式碼,供大家參考,具體內容如下
1、使用watch,採用樂觀鎖
2、不使用悲觀鎖,因為等待時間非常長,響應慢
3、不使用佇列,因為併發量會讓佇列記憶體瞬間升高
程式碼:
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import redis.clients.jedis.Jedis; /** * redis測試搶購 * * @author 10255_000 * */ public class RedisTest { public static void main(String[] args) { final String watchkeys = "watchkeys"; ExecutorService executor = Executors.newFixedThreadPool(20); final Jedis jedis = new Jedis("192.168.3.202",6379); jedis.set(watchkeys,"0");// 重置watchkeys為0 jedis.del("setsucc","setfail");// 清空搶成功的,與沒有成功的 jedis.close(); for (int i = 0; i < 10000; i++) {// 測試一萬人同時訪問 executor.execute(new MyRunnable()); } executor.shutdown(); } } import java.util.List; import java.util.UUID; import redis.clients.jedis.Jedis; import redis.clients.jedis.Transaction; public class MyRunnable implements Runnable { String watchkeys = "watchkeys";// 監視keys Jedis jedis = new Jedis("192.168.3.202",6379); public MyRunnable() { } @Override public void run() { try { jedis.watch(watchkeys);// watchkeys String val = jedis.get(watchkeys); int valint = Integer.valueOf(val); String userifo = UUID.randomUUID().toString(); if (valint < 10) { Transaction tx = jedis.multi();// 開啟事務 tx.incr("watchkeys"); List<Object> list = tx.exec();// 提交事務,如果此時watchkeys被改動了,則返回null if (list != null) { System.out.println("使用者:" + userifo + "搶購成功,當前搶購成功人數:" + (valint + 1)); /* 搶購成功業務邏輯 */ jedis.sadd("setsucc",userifo); } else { System.out.println("使用者:" + userifo + "搶購失敗"); /* 搶購失敗業務邏輯 */ jedis.sadd("setfail",userifo); } } else { System.out.println("使用者:" + userifo + "搶購失敗"); jedis.sadd("setfail",userifo); // Thread.sleep(500); return; } } catch (Exception e) { e.printStackTrace(); } finally { jedis.close(); } } }
Redis對事物的支援目前比較簡單。Redis只能保證一個client發起的事務中的命令可以連續的執行,但後面命令出錯前面不會回滾。而中間不會插入其他client的命令。當一個client在找一個連續中發出multi命令時,這個連結會進入一個事務上下文,該連結後續的命令不會立即執行,而是先放到佇列中,當執行exec命令是,redis會順序的執行佇列中的所有命令。當如果佇列中有命令錯誤,不會回滾。
樂觀鎖:大多數是基於資料版本(version)的記錄機制實現的。即為資料增加一個版本標識,在基於資料庫表的版本解決方案中,一般是通過為資料庫表新增一個”version”欄位來實現讀取出資料時,將此版本號一同讀出,之後更新時,對此版本號+1。此時,將提交資料的版本號與資料庫表對應記錄版本號進行比對,如果提交的資料版本號大於資料當前版本號,則予以更新,否則認為是過去資料。
在Redis中,使用watch命令實現樂觀鎖(watch key):
watch命令會監視給定的key,當exec時,如果監視的key從呼叫watch後發生過變化,則事務會失敗,也可以呼叫wathc多長監視多個key。這樣就可以對指定key加樂觀鎖了。注意watch的可以是對整個連線有效的。事務也一樣。如果連線斷開,監視和事務都會被自動清除。當然exec,discard,unwatch命令都會清除連線中的所有監視。
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。