news 2026/5/1 6:05:55

java使用Redison自旋锁和mysql生成唯一编号

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
java使用Redison自旋锁和mysql生成唯一编号

1. 数据库表设计（存储递增基准值）

CREATE TABLE `t_sequence` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `type_key` varchar(255) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '关键字段', `rule_date` varchar(255) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '规则日期', `max_number` varchar(255) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '自增序列号', `version` bigint(20) DEFAULT NULL COMMENT '版本号', `deleted` varchar(1) COLLATE utf8mb4_unicode_ci DEFAULT '0' COMMENT '删除状态：0-正常 1-删除', `create_user_id` varchar(128) COLLATE utf8mb4_unicode_ci DEFAULT NULL, `create_time` datetime DEFAULT CURRENT_TIMESTAMP, `update_user_id` varchar(128) COLLATE utf8mb4_unicode_ci DEFAULT NULL, `update_time` datetime DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=10 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='序列表';

2、生成实体

@Getter @Setter @Accessors(chain = true) @TableName("t_sequence") @ApiModel(value = "TSequence对象", description = "序列表") public class TSequence implements Serializable { @ApiModelProperty("主键ID") @TableId(value = "id", type = IdType.AUTO) private Long id; @ApiModelProperty("关键字段") private String typeKey; @ApiModelProperty("规则日期") private String ruleDate; @ApiModelProperty("对应某年的自增序列号") private String maxNumber; @ApiModelProperty("版本号") private Long version; @ApiModelProperty("创建人ID") private Long createUserId; @ApiModelProperty("创建时间") private LocalDateTime createTime; @ApiModelProperty("更新人ID") private Long updateUserId; @ApiModelProperty("更新时间") private LocalDateTime updateTime; @ApiModelProperty("是否删除：0-未删除 1-已删除") private String deleted; }

3、实现业务

@Component @AllArgsConstructor @Log4j2 public class TSequenceService { private final RedissonClient redissonClient; private final TSequenceMapper sequenceMapper; private static final String ORDER_SEQ_LOCK_KEY = "seq:lock:";//锁前缀 private static final int MAX_RETRY_TIMES = 10;//自旋次数 private static final long RETRY_INTERVAL = 200;//自旋一次等待时间 private static final long LOCK_EXPIRE_SECONDS = 30;//锁等待时间 /** * 生成唯一编码 * @param prefix :前缀 * @param typeKey :业务类型 * @param currentValue :自增数据 * @return */ @Transactional(rollbackFor = Exception.class) public String publicCreateNumber(String prefix,String typeKey,String currentValue) { String lockKey = ORDER_SEQ_LOCK_KEY + typeKey; int retryCount = 0; // 锁对象移到循环外，避免重复创建 RLock lock = redissonClient.getLock(lockKey); // 自旋获取锁 while (retryCount < MAX_RETRY_TIMES) { try { // 尝试获取锁（非阻塞） boolean locked = lock.tryLock(0, LOCK_EXPIRE_SECONDS, TimeUnit.SECONDS); if (locked) { try { // 加锁成功后执行核心逻辑 return doCreateNumber(prefix,typeKey,currentValue); } finally { // 释放锁（确保当前线程持有锁） if (lock.isHeldByCurrentThread()) { lock.unlock(); log.info("释放分布式锁成功，lockKey:{}", lockKey); } } } else { // 自旋等待 retryCount++; log.warn("第{}次获取锁失败，等待{}ms后重试，lockKey:{}", retryCount, RETRY_INTERVAL, lockKey); TimeUnit.MILLISECONDS.sleep(RETRY_INTERVAL); } } catch (InterruptedException e) { log.error("自旋等待时被中断", e); Thread.currentThread().interrupt(); throw new RuntimeException("生成编号失败：线程被中断"); } catch (Exception e) { log.error("获取/释放锁异常", e); throw new RuntimeException("生成编号失败：锁操作异常", e); } } log.error("生成编号失败：超出最大自旋重试次数（{}次），lockKey:{}", MAX_RETRY_TIMES, lockKey); throw new RuntimeException("业务繁忙，请稍后尝试"); } /** * 加锁后的核心业务逻辑 * @param prefix :前缀 * @param typeKey :业务类型 * @param currentValue :自增数据 * @return */ public String doCreateNumber(String prefix,String typeKey,String currentValue) { String yearMonth = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMM"));//获取日期 long newVersion; int nextNumber; String number; //查询数据库序列数据,悲观锁查询，锁定行 TSequence tSequence = sequenceMapper.selectOne(new LambdaQueryWrapper<TSequence>() .eq(TSequence::getDeleted, DeletedEnum.DEFAULT.getValue()) .eq(TSequence::getTypeKey, typeKey) .eq(TSequence::getRuleDate, yearMonth) .last("FOR UPDATE")); if (ObjectUtil.isNull(tSequence)) { // 初始化编号 nextNumber = Integer.parseInt(currentValue)+ 1; // 使用 DecimalFormat 保持前导零 DecimalFormat df = new DecimalFormat(currentValue); String index = df.format(nextNumber); number = prefix+yearMonth+index;//拼接新编号 // 插入新记录 TSequence newSequence = new TSequence(); newSequence.setTypeKey(typeKey); newSequence.setMaxNumber(nextNumber); newSequence.setVersion(1L); newSequence.setRuleDate(yearMonth); newSequence.setCreateTime(LocalDateTime.now()); int insert = sequenceMapper.insert(newSequence); if (insert != 1) { throw new RuntimeException("初始化序列失败，enumValue:" + typeKey); } log.info("初始化序列成功，编号：{}", number); } else { // 已有序列，递增编号 String maxNumber = tSequence.getMaxNumber(); nextNumber = Integer.parseInt(tSequence.getMaxNumber())+ 1; // 使用 DecimalFormat 保持前导零 DecimalFormat df = new DecimalFormat(currentValue); String index = df.format(nextNumber); number = prefix+yearMonth+index;//拼接新编号 if (ObjectUtil.isEmpty(number)) { throw new RuntimeException("递增编号失败，当前最大编号：" + maxNumber); } // 乐观锁更新：校验旧版本号，设置新版本号 Long oldVersion = tSequence.getVersion(); newVersion = oldVersion + 1; LambdaUpdateWrapper<TSequence> updateWrapper = new LambdaUpdateWrapper<TSequence>() .eq(TSequence::getTypeKey, typeKey) .eq(TSequence::getRuleDate, yearMonth) .eq(TSequence::getMaxNumber, maxNumber) // 校验旧编号 .eq(TSequence::getVersion, oldVersion) // 校验旧版本号（核心修复） .set(TSequence::getVersion, newVersion) // 设置新版本号 .set(TSequence::getMaxNumber, nextNumber) .set(TSequence::getUpdateTime, LocalDateTime.now()); // 执行更新并校验结果 int update = sequenceMapper.update(null, updateWrapper); if (update != 1) { throw new RuntimeException("更新序列失败，并发冲突！enumValue:" + typeKey + ", 当前编号:" + maxNumber); } log.info("更新序列成功，旧编号：{}，新编号：{}", maxNumber, number); } return number; } }
版权声明: 本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系邮箱：809451989@qq.com进行投诉反馈，一经查实，立即删除！
网站建设 2026/4/28 12:39:39

第十五讲 指针 从本质吃透 C 语言指针（上）

本文Gittee: 东华逐梦码为径&#xff0c;万里探真路自长。 指针是 C 语言的灵魂&#xff0c;也是初学者的 “拦路虎”。很多人觉得指针难&#xff0c;核心是没搞懂 “地址” 和 “指针变量” 的本质关系。这篇文章会抛开复杂概念&#xff0c;用生活案例 极简代码&#x…

作者头像 李华
网站建设 2026/4/25 14:43:33

TensorFlow 2.5.0 GPU版环境配置全指南

TensorFlow 2.5.0 GPU 版本配置实战指南 在深度学习项目中&#xff0c;一个稳定高效的开发环境是成功的关键。尤其是当你手握一块高性能 NVIDIA 显卡&#xff0c;却只能用 CPU 跑模型时&#xff0c;那种“算力被封印”的感觉实在令人抓狂。本文将带你一步步打通 Windows 10 A…

作者头像 李华
网站建设 2026/5/1 5:43:32

【提升OCR准确率300%】：Dify平台Tesseract自定义字体训练全解析

第一章&#xff1a;Dify Tesseract 的字体适配在使用 Dify 平台集成 Tesseract OCR 引擎进行文本识别时&#xff0c;字体适配是影响识别准确率的关键因素之一。Tesseract 依赖训练好的语言数据模型来识别字符&#xff0c;而不同字体的结构差异可能导致识别失败。因此&#xff0…

作者头像 李华
网站建设 2026/4/30 0:53:24

Linux进程管理完全指南：创建、终止、回收与替换

引言进程是Linux系统的核心概念之一&#xff0c;理解进程的创建、终止、回收和替换是系统编程的基石。本文将系统性地介绍Linux进程管理的各个方面&#xff0c;包括父子进程关系、写时复制技术、进程终止方式、僵尸进程处理、进程回收机制以及exec函数族的使用。一、父子进程与…

作者头像 李华
网站建设 2026/4/23 16:27:18

【专家亲授】量子计算容器化部署瓶颈突破：依赖精简直击5大关键点

第一章&#xff1a;量子计算镜像的依赖精简在构建用于量子计算模拟的容器化环境时&#xff0c;镜像体积与运行效率直接相关。过量的依赖不仅增加部署时间&#xff0c;还可能引入安全漏洞。因此&#xff0c;对量子计算框架如Qiskit或Cirq的镜像进行依赖精简&#xff0c;是提升系…

作者头像 李华
网站建设 2026/5/1 5:44:35

揭秘Dify集成Tesseract自定义词典全过程：5步实现精准文本识别

第一章&#xff1a;揭秘Dify集成Tesseract自定义词典的核心价值在OCR&#xff08;光学字符识别&#xff09;技术日益普及的今天&#xff0c;准确识别特定领域文本成为关键挑战。Tesseract作为开源OCR引擎&#xff0c;虽具备强大识别能力&#xff0c;但在专业术语、专有名词或非…

作者头像 李华