干货!java项目分布式锁实现高并发
关于java高并发的实现方式
关于并发的实现方式,结合项目中的实际问题 场景描述:一个电商的商城,用户购买商品进行下单,请求下单接口,会产生并发。 解决方式三部曲: 第一步:基于redis缓存,订单号和对应业务标识作为key 缓存,失效时间根据自己业务的场景是否进行使用 第二步:分布式锁,在微服务下保证幂等,这里特别要注意的是锁的加锁需要设置过期时间,释放问题需要按照每个请求clientId进行解锁 具体步骤如下: //每个请求标识clentId通过UUDID生成 String clientId=UUID.randomUUID().toString(); key:orderId+业务编码+商户Id(可选用其他维度) 基于redis的setNx(key,clientId,过期实现)方法进行实现(clientId:redis中key对应的的value值) 在业务代码中
try{
.....
//**缓存按照自己实际业务确认是否需要缓存限制频次拦截**
//注意获取锁的状态
boolean lockStatus=redis.setNX(key,value,10);
return 未获取到锁提示友好的信息给用户
}catch(Excention e){
//注意异常时日志的输出,要打印关键的识别信息 (orderId等)
}finally{
//解锁处理
if(lockStatus&&clientId.equals(redis.get(key))){
//删除操作
redis.del();
}
}
第三步:基于数据库mysql的行锁机制,保证数据的幂等(当redis出现挂掉或者异常时,进行兜底) 扩展 这里使用基础的redis功能,没有对redis的续租进行实现,可以通过redission实现分布式锁内部实现了续租的功能更加强大,实现更简单。
下一篇:
Dubbo基本结构及执行流程
