关注我，精彩文章第一时间推送给你
公众号.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天，所以过期的数据会自动删除
- 看一下控制台的log日志
09-8f6dc9b4-1
- 在执行一次
09-8f6dc9b4-2
