使用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日誌

• 在執行一次