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

作者: yunqing_71 | 来源:发表于2020-04-09 23:16 被阅读0次

使用redis特性来创建每日流水号
redis-search
Redis 初次见面
20年第45周：docker部署Redis集群
Spring Cache与Redis结合使用
Redis 对象类型与编码
redis对象实现
好的文章
redis-string分析
redis集群搭建

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

公众号.jpg

这里需求是创建每日的流水号，例如：每向数据库中添加一条数据，其编号设置为yyyyMMdd0001、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天，所以过期的数据会自动删除