本篇文章為大家展示了SpringBoot中如何使用redisson實(shí)現(xiàn)分布式鎖，內(nèi)容簡(jiǎn)明扼要并且容易理解，絕對(duì)能使你眼前一亮，通過(guò)這篇文章的詳細(xì)介紹希望你能有所收獲。

在大興等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強(qiáng)發(fā)展的系統(tǒng)性、市場(chǎng)前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務(wù)理念，為客戶提供網(wǎng)站制作、做網(wǎng)站 網(wǎng)站設(shè)計(jì)制作按需網(wǎng)站策劃,公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),成都品牌網(wǎng)站建設(shè),全網(wǎng)整合營(yíng)銷(xiāo)推廣,外貿(mào)網(wǎng)站制作,大興網(wǎng)站建設(shè)費(fèi)用合理。

1.1、引入Maven依賴

org.redisson redisson-spring-boot-starter 3.10.6

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

org.redisson redisson 3.6.1

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

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-productredis:port: 6379host: 127.0.0.1password:database: 0timeout: 2000

1.3、配置redisson

新建一個(gè)redisson-single.yml的配置文件下面是單機(jī)配置

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的檢查操作會(huì)直接報(bào)錯(cuò) 所以我直接注釋掉了 #dnsMonitoring: false dnsMonitoringInterval: 5000threads: 0nettyThreads: 0codec: ! {}transportMode : "NIO"

1.4、寫(xiě)一個(gè)RedissonConfig配置類(lèi)來(lái)配置你的redisson

/*** @Description //TODO* @Date $ $* @Author huangwb**/@Configurationpublic 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、編寫(xiě)一個(gè)秒殺接口

@Autowiredprivate RedissonClient redissonClient; @Overridepublic boolean decrementProductStore(Long productId, Integer productQuantity) { String key = "dec_store_lock_" + productId; RLock lock = redissonClient.getLock(key); try {  //加鎖 操作很類(lèi)似Java的ReentrantLock機(jī)制  lock.lock();  ProductInfo productInfo = productInfoMapper.selectByPrimaryKey(productId);  //如果庫(kù)存為空  if (productInfo.getProductStock() == 0) {   return false;  }  //簡(jiǎn)單減庫(kù)存操作 沒(méi)有重新寫(xiě)其他接口了  productInfo.setProductStock(productInfo.getProductStock() - 1);  productInfoMapper.updateByPrimaryKey(productInfo); } catch (Exception e) {  System.out.println(e.getMessage()); } finally {  //解鎖  lock.unlock(); } return true;}

1.6、寫(xiě)一個(gè)簡(jiǎn)單的測(cè)試請(qǐng)求

@GetMapping("test")public String createOrderTest() { if (!productInfoService.decrementProductStore(1L, 1)) {  return "庫(kù)存不足"; } OrderMaster orderMaster = new OrderMaster(); //未支付 orderMaster.setOrderStatus(0); //未支付 orderMaster.setPayStatus(0); orderMaster.setBuyerName(name); orderMaster.setBuyerAddress("湖南長(zhǎng)沙"); 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做接口測(cè)試

ab -n 300 -c 300請(qǐng)求地址

-n的含義就是你做多少個(gè)請(qǐng)求

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

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

如果對(duì)ab不是太了解可以看看這篇文章：使用Apache ab進(jìn)行http性能測(cè)試

上述內(nèi)容就是SpringBoot中如何使用Redisson實(shí)現(xiàn)分布式鎖，你們學(xué)到知識(shí)或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。