Java服务使用Redis实现分布式全局唯一标识

此处以SpringBoot为例,示范如何使用Redis构造全局唯一标识.

1. RedisTemplate配置

1spring.redis.database = 0
2spring.redis.host = **
3spring.redis.port = 6379
4spring.redis.password = **
5spring.redis.lettuce.pool.max-wait = 1000ms

以上配置,参照实际情况进行设置.,

2.Java服务中Redis配置

1@Repository
2@Slf4j
3public class RedisCounterRepository {
4
5    private final DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyyMMdd");
6
7    private RedisTemplate<String, Object> redisTemplate;
8
9    @Autowired
10    public RedisCounterRepository(RedisTemplate<String, Object> redisTemplate) {
11        this.redisTemplate = redisTemplate;
12    }
13
14    // 根据获取的自增数据,添加日期标识构造分布式全局唯一标识
15    private String getNumFromRedis(String changeNumPrefix) {
16        String dateStr = LocalDate.now().format(dateTimeFormatter);
17        Long value = incrementNum(changeNumPrefix + dateStr);
18        return dateStr + StringUtils.leftPad(String.valueOf(value), 4, '0');
19    }
20
21    // 从redis中获取自增数据(redis保证自增是原子操作)
22    private long incrementNum(String key) {
23
24        RedisConnectionFactory factory = redisTemplate.getConnectionFactory();
25        if (null == factory) {
26            log.error("Unable to connect to redis.");
27            throw new UserException(AppStatus.INTERNAL_SERVER_ERROR);
28        }
29        RedisAtomicLong redisAtomicLong = new RedisAtomicLong(key, factory);
30        long increment = redisAtomicLong.incrementAndGet();
31        if (1 == increment) {
32            // 如果数据是初次设置,需要设置超时时间
33            redisAtomicLong.expire(1, TimeUnit.DAYS);
34        }
35        return increment;
36    }

PS: 如果您觉得我的文章对您有帮助，请关注我的微信公众号，谢谢!