Redis对批量数据实现分布式锁的实现代码
目录
- 需求背景
- 代码实现
- 实现效果
需求背景
在开发的收入结转平台界面上有一个归集按钮,可以实现抓取结转表里面的多条数据进行归集操作。为了防止多人多电脑同时操作一条数据,我们自己开发了一个简单的基于Redis实现的分布式锁。
代码实现
逻辑代码中的使用案例
参数说明:
scIds:结转数据的ID主键集合。
timeOutToDeleteRedisKey:最大锁超时时间(用于自动解锁)
organizationId:租户ID(这个参数根据情况选择是否需要)
ReturnLock returnLock = RedisLock.applyByIds(scIds, redisLockTime, organizationId, () -> {
// dothing 具体的代码业务逻辑
return 123;
});
if (!returnLock.getFlag()) {
if(returnLock.getLock()){
throw new CommonException("归集数据有程序正在运行,请稍候刷新页面重试");
}else {
throw new CommonException(returnLock.getErrorMsg());
}
}
// 返回对象
System.out.println(returnLock.getResObj()) // 123
Redis加锁方法封装
public static ReturnLock applyByIds(ListscIds, Long timeOutToDeleteRedisKey, Long tenantId, Supplier
getLockByIds
批量获取每一条数据的Redis锁
private static MapgetLockByIds(List scIds, Long timeOutToDeleteRedisKey, Long tenantId) { Map keyMap = new HashMap<>(); // 从spring上下文中获取Redis的操作对象,因为这个代码是写在util中,所以通过上下文方式获取bean对象 // RedisHelper:Redis的操作对象,我们自己公司基于redisTemplate封装的 RedisHelper redisHelper = SpringUtil.getBean(RedisHelper.class); try { if (CollectionUtil.isNotEmpty(scIds)) { for (int i = 0; i < scIds.size(); i++) { String item = "L_" + scIds.get(i); String UUID = UUIDUtils.generateTenantUUID(tenantId); // 判断key值是否被锁,如果没有锁则加锁并设置过期时间, 如果有锁, 则报错并立即释放已加的锁 // strSetIfAbsent会返回true/false,底层是封装了java的setIfAbsent方法和Redis的setnx方法 // 如果设置成功返回true否则false if (redisHelper.strSetIfAbsent(item, UUID)) { // 设置过期时间 redisHelper.setExpire(item, timeOutToDeleteRedisKey, TimeUnit.SECONDS); // 保存设置的锁信息 keyMap.put(item, UUID); } else { // 锁设置异常,表示有数据被锁住了,解锁之间加锁的数据 if (MapUtil.isNotEmpty(keyMap)) { if (unLockByIds(keyMap)) { // 解锁失败再次解锁 unLockByIds(keyMap); } } // 返回锁信息 return keyMap; } } } return keyMap; }catch (Exception e) { e.printStackTrace(); } }
解锁
private static Boolean unLockByIds(MapkeyMap) { RedisHelper redisHelper = SpringUtil.getBean(RedisHelper.class); try { if (MapUtil.isEmpty(keyMap)) { return false; } // 判断是否是自己的锁 for (String key : keyMap.keySet()) { String uuid = keyMap.get(key); if (StringUtils.equals(uuid, redisHelper.strGet(key))) { // 封装了redisTemplate.delete(key); redisHelper.delKey(key); } return true; }catch (Exception e) { e.printStackTrace(); return false; } }
实现效果
当对数据进行批量加锁的时候,若在加锁的过程中出现加锁失败,则回滚直接加的锁,并提示"归集数据有程序正在运行,请稍候刷新页面重试"。
若业务代码逻辑执行成功或者执行报错都会自动的解锁当前加锁的数据。
栏 目:其它数据库
本文地址:https://zz.feitang.co/shujuku/28276.html
您可能感兴趣的文章
- 12-22使用mysql记录从url返回的http GET请求数据操作
- 12-22详解sql中exists和in的语法与区别
- 12-22hive从mysql导入数据量变多的解决方案
- 12-22如何为PostgreSQL的表自动添加分区
- 12-22postgresql 实现得到时间对应周的周一案例
- 12-22sqoop export导出 map100% reduce0% 卡住的多种原因及解决
- 12-22mysql查询条件not in 和 in的区别及原因说明
- 12-22解决mysql使用not in 包含null值的问题
- 12-22解决从集合运算到mysql的not like找不出NULL的问题
- 12-22postgresql 实现多表关联删除


阅读排行
推荐教程
- 12-11mysql代码执行结构实例分析【顺序、分支、循环结构】
- 12-08添加mysql的用户名和密码是什么语句?
- 12-20PhpMyAdmin出现错误数据无法导出怎么办?
- 12-19Redis中实现查找某个值的范围
- 12-15浅析mysql迁移到clickhouse的5种方法
- 12-15CentOS7 64位下MySQL5.7安装与配置教程
- 12-14Mysql大型SQL文件快速恢复方案分享
- 12-14mysql 5.7.27 安装配置方法图文教程
- 12-13MySQL给新建用户并赋予权限最简单的方法
- 12-13关于MySQL索引的深入解析





