※評比南投搬家公司費用收費行情懶人包大公開
搬家價格與搬家費用透明合理，不亂收費。本公司提供下列三種搬家計費方案，由資深專業組長到府估價，替客戶量身規劃選擇最經濟節省的計費方式
目錄
- 原理剖析
- 實現
- 編寫註解
- 攔截器攔截
- 上述提及工具
- RedisLock
- StockKeyGenerator
- 問題分析
- 業務處理時間>上鎖過期時間
※智慧手機時代的來臨，RWD網頁設計為架站首選
網動結合了許多網際網路業界的菁英共同研發簡單易操作的架站工具，及時性的更新，為客戶創造出更多的網路商機。
系統的不斷擴大，分佈式鎖是最基本的保障。與單機的多線程不一樣的是，分佈式跨多個機器。線程的共享變量無法跨機器。
為了保證一個在高併發存場景下只能被同一個線程操作，java併發處理提供ReentrantLock或Synchronized進行互斥控制。但是這僅僅對單機環境有效。我們實現分佈式鎖大概通過三種方式。
- redis實現分佈式鎖
- 數據庫實現分佈式鎖
- zk實現分佈式鎖
今天我們介紹通過redis實現分佈式鎖。實際上這三種和java對比看屬於一類。都是屬於程序外部鎖。
原理剖析
- 上述三種分佈式鎖都是通過各自為依據對各個請求進行上鎖，解鎖從而控制放行還是拒絕。redis鎖是基於其提供的setnx命令。
- setnx當且僅當key不存在。若給定key已經存在，則setnx不做任何動作。setnx是一個原子性操作。
- 和數據庫分佈式相比，因為redis內存輕量。所以redis分佈式鎖性能更好
實現
- 原理很簡單。結合springboot項目我們實現一套通過註解形式對接口進行庫存上鎖案例進行理解
編寫註解
- 我們編寫註解。方便我們在接口上添加註解提供攔截信息
/**
* @author 張新華
* @version V1.0
* @Package com.ay.framework.order.redis.product
* @date 2020年03月26日, 0026 10:29
* @Copyright © 2020 安元科技有限公司
*/
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
public @interface StockLock {
/**
* @author zxhtom
* @Description 鎖key的前綴
* @Date 15:25 2020年03月25日, 0025
* @Param []
* @return java.lang.String
*/
String prefix() default "";
/**
* @author zxhtom
* @Description key的分隔符
* @Date 15:27 2020年03月25日, 0025
* @Param []
* @return java.lang.String
*/
String delimiter() default ":";
}
/**
* @author 張新華
* @version V1.0
* @Package com.ay.framework.order.redis.product
* @date 2020年03月26日, 0026 11:09
* @Copyright © 2020 安元科技有限公司
*/
@Target({ElementType.PARAMETER , ElementType.METHOD , ElementType.FIELD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
public @interface StockParam {
/**
* @author zxhtom
* @Description 組成key
* @Date 11:11 2020年03月26日, 0026
* @Param []
* @return java.lang.String[]
*/
String[] names() default {""};
}
攔截器攔截
- redis分佈式鎖實現的關鍵就是攔截器的編寫。上面的註解只是為了實現攔截的一個輔助。
@Around("execution(public * *(..)) && @annotation(com.ay.framework.order.redis.product.StockLock)")
- 通過springboot的Around進行針對StockLock註解的攔截。通過攔截我們可以獲取到攔截的方法、參數、及需要的鎖的參數。
- 我們獲取到需要鎖的名稱這裏叫做【a】之後通過redis的原子性操作對該key進行遞減操作。
- 為了方便我們在削減庫存的時候可以對庫存進行更新操作。我們在遞減庫存前還需要藉助於另一把鎖。 這一把鎖我們叫做【a_key】
- 換句話說我們接口想訪問就必須獲取【a】鎖，拿到【a】鎖需要減少庫存。減少庫存之前需要獲取【a_key】鎖。
- 拿到鎖之後處理完邏輯之後我們需要釋放對應鎖。
RedisAtomicLong entityIdCounter = new RedisAtomicLong(lockKey, redisTemplate.getConnectionFactory());
if (redisTemplate.hasKey(CoreConstants.UPDATEPRODUCTREDISLOCKKEY + lockKey)) {
//表示lockKey的庫存信息有變動。此時無法進行交易
throw new BusinessException("庫存變動。暫無法交易");
}
Long increment = entityIdCounter.decrementAndGet();
if (increment >= 0) {
try {
Object proceed = pjp.proceed();
} catch (Throwable throwable) {
//所佔資源需要釋放回資源池
while (!redisLock.tryGetLock(CoreConstants.UPDATEPRODUCTREDISLOCKKEY + lockKey, "")) {
}
//表示lockKey的庫存信息有變動。此時無法進行交易
long l = entityIdCounter.incrementAndGet();
if (l < 1) {
redisTemplate.opsForValue().set(lockKey,1);
}
redisLock.unLock(CoreConstants.UPDATEPRODUCTREDISLOCKKEY + lockKey);
throwable.printStackTrace();
}
} else {
redisTemplate.opsForValue().set(lockKey,0);
throw new BusinessException("庫存不足！無法操作");
}
- 因為我們上鎖就需要釋放鎖。但是程序在中途處理業務是發生異常導致沒有走到釋放鎖的步驟。這個時候就導致我們的分佈式鎖一直被鎖。俗稱【死鎖】。為了避免這種場景的發生。我們常常在上鎖的時候給一個有效期。有效期已過自動釋放鎖。這個特性恰好和redis的過期策略不摩爾和。
上述提及工具
RedisLock
public Boolean tryGetLock(String key , String value) {
return tryGetLock(key, value, -1, TimeUnit.DAYS);
}
public Boolean tryGetLock(String key , String value, Integer expire) {
return tryGetLock(key, value, expire, TimeUnit.SECONDS);
}
public Boolean tryGetLock(String key , String value, Integer expire , TimeUnit timeUnit) {
ValueOperations operations = redisTemplate.opsForValue();
if (operations.setIfAbsent(key, value)) {
//說明 redis沒有該key , 換言之 加鎖成功 設置過期時間防止死鎖
if (expire > 0) {
redisTemplate.expire(key, expire, timeUnit);
}
return true;
}
return false;
}
public Boolean unLock(String key) {
return redisTemplate.delete(key);
}
StockKeyGenerator
@Component()
@Primary
public class StockKeyGenerator implements CacheKeyGenerator {
@Override
public String getLockKey(ProceedingJoinPoint pjp) {
//獲取方法簽名
MethodSignature signature = (MethodSignature) pjp.getSignature();
Method method = signature.getMethod();
//獲取方法cacheLock註解
StockLock stockLock = method.getAnnotation(StockLock.class);
//獲取方法參數
Object[] args = pjp.getArgs();
Parameter[] parameters = method.getParameters();
StringBuilder builder = new StringBuilder();
for (int i = 0; i < parameters.length; i++) {
StockParam stockParam = parameters[i].getAnnotation(StockParam.class);
Object arg = args[i];
if (arg instanceof Map) {
Map<String, Object> temArgMap = (Map<String, Object>) arg;
String[] names = stockParam.names();
for (String name : names) {
if (builder.length() > 0) {
builder.append(stockLock.delimiter());
}
builder.append(temArgMap.get(name));
}
}
}
return builder.toString();
}
}
問題分析
- 上面分析了一個死鎖的場景，理論上出了死鎖我們redis分佈鎖很好的解決了分佈式問題。但是還是會出現問題。下面列舉寫小編遇到的問題。
業務處理時間>上鎖過期時間
- a線程獲取到鎖，開始進行業務處理需要8S，
- 在8S內，鎖的有效期是5S，在鎖過期后也就是第6S ， b線程進入開始獲取鎖這個時候b是可以獲取到新鎖的。這個時候就是有問題的。
- 假設b線程業務處理只需要3S ， 但是因為a線程釋放了鎖，所以在第8S的時候雖然b線程沒有釋放鎖，b的鎖也沒有過期但是這時候也沒有了鎖。從而導致C線程也可以進入
本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理
※回頭車貨運收費標準
宇安交通關係企業，自成立迄今，即秉持著「以誠待人」、「以實處事」的企業信念