接口冪等性的設(shè)計(jì)之————redis分布式鎖的應(yīng)用

在集群分布式機(jī)器部署的前提下，接口在相同數(shù)據(jù)高并發(fā)的情況下如果沒有唯一索引的情況下，可能會(huì)有一些問題。

比如：

插入或更新商品的接口，如果沒有則插入，有則更新的接口。支持多次修改。

考慮一種情況，前端頁面第一次提交時(shí)瞬間點(diǎn)擊多次。這種情況下會(huì)先去數(shù)據(jù)庫查詢，然后再插入。（當(dāng)然唯一索引也可以解決，但是這種的有一次提交將會(huì)被拒絕）。

所有分布式鎖的使用場景可以類比于以前使用sychronized的場景，java自己的鎖只適用于單jvm的場景，在多jvm的時(shí)候只能用分布式鎖來解決。

下面看下簡單的使用

/*** * @param lockName 鎖名稱* @param acquireTimeout 等待獲取鎖時(shí)間* @param lockTimeout 鎖超時(shí)時(shí)間* @return*/ public String acquireRedisLock(String lockName, long acquireTimeout, long lockTimeout) {Jedis jedis = getRedisResource();if (jedis == null) {logger.error("get resource failed");return null;}String identifier = UUID.randomUUID().toString();String lockKey =lockName;int lockExpire = (int)(lockTimeout / 1000);try {long end = System.currentTimeMillis() + acquireTimeout;while (System.currentTimeMillis() < end) {if (jedis.setnx(lockKey, identifier) == 1){jedis.expire(lockKey, lockExpire);return identifier;}if (jedis.ttl(lockKey) == -1) {jedis.expire(lockKey, lockExpire);}try {Thread.sleep(1);}catch(InterruptedException ie){Thread.currentThread().interrupt();}}} catch (Exception e) {logger.error("acquireLockWithFullLockKey 獲取分布式鎖出現(xiàn)問題，",e);} finally {jedis.close();}// null indicates that the lock was not acquiredreturn null; }/*** 釋放分布式鎖* @param lockName* @param identifier* @return*/ public boolean releaseLock(String lockName, String identifier) {Jedis jedis = getRedisResource();String lockKey = lockName;try {while (true){jedis.watch(lockKey);if (identifier.equals(jedis.get(lockKey))){Transaction trans = jedis.multi();trans.del(lockKey);List<Object> results = trans.exec();if (results == null){continue;}return true;}jedis.unwatch();break;}} catch (Exception e) {logger.error("releaseLock 釋放分布式鎖出現(xiàn)問題，",e);} finally {jedis.close();}return false; }

釋放的時(shí)候用到了redis的watch命令和multi，exec，主要是事務(wù)方面操作，防止被key的值修改后刪除。和jedis.get出來的值不一樣。

redis的操作可以見我博客后續(xù)關(guān)于redis的文章。

這兩個(gè)方法有了之后，一個(gè)redis分布式鎖就好了，來看看使用：

public void runAmethod() {String lockId = lock.acquireLock("get", 2000, 5000);boolean isLock = StringUtils.isNotBlank(lockId);if (isLock) {System.out.println("執(zhí)行方法============");} else {logger.error("未獲取到redis鎖，不能執(zhí)行");}if (null != lockId) {lock.releaseLock("get", lockId);} }

使用時(shí)直接這樣，鎖名字每個(gè)方法應(yīng)該不同，鎖獲取時(shí)間根據(jù)方法一般執(zhí)行時(shí)間設(shè)置，超時(shí)時(shí)間應(yīng)該要考慮到吞吐量和接口的最長執(zhí)行時(shí)間。太長了吞吐量不夠，太短了可能會(huì)導(dǎo)致并發(fā)問題。

后續(xù)，如果要進(jìn)一步封裝可以這樣:

首先定義一個(gè)接口

package com.service;public interface RedisLockMethod {void runMethod();}

然后使用：

先看無鎖情況下：

public void test() {noLockMethod(); }private void noLockMethod() {System.out.println("我是之前無鎖的方法"); }

test方法里面的方法現(xiàn)在要加分布式鎖處理，該怎么操作呢？

public void test() {//1，lamda寫法runAmethod(()->noLockMethod());//2，匿名內(nèi)部類寫法runAmethod(new RedisLockMethod() {@Overridepublic void runMethod() {//原有的方法noLockMethod();}});} private void noLockMethod() {System.out.println("我是之前無鎖的方法"); }public void runAmethod(RedisLockMethod aaa){String lockId = lock.acquireLock("get", 2000, 5000);boolean isLock = StringUtils.isNotBlank(lockId);if (isLock) {aaa.runMethod();} else {logger.error("未獲取到redis鎖，不能執(zhí)行");}if (null != lockId) {lock.releaseLock("get", lockId);} }

提供了兩種方法，比較推薦lamda寫法。這種寫法下runAmethod()這個(gè)方法可以抽取出來作為公共的方法，所有需要分布式鎖的時(shí)候直接調(diào)用即可，里面封裝要鎖的方法即可。

總結(jié)

以上是生活随笔為你收集整理的接口幂等性的设计之————redis分布式锁的应用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。