multi

exec

discard

watch key [key…]

unwatch

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set s1 111
QUEUED
127.0.0.1:6379> hset set1 name zhangsan
QUEUED
127.0.0.1:6379> exec
1) OK
2) (integer) 1
127.0.0.1:6379> multi
OK
127.0.0.1:6379> set s2 222
QUEUED
127.0.0.1:6379> hset set2 age 20
QUEUED
127.0.0.1:6379> discard
OK
127.0.0.1:6379> exec (error) ERR EXEC without MULTI 
127.0.0.1:6379> watch s1
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> set s1 555
QUEUED 127.0.0.1:6379> exec # 此時在沒有exec之前，通過另一個命令窗口對監(jiān)控的s1字段進(jìn)行修改 
(nil)
127.0.0.1:6379> get s1
111

public void watch() {
	try {
		String watchKeys = "watchKeys";
		//初始值 value=1
		jedis.set(watchKeys, 1);
		//監(jiān)聽key為watchKeys的值
		jedis.watch(watchkeys);
		//開啟事務(wù)
		Transaction tx = jedis.multi();
		//watchKeys自增加一
		tx.incr(watchKeys);
		//執(zhí)行事務(wù)，如果其他線程對watchKeys中的value進(jìn)行修改，則該事務(wù)將不會執(zhí)行
		//通過redis事務(wù)以及watch命令實現(xiàn)樂觀鎖
		List<Object> exec = tx.exec();
		if (exec == null) {
			System.out.println("事務(wù)未執(zhí)行");
		} else {
			System.out.println("事務(wù)成功執(zhí)行，watchKeys的value成功修改");
		}
	} catch (Exception e) {
		e.printStackTrace();
	} finally {
		jedis.close();
	}
}

public class RedisLock {
    public static void main(String[] arg) {
        //庫存key 
        String redisKey = "stock";
        ExecutorService executorService = Executors.newFixedThreadPool(20);
        try {
            Jedis jedis = new RedisProperties.Jedis("127.0.0.1", 6378);
            // 可以被秒殺的庫存的初始值，庫存總共20個
            jedis.set(redisKey, "0");
            jedis.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
        for (int i = 0; i < 1000; i++) {
            executorService.execute(() -> {
                Jedis jedis1 = new Jedis("127.0.0.1", 6378);
                try {
                    jedis1.watch(redisKey);
                    String redisValue = jedis1.get(redisKey);
                    int valInteger = Integer.valueOf(redisValue);
                    String userInfo = UUID.randomUUID().toString();
                    // 沒有秒完
                    if (valInteger < 20) {
                        Transaction tx = jedis1.multi();
                        tx.incr(redisKey);
                        List list = tx.exec();
                        // 秒成功 失敗返回空list而不是空
                        if (list != null && list.size() > 0) {
                            System.out.println("用戶：" + userInfo + "，秒殺成 功！當(dāng)前成功人數(shù)：" + (valInteger + 1));
                        }
                        // 版本變化，被別人搶了。
                        else {
                            System.out.println("用戶：" + userInfo + "，秒殺失 敗");
                        }
                    }
                    // 秒完了
                    else {
                        System.out.println("已經(jīng)有20人秒殺成功，秒殺結(jié)束");
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    jedis1.close();
                }
            });
        }
        executorService.shutdown();
    }
}