正文

東西不多賣

秒殺系統需要保證東西不多賣，關鍵是在多個客戶端對庫存進行減操作時，必須加鎖。Redis中的Watch剛好可以實現一點。首先我們需要獲取當前庫存，只有庫存中的食物小於購物車的數目才能對庫存進行減。在高併發的情況下會出現某時刻查詢庫存夠的，但下一時刻另外一個執行緒下單了，對庫存進行減操作，剛好小於上個執行緒的購物車數目。照理現在的狀態是不能下單成功的，因為庫存已經不夠了，但上一執行緒仍然認為數量還夠，對庫存進行減操作，從而導致庫存出現負數的情況。如何避免？

Redis 中的watch可以在事務前對資料進行監控，如果在事務執行前，該資料發生改變，則事務不執行。剛好能滿足我們的要求。看了很多程式碼，對watch功能還不是很理解，因為網上很多寫的帖子都沒有明確指出多客戶端（理解之後發現還是有寫的），所以不明白的可以參見下面的例子，是用Java寫的。以下程式碼可以保證庫存不多賣。

在redis中設定一個鍵為mykey，值為1000的變數，

public class Main {

    public static void main(String[] args) {
            new MyThread().start();
            new MyThread().start();
            new MyThread().start();
            new MyThread().start();
            new MyThread().start();
            new MyThread().start();
            new
 
 MyThread().start();
            new MyThread().start();
            new MyThread().start();
            new MyThread().start();
    }
}

class MyThread extends Thread {
    Jedis jedis = null;

    @Override
    public void run() {
        // TODO Auto-generated method stub
        while (true) {
            System.out.println(Thread.currentThread().getName());
            jedis = RedisUtil.getJedis();
            try
 
 {
                int stock = Integer.parseInt(jedis.get("mykey"));
                if (stock > 0) {
                    jedis.watch("mykey");
                    Transaction transaction = jedis.multi();
                    transaction.set("mykey", String.valueOf(stock - 1));
                    List<Object> result = transaction.exec();
                    if (result == null || result.isEmpty()) {
                        System.out.println("Transaction error...");// 可能是watch-key被外部修改，或者是資料操作被駁回
                    }
                } else {
                    System.out.println("庫存為0");
                    break;
                }
            } catch (Exception e) {
                // TODO: handle exception
                e.printStackTrace();
                RedisUtil.returnResource(jedis);
            }finally{
                RedisUtil.returnResource(jedis);
            }

        }
    }

}

Redis保證從資料只加載一次

我這裡碰到的需求是一開始要從Mysql資料庫中匯入資料到Redis，由於有多臺伺服器，不進行控制會對資料進行多次載入，所以我們可以設定一個鍵值進行控制。

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Response;
import redis.clients.jedis.Transaction;
public class Main {

    public static void main(String[] args) {
            new lock().start();
            new lock().start();
            new lock().start();
            new lock().start();
            new lock().start();
            new lock().start();
            new lock().start();
            new lock().start();
            new lock().start();
            new lock().start();
    }
}

class lock extends Thread{

    @Override
    public void run() {
        // TODO Auto-generated method stub
        System.out.println(Thread.currentThread().getName());
        Jedis jedis = null;
        try {
            jedis = RedisUtil.getJedis();
            if(jedis.setnx("look", "1") == 1){
                jedis.set("food", Thread.currentThread().getName());
            }else{
                System.out.println(Thread.currentThread().getName() + "未訪問");
            }
        } catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
            RedisUtil.returnResource(jedis);
        }finally{
            RedisUtil.returnResource(jedis);
        }
    }

}