使用Redis 对于分布式服务进行加锁, 防止一个服务多个部署实例,对资源抢占发生冲突。
在单体应用时,对于并发场景,读取公共资源如扣库存,买车票等,使用简单的加锁即可实现,Java本身提供了很多并发处理的API,如Synchronized。
但是对于分布式服务来说, 一个服务可能被部署在多台机器中,形成多个实例,之前的单进程多线程变成了多进程多线程
Java提供的API就不足以解决此类问题
单体应用
单个锁实现单进程多线程并发访问问题
@GetMapping("/getNumber")
public Integer getNumber(){
Integer redPacketNumber;
synchronized (this){
log.info("《idea redPacket》 请求红包数量");
redPacketNumber = Integer.valueOf(stringRedisTemplate.opsForValue().get(RED_PACKET_NUMBER));
if(redPacketNumber > 0){
stringRedisTemplate.opsForValue().set(RED_PACKET_NUMBER, String.valueOf(--redPacketNumber));
log.info("扣除成功,剩余库存 {}", redPacketNumber);
} else {
log.warn("扣除失败, 数量为{}", redPacketNumber);
}
}
return redPacketNumber;
}
分布式应用
一个服务多个实例
如果还用synchronized关键字 因为在不同服务, synchronized只能锁住单个实例的代码, 对于其他服务的代码不起作用。
Redis分布式锁
使用redis当作分布式锁
原理
setnx 命令是redis的一条原生命令
大意为 set if not exists, 在指定的key不存在的情况下,为key设置值
使用如下
redis 127.0.0.1:6379> SETNX KEY_NAME VALUE
setIfAbsent方法
使用 Redis的setIfAbsent方法可以达到setnx命令同样的效果。如果key对应的value为空,则设置值, 返回true,否则返回false
注意:
- 使用过期时间
- 为了保证万一服务报错, 锁过一会自动解锁
使用随机Value值进行存储,防止 锁的持续时间小于 业务执行时间, 导致锁自动解锁,使锁失效,下一个请求就会直接进入。所以使用随机Value 使得这个锁唯一,只能自己解开
(实践中出了问题, 锁解开的没访问的快, 还没解开,请求都发送完了)
public Integer getNumberByDistributed(){
String redPacket = "redPacket";
Integer redPacketNumber;
String vauleId = UUID.randomUUID().toString();
try{
Boolean aBoolean = stringRedisTemplate.opsForValue().setIfAbsent(redPacket, vauleId, 5, TimeUnit.SECONDS);
//已存在,相当于已加锁
if(!aBoolean){
return -1;
}
log.info("《idea redPacket》 请求红包数量");
redPacketNumber = Integer.valueOf(stringRedisTemplate.opsForValue().get(RED_PACKET_NUMBER));
if(redPacketNumber > 0){
stringRedisTemplate.opsForValue().set(RED_PACKET_NUMBER, String.valueOf(--redPacketNumber));
log.info("扣除成功,剩余库存 {}", redPacketNumber);
} else {
log.warn("扣除失败, 数量为{}", redPacketNumber);
}
} finally{
//释放锁(为当前锁)
if(stringRedisTemplate.opsForValue().get(redPacket).equals(vauleId)){
stringRedisTemplate.delete(redPacket);
}
}
return redPacketNumber;
}
Redisson客户端
高性能的异步,无锁的redis客户端 成熟的分布式锁解决方案, 可以减少开发人员的工作量,且性能优异。 这个方法可以保证较高的可用性 推荐使用
Redisson 架设在 redis 基础上的 Java 驻内存数据网格(In-Memory Data Grid),基于NIO的 Netty 框架上,利用了 redis 键值数据库。功能非常强大,解决了很多分布式架构中的问题。
Github的wiki地址:github.com/redisson/re…
官方文档:github.com/redisson/re…
- maven依赖
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>3.13.2</version>
</dependency>
- 注入实例
@Bean
public Redisson redisson(){
Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379").setPassword("****").setDatabase(0);
return (Redisson) Redisson.create(config);
}
- 使用锁
@Autowired
Redisson redisson;
public Integer getNumberByRedisson(){
String redPacket = "redPacket";
Integer redPacketNumber;
RLock redissonLock = redisson.getLock(redPacket);
String vauleId = UUID.randomUUID().toString();
try{
redissonLock.lock(30, TimeUnit.SECONDS);
log.info("{}进入redisson分布式锁的接口中",Thread.currentThread().getName());
log.info("《idea redPacket》 请求红包数量");
redPacketNumber = Integer.valueOf(stringRedisTemplate.opsForValue().get(RED_PACKET_NUMBER));
if(redPacketNumber > 0){
stringRedisTemplate.opsForValue().set(RED_PACKET_NUMBER, String.valueOf(--redPacketNumber));
log.info("扣除成功,剩余库存 {}", redPacketNumber);
} else {
log.warn("扣除失败, 数量为{}", redPacketNumber);
}
} finally{
redissonLock.unlock();
}
return redPacketNumber;
}