SpringBoot使用Redisson实现分布式锁（秒杀系统）

SpringBoot使用Redisson实现分布式锁（秒杀系统）

前面讲完了Redis的分布式锁的实现，接下来讲Redisson的分布式锁的实现，一般提及到Redis的分布式锁我们更多的使用的是Redisson的分布式锁，Redis的官方也是建议我们这样去做的。Redisson点我可以直接跳转到Redisson的官方文档。

1.1、引入Maven依赖

org.redisson

redisson-spring-boot-starter

3.10.6

注意：我这里引入的是redisson和springboot的集成包，网上一些教程可能是引入如下配置

org.redisson

redisson

3.6.1

如果你引入的就是redisson的依赖包，如果该依赖包的版本低于3.5会需要你再引入

io.netty

netty-all

4.1.25.Final

com.fasterxml.jackson.core

jackson-core

2.9.0

com.fasterxml.jackson.core

jackson-databind

2.9.0

这样的一些依赖。

1.2、配置redis信息

spring:

  application:

    name: spring-cloud-product

  redis:

    port: 6379

    hobMQeSitUst: 127.0.0.1

    password:

    database: 0

    timeout: 2000

1.3、配置redisson

新建一个redisson-single.yml的配置文件 下面是单机配置

singleServerConfig:

idleConnectionTimeout: 10000

pingTimeout: 1000

connectTimeout: 10000

timeout: 3000

retryAttempts: 3

retryInterval: 1500

reconnectionTimeout: 3000

failedAttempts: 3

password: null

subscriptionsPerConnection: 5

clientName: null

address: "redis://127.0.0.1:6379"

subscriptionConnectionMinimumIdleSize: 1

subscriptionConnectionPoolSize: 50

connectionMinimumIdleSize: 32

connectionPoolSize: 64

database: 0

#在最新版本中dns的检查操作会直接报错 所以我直接注释掉了

#dnsMonitoring: false

dnsMonitoringInterval: 5000

threads: 0

nettyThreads: 0

codec: ! {}

transportMode : "NIO"

1.4、写一个RedissonConfig配置类 来配置你的redisson

/**

* @Description //TODO

* @Date $ $

* @Author huangwb

**/

@Configuration

public class RedssonConfig {

@Bean(destroyMethod="shutdown")

public RedissonClient redisson() throws IOException {

RedissonClient redisson = Redisson.create(

Config.fromYAML(new ClassPathResource("redisson-single.yml").getInputStream()));

return redisson;

}

}

1.5、编写一个秒杀接口

@Autowired

private RedissonClient redissonClient;

@Override

public boolean decrementProductStore(Long productId, Integer productQuantity) {

String key = "dec_store_lock_" + productId;

RLock lock = redissonClient.getLock(key);

try {

//加锁 操作很类似java的ReentrantLock机制

lock.lock();

ProductInfo productInfo = productInfoMapper.selectByPrimaryKey(productId);

//如果库存为空

if (productInfo.getProductStock() == 0) {

return false;

}

//简单减库存操作 没有重新写其他接口了

productInfo.setProductStock(productInfo.getProductStock() - 1);

productInfoMapper.updateByPrimaryKey(productInfo);

} catch (Exception e) {

System.out.println(e.getMessage());

} finally {

//解锁

lock.unlock();

}

return true;

}

1.6、写一个简单的测试请求

@GetMapping("test")

public String createOrderTest() {

if (!productInfoService.decrementProductStore(1L, 1)) {

return "库存不足";

}

OrderMaster orderMaster = new OrderMaster();

/http:///未支付

orderMaster.setOrderStatus(0);

//未支付

orderMaster.setPayStatus(0);

orderMaster.setBuyerName(name);

orderMaster.setBuyerAddress("湖南长沙");

orderMaster.setBuyerPhone("18692794847");

orderMaster.setOrderAmount(BigDecimal.ZERO);

orderMaster.setCreateTime(DateUtils.getCurrentDate());

orderMaster.setOrderId(UUID.randomUUID().toString().replaceAll("-", ""));

orderMasterService.insert(orderMaster);

return "创建订单成功";

}

1.7、使用ab做接口测试

ab -n 300 -c 300 请求地址

-n 的含义就是你做多少个请求

-c 的含义就是多少个用户并发请求

数据库中的商品已经全部被秒杀完 并未出现超库存的情况。

如果对ab不是太了解可以看看这篇文章：使用Apache ab进行http性能测试

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。