。

添加用户锁#xff0c;在用户第二次点击按钮时#xff0c;拦击用…用户锁的作用

秒杀、支付等场景用户频繁点击按钮会造成同一时刻调用多次接口【第一次请求接口还没响应数据用户又进行了第二次请求】造成数据异常和网络拥堵。

添加用户锁在用户第二次点击按钮时拦击用户请求。

限制用户在操作未完成前不能再进行下一次相同操作

1.主要组成

RedisDistributedUserLock分布式锁实现类

DistributedUserLockAspect切面类【核心】

自定义锁注解利用切面给所有加注解的方法加分布式锁防止用户重复点击按钮。

2.关键代码分析

DistributedUserLockAspect用redis的setIfAbsent

Around(annotation(com.nascent.ecrp.mall.common.distribute.Dul))public

Object

distributedLock(ProceedingJoinPoint

proceedingJoinPoint)

proceedingJoinPoint.proceed();}String

token

proceedingJoinPoint.proceed();}MethodSignature

methodSignature

proceedingJoinPoint.getSignature();Method

method

methodSignature.getMethod();String

lockKey

method.getDeclaringClass().getName()

method.getName();Dul

method.getAnnotation(Dul.class);int

lockTime

distributedKey.lockTimeSeconds();TimeUnit

timeUnit

USER_LOCK_KEY_OF_类名方法名token作为redis的keylockKey

token;try

(distributedUserLock.lock(lockKey,

lockTime,

proceedingJoinPoint.proceed();}

else

WmDefinitelyRuntimeException(操作过于频繁请稍后再试);}}

catch

{Thread.currentThread().interrupt();throw

new

WmDefinitelyRuntimeException(e);}

finally

{distributedUserLock.unlock(lockKey);}}3.全部代码

Dcl

Retention(RetentionPolicy.RUNTIME)

public

SuppressWarnings({UnusedReturnValue,

NullableProblems,

UnsupportedOperationException();}Overridepublic

void

InterruptedException();}Overridepublic

boolean

UnsupportedOperationException();}/***

param

InterruptedException*/Overridepublic

boolean

redisTemplate.opsForValue().get(lockKey);if

(obj

false;}redisTemplate.opsForValue().set(lockKey,

TYPE_LOCK,

加锁如果key不存在进行加锁如果key已经存在返回加锁失败return

redisTemplate.opsForValue().setIfAbsent(lockKey,

TYPE_LOCK,

UnsupportedOperationException();}/***

解锁*

{redisTemplate.delete(lockKey);}Overridepublic

void

UnsupportedOperationException();}SuppressWarnings(NullableProblems)Overridepublic

Condition

UnsupportedOperationException();}}DistributedUserLockAspect

/***

distributedUserLock;Autowiredprivate

HttpServletRequest

proceedingJoinPoint*/Around(annotation(com.nascent.ecrp.mall.common.distribute.Dul))public

Object

distributedLock(ProceedingJoinPoint

proceedingJoinPoint)

proceedingJoinPoint.proceed();}String

token

proceedingJoinPoint.proceed();}MethodSignature

methodSignature

proceedingJoinPoint.getSignature();Method

method

methodSignature.getMethod();String

lockKey

method.getDeclaringClass().getName()

method.getName();Dul

method.getAnnotation(Dul.class);int

lockTime

distributedKey.lockTimeSeconds();TimeUnit

timeUnit

USER_LOCK_KEY_OF_类名方法名token作为redis的keylockKey

token;try

(distributedUserLock.lock(lockKey,

lockTime,

proceedingJoinPoint.proceed();}

else

WmDefinitelyRuntimeException(操作过于频繁请稍后再试);}}

catch

{Thread.currentThread().interrupt();throw

new

WmDefinitelyRuntimeException(e);}

finally

{distributedUserLock.unlock(lockKey);}}

秒杀接口添加锁注解

秒杀活动开始用户点击按钮进行上锁lockTimeSeconds【默认10秒】内不能再点击lockTimeSeconds秒后自动释放锁。

/***

doSeckill(WmMarketingSeckillPostVo

seckillPostVo)

checkGoodsSeckillInfo(seckillPostVo.getSeckillOrderInfoList(),seckillPostVo.getShopId());if(checkResult.equals(ErrorCode.SECKILL_ACTIVITY_UPDATE.getCode())){return

new

CommonResult().setFailed().setCode(ErrorCode.SECKILL_ACTIVITY_UPDATE.getCode()).setMsg(活动状态已变更请重新下单);}ListJSONObject

seckillOrderList

ArrayList();//下单校验ListSecKillBuyInfo

buyInfos

ArrayList();SeckillOrderCheckRequest

new

SeckillOrderCheckRequest();seckillOrderCheckRequest.setCustomerId(getCustomerId());seckillOrderCheckRequest.setShopId(seckillPostVo.getShopId());for(WmMarketingSeckillPostVo.SeckillOrderInfo

seckillOrderInfo

seckillPostVo.getSeckillOrderInfoList()){SecKillBuyInfo

secKillBuyInfo

SecKillBuyInfo();secKillBuyInfo.setActivityId(seckillOrderInfo.getMarketingGuid());ListSeckillBuyGoodsInfo

seckillBuyGoodsInfos

ArrayList();SeckillBuyGoodsInfo

seckillBuyGoodsInfo

SeckillBuyGoodsInfo();seckillBuyGoodsInfo.setGoodsId(seckillOrderInfo.getGoodsId());seckillBuyGoodsInfo.setGoodsLibId(seckillOrderInfo.getGoodsLibId());ListSeckillBuySkuInfo

seckillBuySkuInfos

SeckillBuySkuInfo();seckillBuySkuInfo.setGoodsSkuId(StringUtil.isBlank(seckillOrderInfo.getGoodsSkuId())

seckillOrderInfo.getGoodsSkuId());seckillBuySkuInfo.setBuyCount(seckillOrderInfo.getGoodsNum());seckillBuySkuInfos.add(seckillBuySkuInfo);seckillBuyGoodsInfo.setSkuInfos(seckillBuySkuInfos);seckillBuyGoodsInfos.add(seckillBuyGoodsInfo);secKillBuyInfo.setGoodsList(seckillBuyGoodsInfos);buyInfos.add(secKillBuyInfo);}seckillOrderCheckRequest.setBuyInfos(buyInfos);seckillOrderCheckRequest.setGroupId(getGroupId());SeckillOrderCheckResponse

OpenPlatformClient.exec(getGroupId(),

seckillOrderCheckRequest);log.info(【调用中台下单校验接口响应结果】seckillOrderCheckResponseJSON.toJSONString(seckillOrderCheckResponse));if(!seckillOrderCheckResponse.successseckillOrderCheckResponse.getCode().equals(50402)){log.info(【秒杀下单已达限购上限】);return

new

CommonResult().setFailed().setCode(50402).setMsg(已达限购上限);}if(!seckillOrderCheckResponse.successseckillOrderCheckResponse.getCode().equals(50404)){log.info(【秒杀剩余库存不足】);return

new

CommonResult().setFailed().setCode(50404).setMsg(剩余库存不足);}if(!seckillOrderCheckResponse.successseckillOrderCheckResponse.getCode().equals(50005)){log.info(【秒杀活动已结束】);return

new

CommonResult().setFailed().setCode(50005).setMsg(活动已结束);}AssertUtil.assertTrue(seckillOrderCheckResponse.getSuccess()seckillOrderCheckResponse.getResult().isSeckillSuccess(),秒杀活动校验失败);MapString,ActivitySeckillCheckInfo

activityCheckInfoMap

HashMap();for(ActivitySeckillCheckInfo

seckillOrderCheckResponse.getResult().getCheckInfos()){Long

goodsId

activitySeckillCheckInfo.getItemInfos().get(0).getGoodsId();Long

goodsLibId

activitySeckillCheckInfo.getItemInfos().get(0).getGoodsLibId();String

skuId

activitySeckillCheckInfo.getItemInfos().get(0).getSkuInfos().get(0).getSkuId();//无sku也会返回到sku级skuid为0activityCheckInfoMap.put(activitySeckillCheckInfo.getActivityId()_goodsLibId_goodsId_skuId,activitySeckillCheckInfo);}MapString,

ItemDetailsInfo

getGoodsInfos(seckillPostVo.getShopId(),seckillPostVo.getSeckillOrderInfoList());Integer

expireMinute

seckillOrderCheckResponse.getResult().getExpireMinute();for(WmMarketingSeckillPostVo.SeckillOrderInfo

seckillOrderInfo

:seckillPostVo.getSeckillOrderInfoList()){ItemDetailsInfo

itemInfo

itemInfoMap.get(seckillOrderInfo.getGoodsId()_seckillOrderInfo.getGoodsLibId());Long

marketGuid

seckillOrderInfo.getMarketingGuid();Long

goodsId

seckillOrderInfo.getGoodsId();Long

goodsLibId

seckillOrderInfo.getGoodsLibId();String

goodsSkuId

seckillOrderInfo.getGoodsSkuId()null?0:seckillOrderInfo.getGoodsSkuId();//无sku也会返回到sku级skuid为0ActivitySeckillCheckInfo

activityCheckInfoMap.get(marketGuid_goodsLibId_goodsId_goodsSkuId);String

activityName

activitySeckillCheckInfo.getActivityName();//秒杀价BigDecimal

price

itemInfo.getPrice();for(ActivitySeckillCheckItemInfo

activitySeckillCheckInfo.getItemInfos()){if(activitySeckillCheckItemInfo.getGoodsId().longValue()

seckillOrderInfo.getGoodsId().longValue()

activitySeckillCheckItemInfo.getGoodsLibId().longValue()

seckillOrderInfo.getGoodsLibId().longValue()){for(ActivitySeckillCheckSkuInfo

seckillCheckSkuInfo

activitySeckillCheckItemInfo.getSkuInfos()){if(seckillCheckSkuInfo.getSkuId().equals(0)||seckillCheckSkuInfo.getSkuId().equals(seckillOrderInfo.getGoodsSkuId())){price

seckillCheckSkuInfo.getPrice();}}}}JSONObject

orderJson

createOrderDetail(marketGuid,activityName,expireMinute,seckillOrderInfo.getGoodsNum(),

goodsId,

itemInfo);seckillOrderList.add(orderJson);}return

new

CommonResult(seckillOrderList);}