使用redis特性来建立每日流水号

关注我，精彩文章第一时间推送给你

这里需求是建立每日的流水号，例如：每向数据库中添加一条数据，其编号设置为yyyyMMdd000一、yyyyMMdd0002这样的格式，日期加后四位为当日流水号，也就是当日第几个添加的数据。

• 为何考虑使用redis呢？

额、redis的特性就不介绍了，反正本文也不是介绍redis怎么使用的...

简而言之，为了显示本身用过redis而用，哈哈哈

• 这里docker启动redis遇到一个问题，记录一下

#建立容器的时候报错WARNING: IPv4 forwarding is disabled. Networking will not work.
#这个错致使链接不上redis，可是在容器内部docker exec -it redis bash redis-cli可以使用
#我启动redis容器的命令
docker run -d --privileged=true --restart=always -p 6379:6379 -v /usr/docker/redis/data:/data --name redis redis:latest redis-server --appendonly yes
#解决办法
vim  /usr/lib/sysctl.d/00-system.conf
#添加下面这行
net.ipv4.ip_forward=1
#重启network
systemctl restart network
#删除错误的重启从新执行启动redis的命令
docker stop redis
docker rm redis
复制代码

• 建立一个spring boot项目，在pom.xml中引入以下依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!--由于Springboot 2.0 中redis客户端使用了Lettue, 其依赖于commons-->
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
</dependency>
复制代码

• 配置application.yml链接redis

spring:
 redis:
 host: 192.168.16.128
 port: 6379
    # 链接超时时间（记得添加单位，Duration）
 timeout: 10000ms
    # Redis默认状况下有16个分片，这里配置具体使用的分片
    # database: 0
 lettuce:
 pool:
        # 链接池最大链接数（使用负值表示没有限制） 默认 8
 max-active: 8
        # 链接池最大阻塞等待时间（使用负值表示没有限制） 默认 -1
 max-wait: -1ms
        # 链接池中的最大空闲链接 默认 8
 max-idle: 8
        # 链接池中的最小空闲链接 默认 0
 min-idle: 0
复制代码

• 建立redis操做类，这里主要利用的redis自增操做

@Component
@Slf4j
public class RedisCacheTemplate {

    @Resource
    private RedisTemplate<String, Object> redisTemplate;
    
    /** * @Title: incr * @Description: 获取redis自增序号 * @param key redis的 key值 * @param delta 自增的增量 * @return */
    public long incr(String key, long delta, long time) {
        try {
            long l = redisTemplate.opsForValue().increment(key, delta);
            if (time > 0) {
                expire(key, time);
            }
            return l;
        } catch (Exception e) {
            log.error("redis获取" + key + "失败", e);
            return -1;
        }
    }
    
    /** * @Title: expire * @Description: 设置过时时间 * @param key * @param time * @return */
    public boolean expire(String key, long time) {
        try {
            if (time > 0) {
                redisTemplate.expire(key, time, TimeUnit.SECONDS);
            }
            return true;
        } catch (Exception e) {
            log.error("redis设置" + key + "过时时间失败", e);
            return false;
        }
    }
}
复制代码

• 把获取到的redis自增的序号格式化成指定格式0001/0002/...

public class SequenceUtil {

    private static final int DEFAULT_LENGTH = 3;

    /** * 将传入的数 seq 格式化成 length 位，不够前边补 0 * 若是 length < 3 则按照 3 算 * @param seq * @param length * @return */
    public static String getSequence(long seq, int length) {
        String str = String.valueOf(seq);
        int len = str.length();
        length = Math.max(length, DEFAULT_LENGTH);
        if (len >= length) {
            return str;
        }
        int rest = length - len;
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < rest; i++) {
            sb.append('0');
        }
        sb.append(str);
        return sb.toString();
    }
}
复制代码

• 测试获取到的yyyyMMdd0001格式的每日流水号

@SpringBootTest
@Slf4j
class DemoRedisApplicationTests {

	private static final String  SERIAL_NUM= "redis:serialNumber:";

	@Autowired
	private RedisCacheTemplate redisCacheTemplate;

	@Test
	void contextLoads() {
		String currentDate = new SimpleDateFormat("yyyyMMdd").format(new Date());
		String key = SERIAL_NUM + currentDate;
		long incr = redisCacheTemplate.incr(key, 1, 86400);
		//移位运算符<<，左移几位至关于乘以2的几回方, 1 << 2 = 4
		String code = SequenceUtil.getSequence(incr, 1 << 2);
		log.info(currentDate + code);
	}

}
复制代码

解释一下：用redis:serialNumber:20200409这个做为redis的key去查找自增值，每次执行加1

redis中的key-value将是这样：

key value

redis:serialNumber:20200409 0001

redis:serialNumber:20200409 0002

...

直到下一天key变成了redis:serialNumber:20200410,value则会从0001开始递增

又由于我设置了redis的过时时间是86400秒 = 1天，因此过时的数据会自动删除

• 看一下控制台的log日志

• 在执行一次