SpringBoot使用Redisson實現(xiàn)分布式鎖（秒殺系統(tǒng)）

來源：本站原創(chuàng)|時間：2020-01-10|欄目：Java|點擊：次

前面講完了Redis的分布式鎖的實現(xiàn)，接下來講Redisson的分布式鎖的實現(xiàn)，一般提及到Redis的分布式鎖我們更多的使用的是Redisson的分布式鎖，Redis的官方也是建議我們這樣去做的。Redisson點我可以直接跳轉(zhuǎn)到Redisson的官方文檔。

1.1、引入Maven依賴

<dependency>
 <groupId>org.redisson</groupId>
 <artifactId>redisson-spring-boot-starter</artifactId>
 <version>3.10.6</version>
</dependency>

注意：我這里引入的是redisson和springboot的集成包，網(wǎng)上一些教程可能是引入如下配置

<dependency>
 <groupId>org.redisson</groupId>
 <artifactId>redisson</artifactId>
 <version>3.6.1</version>
</dependency>

如果你引入的就是redisson的依賴包，如果該依賴包的版本低于3.5會需要你再引入

<dependency>
 <groupId>io.netty</groupId>
 <artifactId>netty-all</artifactId>
 <version>4.1.25.Final</version>
</dependency>
 
<dependency>
 <groupId>com.fasterxml.jackson.core</groupId>
 <artifactId>jackson-core</artifactId>
 <version>2.9.0</version>
</dependency>
 
<dependency>
 <groupId>com.fasterxml.jackson.core</groupId>
 <artifactId>jackson-databind</artifactId>
 <version>2.9.0</version>
</dependency>

這樣的一些依賴。

1.2、配置redis信息

spring:
  application:
    name: spring-cloud-product
  redis:
    port: 6379
    host: 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: !<org.redisson.codec.JsonJacksonCodec> {}
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();
 //未支付
 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 "創(chuàng)建訂單成功";
}

1.7、使用ab做接口測試

ab -n 300 -c 300 請求地址

-n 的含義就是你做多少個請求

-c 的含義就是多少個用戶并發(fā)請求

數(shù)據(jù)庫中的商品已經(jīng)全部被秒殺完并未出現(xiàn)超庫存的情況。

如果對ab不是太了解可以看看這篇文章：使用Apache ab進行http性能測試

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持我們。

上一篇：Spring實戰(zhàn)之使用@Resource配置依賴操作示例

欄目：Java

下一篇：如何基于Spring使用工廠模式實現(xiàn)程序解耦

本文標題：SpringBoot使用Redisson實現(xiàn)分布式鎖（秒殺系統(tǒng)）

本文地址：http://mengdiqiu.com.cn/a1/Java/8864.html