redisson分布式锁使用

举报
JavaEdge 发表于 2021/06/03 23:39:02 2021/06/03
【摘要】 简介 Redisson 是一个高级的分布式协调 Redis 客服端,能帮助用户在分布式环境中轻松实现一些 Java 的对象 (Bloom filter, BitSet, Set, SetMultimap, ScoredSortedSet, SortedSet, Map, ConcurrentMap, List, ListMultimap, Queue, Blockin...

简介

Redisson 是一个高级的分布式协调 Redis 客服端,能帮助用户在分布式环境中轻松实现一些 Java 的对象 (Bloom filter, BitSet, Set, SetMultimap, ScoredSortedSet, SortedSet, Map, ConcurrentMap, List, ListMultimap, Queue, BlockingQueue, Deque, BlockingDeque, Semaphore, Lock, ReadWriteLock, AtomicLong, CountDownLatch, Publish / Subscribe, HyperLogLog)。

适用场景

分布式应用,分布式缓存,分布式回话管理,分布式服务(任务,延迟任务,执行器),分布式 redis 客户端。

我们一般使用其分布式锁功能。

项目集成

  • 添加依赖
  • 引入依赖

代码示例

@Resource
private RedissonClient redissonClient;

/**
 * 抢购代金券
 *
 * @param voucherId   代金券 ID
 * @param accessToken 登录token
 * @Para path 访问路径
 */
@Transactional(rollbackFor = Exception.class)
public ResultInfo doSeckill(Integer voucherId, String accessToken, String path) { // 基本参数校验 AssertUtil.isTrue(voucherId == null || voucherId < 0, "请选择需要抢购的代金券"); AssertUtil.isNotEmpty(accessToken, "请登录"); // ----------注释原始的走 关系型数据库 的流程---------- // 判断此代金券是否加入抢购 // SeckillVouchers seckillVouchers = seckillVouchersMapper.selectVoucher(voucherId); // AssertUtil.isTrue(seckillVouchers == null, "该代金券并未有抢购活动"); // ----------采用 Redis 解问题---------- String redisKey = RedisKeyConstant.seckill_vouchers.getKey() + voucherId; Map<String, Object> seckillVoucherMaps = redisTemplate.opsForHash().entries(redisKey); SeckillVouchers seckillVouchers = BeanUtil.mapToBean(seckillVoucherMaps, SeckillVouchers.class, true, null); // 判断是否有效 AssertUtil.isTrue(seckillVouchers.getIsValid() == 0, "该活动已结束"); // 判断是否开始、结束 Date now = new Date(); AssertUtil.isTrue(now.before(seckillVouchers.getStartTime()), "该抢购还未开始"); AssertUtil.isTrue(now.after(seckillVouchers.getEndTime()), "该抢购已结束"); // 判断是否卖完通过 Lua 脚本扣库存时判断 //AssertUtil.isTrue(seckillVouchers.getAmount() < 1, "该券已经卖完了"); // 获取登录用户信息 String url = oauthServerName + "user/me?access_token={accessToken}"; ResultInfo resultInfo = restTemplate.getForObject(url, ResultInfo.class, accessToken); if (resultInfo.getCode() != ApiConstant.SUCCESS_CODE) { resultInfo.setPath(path); return resultInfo; } // 这里的data是一个LinkedHashMap,SignInDinerInfo SignInDinerInfo dinerInfo = BeanUtil.fillBeanWithMap((LinkedHashMap) resultInfo.getData(), new SignInDinerInfo(), false); // 判断登录用户是否已抢到(一个用户针对这次活动只能买一次) VoucherOrders order = voucherOrdersMapper.findDinerOrder(dinerInfo.getId(), seckillVouchers.getFkVoucherId()); AssertUtil.isTrue(order != null, "该用户已抢到该代金券,无需再抢"); // ----------注释原始的走 关系型数据库 的流程---------- // 扣库存 // int count = seckillVouchersMapper.stockDecrease(seckillVouchers.getId()); // AssertUtil.isTrue(count == 0, "该券已经卖完了"); // 使用 Redis 锁一个账号只能购买一次 String lockName = RedisKeyConstant.lock_key.getKey() + dinerInfo.getId() + ":" + voucherId; // 加锁 long expireTime = seckillVouchers.getEndTime().getTime() - now.getTime(); // 自定义 Redis 分布式锁 // String lockKey = redisLock.tryLock(lockName, expireTime); // Redisson 分布式锁 RLock lock = redissonClient.getLock(lockName); try { // 不为空意味着拿到锁了,执行下单 // 自定义 Redis 分布式锁处理 //if (StrUtil.isNotBlank(lockKey)) { // Redisson 分布式锁处理 boolean isLocked = lock.tryLock(expireTime, TimeUnit.MILLISECONDS); if (isLocked) { // 下单 VoucherOrders voucherOrders = new VoucherOrders(); voucherOrders.setFkDinerId(dinerInfo.getId()); // Redis 中不需要维护外键信息 //voucherOrders.setFkSeckillId(seckillVouchers.getId()); voucherOrders.setFkVoucherId(seckillVouchers.getFkVoucherId()); String orderNo = IdUtil.getSnowflake(1, 1).nextIdStr(); voucherOrders.setOrderNo(orderNo); voucherOrders.setOrderType(1); voucherOrders.setStatus(0); long count = voucherOrdersMapper.save(voucherOrders); AssertUtil.isTrue(count == 0, "用户抢购失败"); // ----------采用 Redis 解问题---------- // 扣库存 // long count = redisTemplate.opsForHash().increment(redisKey, "amount", -1); // AssertUtil.isTrue(count < 0, "该券已经卖完了"); // ----------采用 Redis + Lua 解问题---------- // 扣库存 List<String> keys = new ArrayList<>(); keys.add(redisKey); keys.add("amount"); Long amount = (Long) redisTemplate.execute(redisScript, keys); AssertUtil.isTrue(amount == null || amount < 1, "该券已经卖完了"); } } catch (Exception e) { // 手动回滚事物 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); // 自定义 Redis 解锁 // redisLock.unlock(lockName, lockKey); // Redisson 解锁 lock.unlock(); if (e instanceof ParameterException) { return ResultInfoUtil.buildError(0, "该券已经卖完了", path); } } return ResultInfoUtil.buildSuccess(path, "抢购成功");
}

  
 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95
  • 96
  • 97
  • 98
  • 99
  • 100
  • 101
  • 102
  • 103
  • 104
  • 105
  • 106
  • 107
  • 108
  • 109
  • 110
  • 111
  • 112
  • 113
  • 114
  • 115

文章来源: javaedge.blog.csdn.net,作者:JavaEdge.,版权归原作者所有,如需转载,请联系作者。

原文链接:javaedge.blog.csdn.net/article/details/113246815

【版权声明】本文为华为云社区用户转载文章,如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

举报
请填写举报理由
0/200