SpringBoot中如何使用Redis作為全局鎖

這篇文章主要講解了“SpringBoot中如何使用Redis作為全局鎖”，文中的講解內(nèi)容簡(jiǎn)單清晰，易于學(xué)習(xí)與理解，下面請(qǐng)大家跟著小編的思路慢慢深入，一起來(lái)研究和學(xué)習(xí)“SpringBoot中如何使用Redis作為全局鎖”吧！

一、模擬沒(méi)有鎖情況下的資源競(jìng)爭(zhēng)

public class CommonConsumerService {
    //庫(kù)存?zhèn)€數(shù)
    static int goodsCount = 900;
    //賣(mài)出個(gè)數(shù)
    static int saleCount = 0;
    public static void main(String[] args) throws InterruptedException {
        for (int i = 0; i < 1000; i++) {
            new Thread(() -> {
                try {Thread.sleep(2);} catch (InterruptedException e) {}
                if (goodsCount > 0) {
                    goodsCount--;
                    System.out.println("剩余庫(kù)存：" + goodsCount + " 賣(mài)出個(gè)數(shù)" + ++saleCount);
                }
            }).start();
        }
        Thread.sleep(3000);
    }
}

運(yùn)行一次，最后幾行的輸出結(jié)果如下，很明顯出錯(cuò)了，剩余0個(gè)商品卻只賣(mài)出了899個(gè)商品，很明顯有商品被某個(gè)線程私吞了。

...
剩余庫(kù)存：5 賣(mài)出個(gè)數(shù)893
剩余庫(kù)存：5 賣(mài)出個(gè)數(shù)894
剩余庫(kù)存：4 賣(mài)出個(gè)數(shù)895
剩余庫(kù)存：2 賣(mài)出個(gè)數(shù)896
剩余庫(kù)存：2 賣(mài)出個(gè)數(shù)897
剩余庫(kù)存：1 賣(mài)出個(gè)數(shù)898
剩余庫(kù)存：0 賣(mài)出個(gè)數(shù)899

二、使用redis加鎖

redis是單線程的，串行執(zhí)行，那么接下來(lái)使用redis為資源進(jìn)行加鎖。

1.首先引入依賴

compile "org.springframework.boot:spring-boot-starter-data-redis"

2.引入redis加鎖工具類

package com.kingboy.common.utils;
import redis.clients.jedis.Jedis;
import java.util.Collections;
/**
 * @author kingboy--KingBoyWorld@163.com
 * @date 2017/12/29 下午1:57
 * @desc Redis工具.
 */
public class RedisTool {
    private static final String LOCK_SUCCESS = "OK";
    private static final String SET_IF_NOT_EXIST = "NX";
    private static final String SET_WITH_EXPIRE_TIME = "PX";
    private static final Long RELEASE_SUCCESS = 1L;
    /**
     * 嘗試獲取分布式鎖
     * @param jedis      Redis客戶端
     * @param lockKey    鎖
     * @param requestId  請(qǐng)求標(biāo)識(shí)
     * @param expireTime 超期時(shí)間
     * @return 是否獲取成功
     */
    public static boolean tryGetDistributedLock(Jedis jedis, String lockKey, String requestId, int expireTime) {
        String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime);
        if (LOCK_SUCCESS.equals(result)) {
            return true;
        }
        return false;
    }
    /**
     * 釋放分布式鎖
     * @param jedis     Redis客戶端
     * @param lockKey   鎖
     * @param requestId 請(qǐng)求標(biāo)識(shí)
     * @return 是否釋放成功
     */
    public static boolean releaseDistributedLock(Jedis jedis, String lockKey, String requestId) {
        String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
        Object result = jedis.eval(script, Collections.singletonList(lockKey), Collections.singletonList(requestId));
        if (RELEASE_SUCCESS.equals(result)) {
            return true;
        }
        return false;
    }
}

3.將上面沒(méi)有鎖的示例代碼改編如下：

public class RedisLockConsumerService {
    //庫(kù)存?zhèn)€數(shù)
    static int goodsCount = 900;
    //賣(mài)出個(gè)數(shù)
    static int saleCount = 0;
    @SneakyThrows
    public static void main(String[] args) {
        JedisPool jedisPool = new JedisPool(new JedisPoolConfig(), "192.168.0.130", 6379, 1000);
        for (int i = 0; i < 1000; i++) {
            new Thread(() -> {
                try {Thread.sleep(2);} catch (InterruptedException e) {}
                Jedis jedis = jedisPool.getResource();
                boolean lock = false;
                while (!lock) {
                    lock = RedisTool.tryGetDistributedLock(jedis, "goodsCount", Thread.currentThread().getName(), 10);
                }
                if (lock) {
                    if (goodsCount > 0) {
                        goodsCount--;
                        System.out.println("剩余庫(kù)存：" + goodsCount + " 賣(mài)出個(gè)數(shù)" + ++saleCount);
                    }
                }
                RedisTool.releaseDistributedLock(jedis, "goodsCount", Thread.currentThread().getName());
                jedis.close();
            }).start();
        }
        Thread.sleep(3000);
        jedisPool.close();
    }
}

執(zhí)行幾次程序輸出結(jié)果如下，可以看到結(jié)果是有序，并且正確的。

...
剩余庫(kù)存：6 賣(mài)出個(gè)數(shù)894
剩余庫(kù)存：5 賣(mài)出個(gè)數(shù)895
剩余庫(kù)存：4 賣(mài)出個(gè)數(shù)896
剩余庫(kù)存：3 賣(mài)出個(gè)數(shù)897
剩余庫(kù)存：2 賣(mài)出個(gè)數(shù)898
剩余庫(kù)存：1 賣(mài)出個(gè)數(shù)899
剩余庫(kù)存：0 賣(mài)出個(gè)數(shù)900

感謝各位的閱讀，以上就是“SpringBoot中如何使用Redis作為全局鎖”的內(nèi)容了，經(jīng)過(guò)本文的學(xué)習(xí)后，相信大家對(duì)SpringBoot中如何使用Redis作為全局鎖這一問(wèn)題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！