时间:2022-07-29 09:23:25 | 栏目:Redis | 点击:次
场景:针对于分布式并发环境,易出现编码生成重复问题
方案特点:串行操作可避免阻塞加锁,处理效率更高
具体解决方案
private final static String ENTERPRISE_CODE = "enterpriseCode"; @Resource private RedisTemplate redisTemplate; private String generateCode() { String code; if (!redisTemplate.hasKey(ENTERPRISE_CODE)) { // Mybatis-Plus 查询数据库中企业编码最大值 EnterprisePO enterprise = enterpriseService.getOne( Wrappers.<EnterprisePO>lambdaQuery() .orderByDesc(EnterprisePO::getCode) .last("limit 1")); // 缓存企业编码 if (ObjectUtils.isNotEmpty(enterprise)) { // 如果 key 不存在才 set 避免并发重复 set,setIfAbsent() 属于原子操作 redisTemplate.opsForValue().setIfAbsent(ENTERPRISE_CODE, Long.valueOf(enterprise.getCode())); // 也可设置 key 过期时间,此处设置为 1 天 // redisTemplate.opsForValue().setIfAbsent(ENTERPRISE_CODE, Long.valueOf(enterprise.getCode()), 1, TimeUnit.DAYS); } } // 以递增方式缓存最新编码 Long number = redisTemplate.opsForValue().increment(ENTERPRISE_CODE, 1L); // %06d 意为保留 6 位数,不足六位数字前面补 0 code = String.format("%06d", number); return code; }