在系统开拓中比较常用的有数据库天生、缓存天生、数据库+缓存。这里就上述情形做一些简要记录。
二、数据库天生之前有利用过的一种方案:同步锁 + MySql。在一张数据表中记录最新的流水号数据,然后通过SQL获取数据并做 +1 处理。
这里须要把稳一些问题:
① 并发问题
② 唯一的索引确保数据不重复
三、缓存(Redis)天生在Redis中有一个类叫做:RedisAtomicLong可以比较好的办理这个问题。
我们在IDE中点进去这部分的源码可以看到它的一些操作:
① 固定步长为1
② volatile润色Key,内存共享
③ 先增加再获取数据
④ 单线程操作(PS:什么?Redis6.0多线程...)
四、关键代码如下 / 功能描述: 天生流水 Param: [] Return: java.lang.String / private String generateAutoId(){ RedisConnectionFactory connectionFactory = stringRedisTemplate.getConnectionFactory(); if (connectionFactory == null) { throw new RuntimeException("RedisConnectionFactory is required !"); } RedisAtomicLong atomicLong = new RedisAtomicLong("autoId:autoId", connectionFactory); / 设置过期韶光 / LocalDate now = LocalDate.now(); LocalDateTime expire = now.plusDays(1).atStartOfDay(); atomicLong.expireAt(Date.from(expire.atZone(ZoneId.systemDefault()).toInstant())); Long autoID = atomicLong.getAndIncrement(); DecimalFormat df = new DecimalFormat("00000"); / 流水号不敷5位补充成5位 / String autoNumber = df.format(autoID); System.out.println(autoNumber); return autoNumber; }
同时做简要测试:
@Test void contextLoads() { List<Thread> threads = new ArrayList<>(); for (int i = 0; i < 1000; i++) { Thread thread = new Thread(this::generateAutoId); threads.add(thread); } threads.forEach(Thread::start); threads.forEach(x -> { try { x.join(); } catch (InterruptedException e) { e.printStackTrace(); } }); }
测试结果:
五、后记① 利用数据库+同步锁天生代码大略但效率轻微低,适宜访问量较少的系统。
② 利用缓存天生代码同样简介,由于Redis的特性(单线程、存放于内存)能知足高并发,但是数据可能丢失。
③ 数据库 + 缓存(适用于大部分分布式高并发系统)其大致操作流程如下: