欧美一级特黄大片做受成人-亚洲成人一区二区电影-激情熟女一区二区三区-日韩专区欧美专区国产专区

SpringBoot中如何使用Redisson實現(xiàn)分布式鎖

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

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

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-productredis:port: 6379host: 127.0.0.1password:database: 0timeout: 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: 5000threads: 0nettyThreads: 0codec: !<org.redisson.codec.JsonJacksonCodec> {}transportMode : "NIO"

1.4、寫一個RedissonConfig配置類來配置你的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、編寫一個秒殺接口

@Autowiredprivate RedissonClient redissonClient; @Overridepublic 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)容就是SpringBoot中如何使用Redisson實現(xiàn)分布式鎖,你們學到知識或技能了嗎?如果還想學到更多技能或者豐富自己的知識儲備,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

文章名稱:SpringBoot中如何使用Redisson實現(xiàn)分布式鎖
文章轉(zhuǎn)載:http://aaarwkj.com/article24/pdphje.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供企業(yè)建站網(wǎng)站導(dǎo)航、虛擬主機、網(wǎng)站制作、、App設(shè)計

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)

外貿(mào)網(wǎng)站制作
黄片超刺激在线看在线| 亚洲欧美精品综合久久99| 97资源在线中文一区| 男女啪啪国产精品视频| 高级会所口爆视频在线播放视频 | 十八禁网站免费在线播放| 新午夜福利片在线观看| 亚洲午夜一区二区三区精品| 久久精品国产亚洲av麻豆花絮 | 亚洲女同中文字幕在线| 国产偷人伦激情在线观看| 国产精品亚洲国产精品| 日日夜夜久久一二三区| 久久综合婷婷亚洲五月| 亚洲av乱码乱码精品| 国产日韩熟女中文字幕| 日韩精品视频在线不卡| 97免费公开在线观看| 92国产精品午夜福利| 欧美 国产 综合 日韩| 亚洲综合欧美日韩一区| 国产91高清视频在线观看| 欧美日韩国产精品精品| 久久99精品久久久国产| 中文字幕有码手机在线看| 国产探花猛操性感美女| 欧美伦理片三级在线观看| 久久久亚洲熟妇熟女一区二区| 亚洲午夜精品久久久天堂| 日本黄色高清视频一区| 日本高清不卡免费在线观看视频一二三区| 日本国产在线一区二区| 蜜桃av网站在线播放| 综合激情四射亚洲激情| 一区二区三区在线观看日本视频| 欧美一区二区三区精美| 免费爱爱视频在线观看| 亚洲青涩精品一区二区三区| 亚洲国产专区一区二区麻豆| 日韩精品电影一二三| 亚洲精品不卡在线观看|