eval "return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}" 2 key1 key2 arg1 arg2

eval: 腳本執(zhí)行命令
 
"return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}": 腳本內(nèi)容

2: key數(shù)量 

key1 key2 arg1 arg2: key和value的值  角標(biāo)從1開(kāi)始

因?yàn)閚umkeys數(shù)量為2，故key1 key2 為key， arg1 arg2為value

127.0.0.1:6379> eval "return redis.call('set',KEYS[1],'liulianJAVA')" 1 name
OK
127.0.0.1:6379> get name
"liulianJAVA"
127.0.0.1:6379>

127.0.0.1:6379> eval "return redis.call('set',KEYS[1], ARGV[1])" 1 name LIULIANJAVA
OK
127.0.0.1:6379> get name
"LIULIANJAVA"
127.0.0.1:6379>

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.6.1</version>
</dependency>

import redis.clients.jedis.Jedis;

public class JedisExample {

    public static void main(String[] args) {
        // 創(chuàng)建一個(gè)Jedis連接實(shí)例，連接到Redis服務(wù)器，默認(rèn)端口為6379
        Jedis jedis = new Jedis("localhost", 6379);
        jedis.auth("liulianJAVA");
        // 執(zhí)行一些Redis操作
        jedis.set("myKey", "Hello, Redis!");
        String value = jedis.get("myKey");
        System.out.println("Value for 'myKey': " + value);
        // 關(guān)閉連接
        jedis.close();
    }
}

public static boolean acquireLock(Jedis jedis, String lockName, int lockTimeout) {
        String luaScript = "if redis.call('set', KEYS[1], ARGV[1], 'NX', 'EX', ARGV[2]) then return 1 else return 0 end";
        Object result = jedis.eval(luaScript, 1, lockName, LOCK_VALUE, String.valueOf(lockTimeout));
        return result != null && "1".equals(result.toString());
    }

獲取鎖所需參數(shù):
jedis: redis連接   
lockName: 鎖名稱(chēng) 
lockTimeout: 鎖超時(shí)時(shí)間

public static void releaseLock(Jedis jedis, String lockName) {
    jedis.del(lockName);
}

釋放鎖所需參數(shù): 
jedis: redis連接   
lockName:  鎖名稱(chēng)

import redis.clients.jedis.Jedis;

public class LockUtil {
    private static final String LOCK_VALUE = "locked"; // 鎖的值

    // 獲取鎖 所需參數(shù):jedis:redis連接信息    lockName: 鎖名稱(chēng) lockTimeout: 鎖超時(shí)時(shí)間
    public static boolean acquireLock(Jedis jedis, String lockName, int lockTimeout) {
        String luaScript = "if redis.call('set', KEYS[1], ARGV[1], 'NX', 'EX', ARGV[2]) then return 1 else return 0 end";
        Object result = jedis.eval(luaScript, 1, lockName, LOCK_VALUE, String.valueOf(lockTimeout));
        return result != null && "1".equals(result.toString());
    }

    public static boolean acquireLockWithRetry(Jedis jedis, String LOCK_KEY, int maxRetrySeconds) {
        long startTime = System.currentTimeMillis();
        while (true) {
            long currentTime = System.currentTimeMillis();
            if (currentTime - startTime >= maxRetrySeconds * 1000L) {
                // 超過(guò)預(yù)設(shè)的秒數(shù)，返回獲取失敗
                return false;
            }

            // 嘗試獲取鎖
            boolean lockAcquired = acquireLock(jedis,LOCK_KEY, 60000);
            if (lockAcquired) {
                return true; // 成功獲取鎖
            }

            // 等待一段時(shí)間后重試
            try {
                Thread.sleep(100); // 100毫秒后重試
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                return false; // 線(xiàn)程被中斷，返回獲取失敗
            }
        }
    }


    // 釋放鎖所需參數(shù): jedis: redis連接   lockName: 鎖名稱(chēng)
    public static void releaseLock(Jedis jedis, String lockName) {
        jedis.del(lockName);
    }
}

import java.util.ArrayList;

public class Test {

    private static Integer number = 10000;

    public static void main(String[] args) {

        ArrayList<Thread> threads = new ArrayList<>();
        for (int i = 0; i < 10000; i ++){
            threads.add(new Thread(()-> Test.number = Test.number -1));
        }

        for (int i = 0; i < 10000; i ++){
            threads.get(i).start();
        }

        threads.forEach(thread -> {
            try {
                thread.join();
            } catch (InterruptedException ignored) {
            }
        });
         System.out.println("number結(jié)果: " + number);

    }
}

number結(jié)果: 241

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

import java.util.ArrayList;
import java.util.List;

public class DistributedLockExample {

    private static Integer number = 1000;

    public static void main(String[] args) {
        List<Thread> threads = new ArrayList<>();
        // 創(chuàng)建Jedis連接池
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        poolConfig.setMaxTotal(1000);
        JedisPool jedisPool = new JedisPool(poolConfig, "127.0.0.1", 6379, 200000, "liulian");
        String lockName = "liulian";


        for (int i = 0; i < 1000 ; i++){
            threads.add(new Thread(() -> {
                try (Jedis jedis = jedisPool.getResource()) {
                    // 獲取鎖
                    boolean lockAcquired = LockUtil.acquireLockWithRetry(jedis, lockName, 600);
                    if (lockAcquired) {
                        try {
                            // 在鎖內(nèi)執(zhí)行關(guān)鍵操作
                            number = number - 1;
                        } finally {
                            // 釋放鎖
                            LockUtil.releaseLock(jedis, lockName);
                        }
                    } else {
                        System.out.println("Failed to acquire lock.");
                    }
                }
            }));
        }

        threads.forEach(Thread::start);

        threads.forEach(thread -> {
            try {
                thread.join();
            } catch (InterruptedException ignored) {
            }
        });

        System.out.println("number結(jié)果: " + number);

        // 關(guān)閉Jedis連接池
        jedisPool.close();
    }

    private static void performCriticalOperation() {
        // 在這里執(zhí)行關(guān)鍵操作，例如訪(fǎng)問(wèn)共享資源或執(zhí)行任務(wù)
        System.out.println("Critical operation performed.");
    }
}

number結(jié)果: 0