SpringBoot使用Redisson實現分散式鎖(秒殺系統)
阿新 • • 發佈:2020-01-07
前面講完了Redis的分散式鎖的實現,接下來講Redisson的分散式鎖的實現,一般提及到Redis的分散式鎖我們更多的使用的是Redisson的分散式鎖,Redis的官方也是建議我們這樣去做的。Redisson點我可以直接跳轉到Redisson的官方文件。
1.1、引入Maven依賴
<dependency> <groupId>org.redisson</groupId> <artifactId>redisson-spring-boot-starter</artifactId> <version>3.10.6</version> </dependency>
注意:我這裡引入的是redisson和springboot的整合包,網上一些教程可能是引入如下配置
<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 "建立訂單成功"; }
1.7、使用ab做介面測試
ab -n 300 -c 300請求地址
-n的含義就是你做多少個請求
-c的含義就是多少個使用者併發請求
資料庫中的商品已經全部被秒殺完並未出現超庫存的情況。
如果對ab不是太瞭解可以看看這篇文章:使用Apache ab進行http效能測試
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。