/**
 * Redis數(shù)據(jù)庫(kù)操作，超賣(mài)問(wèn)題模擬
 * @author 
 *
 */
@RestController
public class RedisController {
	
	// 引入String類型redis操作模板
	@Autowired
	private StringRedisTemplate stringRedisTemplate;
 
 
	// 測(cè)試數(shù)據(jù)設(shè)置接口
	@RequestMapping("/setStock")
	public String setStock() {
		stringRedisTemplate.opsForValue().set("stock", "100");
		return "ok";
	}
	
	// 模擬商品超賣(mài)代碼
	@RequestMapping("/deductStock")
	public String deductStock() {
		// 獲取Redis數(shù)據(jù)庫(kù)中的商品數(shù)量
		Integer stock = Integer.parseInt(stringRedisTemplate.opsForValue().get("stock"));
		// 減庫(kù)存
		if(stock > 0) {
			int realStock = stock -1;
			stringRedisTemplate.opsForValue().set("stock", String.valueOf(realStock));
			System.out.println("商品扣減成功，剩余商品："+realStock);
		}else {
			System.out.println("庫(kù)存不足.....");
		}
		return "end";
	}
}

    // 模擬商品超賣(mài)代碼,
	// 設(shè)置synchronized同步鎖
	@RequestMapping("/deductStock1")
	public String deductStock1() {
		synchronized (this) {
			// 獲取Redis數(shù)據(jù)庫(kù)中的商品數(shù)量
			Integer stock = Integer.parseInt(stringRedisTemplate.opsForValue().get("stock"));
			// 減庫(kù)存
			if(stock > 0) {
				int realStock = stock -1;
				stringRedisTemplate.opsForValue().set("stock", String.valueOf(realStock));
				System.out.println("商品扣減成功，剩余商品："+realStock);
			}else {
				System.out.println("庫(kù)存不足.....");
			}
		}
		return "end";
	}

// 模擬商品超賣(mài)代碼
	@RequestMapping("/deductStock2")
	public String deductStock2() {
		// 創(chuàng)建一個(gè)key，保存至redis
		String key = "lock";
		// setnx
		// 由于redis是一個(gè)單線程，執(zhí)行命令采取“隊(duì)列”形式排隊(duì)！
		// 優(yōu)先進(jìn)入隊(duì)列的命令先執(zhí)行，由于是setnx，第一個(gè)執(zhí)行后，其他操作執(zhí)行失敗。
		boolean result = stringRedisTemplate.opsForValue().setIfAbsent(key, "this is lock");
		// 當(dāng)不存在key時(shí)，可以設(shè)置成功，回執(zhí)true；如果存在key，則無(wú)法設(shè)置，返回false
		if (!result) {
			// 前端監(jiān)測(cè)，redis中存在，則不能讓這個(gè)搶購(gòu)操作執(zhí)行，予以提示！
			return "err";
		}
		
		// 獲取Redis數(shù)據(jù)庫(kù)中的商品數(shù)量
		Integer stock = Integer.parseInt(stringRedisTemplate.opsForValue().get("stock"));
		// 減庫(kù)存
		if(stock > 0) {
			int realStock = stock -1;
			stringRedisTemplate.opsForValue().set("stock", String.valueOf(realStock));
			System.out.println("商品扣減成功，剩余商品："+realStock);
		}else {
			System.out.println("庫(kù)存不足.....");
		}
 
        // 程序執(zhí)行完成，則刪除這個(gè)key
		stringRedisTemplate.delete(key);
 
		return "end";
	}

/**
	 * 模擬商品超賣(mài)代碼 設(shè)置
	 *
	 * @return
	 */
	@RequestMapping("/deductStock3")
	public String deductStock3() {
		// 創(chuàng)建一個(gè)key，保存至redis
		String key = "lock";
		// setnx
		// 由于redis是一個(gè)單線程，執(zhí)行命令采取隊(duì)列形式排隊(duì)！優(yōu)先進(jìn)入隊(duì)列的命令先執(zhí)行，由于是setnx，第一個(gè)執(zhí)行后，其他操作執(zhí)行失敗
		boolean result = stringRedisTemplate.opsForValue().setIfAbsent(key, "this is lock");
		// 當(dāng)不存在key時(shí)，可以設(shè)置成功，回執(zhí)true；如果存在key，則無(wú)法設(shè)置，返回false
		if (!result) {
			// 前端監(jiān)測(cè)，redis中存在，則不能讓這個(gè)搶購(gòu)操作執(zhí)行，予以提示！
			return "err";
		}
 
		try {
			// 獲取Redis數(shù)據(jù)庫(kù)中的商品數(shù)量
			Integer stock = Integer.parseInt(stringRedisTemplate.opsForValue().get("stock"));
			// 減庫(kù)存
			if (stock > 0) {
				int realStock = stock - 1;
				stringRedisTemplate.opsForValue().set("stock", String.valueOf(realStock));
				System.out.println("商品扣減成功，剩余商品：" + realStock);
			} else {
				System.out.println("庫(kù)存不足.....");
			}
		} finally {
			// 程序執(zhí)行完成，則刪除這個(gè)key
			// 放置于finally中，保證即使上述邏輯出問(wèn)題，也能del掉
			stringRedisTemplate.delete(key);
		}
 
		return "end";
	}

/**
	 * 模擬商品超賣(mài)代碼 設(shè)置setnx保證分布式環(huán)境下，數(shù)據(jù)處理安全行問(wèn)題；<br>
	 * 但如果某個(gè)代碼段執(zhí)行異常，導(dǎo)致key無(wú)法清理，出現(xiàn)死鎖，添加try...finally;<br>
	 * 如果某個(gè)服務(wù)因某些問(wèn)題導(dǎo)致釋放key不能執(zhí)行，導(dǎo)致死鎖，此時(shí)解決思路為：增加key的有效時(shí)間;<br>
	 * 為了保證設(shè)置key的值和設(shè)置key的有效時(shí)間，兩條命令構(gòu)成同一條原子命令，將下列邏輯換成其他代碼。
	 *
	 * @return
	 */
	@RequestMapping("/deductStock4")
	public String deductStock4() {
		// 創(chuàng)建一個(gè)key，保存至redis
		String key = "lock";
		// setnx
		// 由于redis是一個(gè)單線程，執(zhí)行命令采取隊(duì)列形式排隊(duì)！優(yōu)先進(jìn)入隊(duì)列的命令先執(zhí)行，由于是setnx，第一個(gè)執(zhí)行后，其他操作執(zhí)行失敗
		//boolean result = stringRedisTemplate.opsForValue().setIfAbsent(key, "this is lock");
 
		//讓設(shè)置key和設(shè)置key的有效時(shí)間都可以同時(shí)執(zhí)行
		boolean result = stringRedisTemplate.opsForValue().setIfAbsent(key, "this is lock", 10, TimeUnit.SECONDS);
 
		// 當(dāng)不存在key時(shí)，可以設(shè)置成功，回執(zhí)true；如果存在key，則無(wú)法設(shè)置，返回false
		if (!result) {
			// 前端監(jiān)測(cè)，redis中存在，則不能讓這個(gè)搶購(gòu)操作執(zhí)行，予以提示！
			return "err";
		}
		// 設(shè)置key有效時(shí)間
		//stringRedisTemplate.expire(key, 10, TimeUnit.SECONDS);
 
		try {
			// 獲取Redis數(shù)據(jù)庫(kù)中的商品數(shù)量
			Integer stock = Integer.parseInt(stringRedisTemplate.opsForValue().get("stock"));
			// 減庫(kù)存
			if (stock > 0) {
				int realStock = stock - 1;
				stringRedisTemplate.opsForValue().set("stock", String.valueOf(realStock));
				System.out.println("商品扣減成功，剩余商品：" + realStock);
			} else {
				System.out.println("庫(kù)存不足.....");
			}
		} finally {
			// 程序執(zhí)行完成，則刪除這個(gè)key
			// 放置于finally中，保證即使上述邏輯出問(wèn)題，也能del掉
			stringRedisTemplate.delete(key);
		}
 
		return "end";
	}

/**
	 * 模擬商品超賣(mài)代碼 <br>
	 * 解決`deductStock6`中，key形同虛設(shè)的問(wèn)題。
	 *
	 * @return
	 */
	@RequestMapping("/deductStock5")
	public String deductStock5() {
		// 創(chuàng)建一個(gè)key，保存至redis
		String key = "lock";
		String lock_value = UUID.randomUUID().toString();
		// setnx
		//讓設(shè)置key和設(shè)置key的有效時(shí)間都可以同時(shí)執(zhí)行
		boolean result = stringRedisTemplate.opsForValue().setIfAbsent(key, lock_value, 10, TimeUnit.SECONDS);
		// 當(dāng)不存在key時(shí)，可以設(shè)置成功，回執(zhí)true；如果存在key，則無(wú)法設(shè)置，返回false
		if (!result) {
			// 前端監(jiān)測(cè)，redis中存在，則不能讓這個(gè)搶購(gòu)操作執(zhí)行，予以提示！
			return "err";
		}
		try {
			// 獲取Redis數(shù)據(jù)庫(kù)中的商品數(shù)量
			Integer stock = Integer.parseInt(stringRedisTemplate.opsForValue().get("stock"));
			// 減庫(kù)存
			if (stock > 0) {
				int realStock = stock - 1;
				stringRedisTemplate.opsForValue().set("stock", String.valueOf(realStock));
				System.out.println("商品扣減成功，剩余商品：" + realStock);
			} else {
				System.out.println("庫(kù)存不足.....");
			}
		} finally {
			// 程序執(zhí)行完成，則刪除這個(gè)key
			// 放置于finally中，保證即使上述邏輯出問(wèn)題，也能del掉
 
			// 判斷redis中該數(shù)據(jù)是否是這個(gè)接口處理時(shí)的設(shè)置的，如果是則刪除
			if(lock_value.equalsIgnoreCase(stringRedisTemplate.opsForValue().get(key))) {
				stringRedisTemplate.delete(key);
			}
		}
		return "end";
	}

@Component
public class RedisLock {
    private final Logger log = LoggerFactory.getLogger(this.getClass());
 
    private final long acquireTimeout = 10*1000;    // 獲取鎖之前的超時(shí)時(shí)間(獲取鎖的等待重試時(shí)間)
    private final int timeOut = 20;   // 獲取鎖之后的超時(shí)時(shí)間(防止死鎖)
 
    @Autowired
    private StringRedisTemplate stringRedisTemplate;  // 引入String類型redis操作模板
 
    /**
     * 獲取分布式鎖
     * @return 鎖標(biāo)識(shí)
     */
    public boolean getRedisLock(String lockName,String lockValue) {
        // 1.計(jì)算獲取鎖的時(shí)間
        Long endTime = System.currentTimeMillis() + acquireTimeout;
        // 2.嘗試獲取鎖
        while (System.currentTimeMillis() < endTime) {
            //3. 獲取鎖成功就設(shè)置過(guò)期時(shí)間 讓設(shè)置key和設(shè)置key的有效時(shí)間都可以同時(shí)執(zhí)行
            boolean result = stringRedisTemplate.opsForValue().setIfAbsent(lockName, lockValue, timeOut, TimeUnit.SECONDS);
            if (result) {
                return true;
            }
        }
        return false;
    }
 
 
    /**
     * 釋放分布式鎖
     * @param lockName 鎖名稱
     * @param lockValue 鎖值
     */
    public void unRedisLock(String lockName,String lockValue) {
        if(lockValue.equalsIgnoreCase(stringRedisTemplate.opsForValue().get(lockName))) {
            stringRedisTemplate.delete(lockName);
        }
    }
}

@RestController
public class RedisController {
	
	// 引入String類型redis操作模板
	@Autowired
	private StringRedisTemplate stringRedisTemplate;
	@Autowired
	private RedisLock redisLock;
 
 
	@RequestMapping("/setStock")
	public String setStock() {
		stringRedisTemplate.opsForValue().set("stock", "100");
		return "ok";
	}
 
	@RequestMapping("/deductStock")
	public String deductStock() {
		// 創(chuàng)建一個(gè)key，保存至redis
		String key = "lock";
		String lock_value = UUID.randomUUID().toString();
		try {
			boolean redisLock = this.redisLock.getRedisLock(key, lock_value);//獲取鎖
			if (redisLock)
			{
				// 獲取Redis數(shù)據(jù)庫(kù)中的商品數(shù)量
				Integer stock = Integer.parseInt(stringRedisTemplate.opsForValue().get("stock"));
				// 減庫(kù)存
				if (stock > 0) {
					int realStock = stock - 1;
					stringRedisTemplate.opsForValue().set("stock", String.valueOf(realStock));
					System.out.println("商品扣減成功，剩余商品：" + realStock);
				} else {
					System.out.println("庫(kù)存不足.....");
				}
			}
		} finally {
			redisLock.unRedisLock(key,lock_value);   //釋放鎖
		}
		return "end";
	}
}