redis解決高并發看門狗策略

當一個業務執行時間超過自己設定的鎖釋放時間,那么會導致有其他線程進入,從而搶到同一個票,所有需要使用看門狗策略,其實就是開一個守護線程,讓守護線程去監控key,如果到時間了還未結束,就會將這個key重新set一次,重置到原來的時間,只要主線程未結束,守護線程就會一直存在,這里還是會有一些問題,就是如果redis宕機了,導致第一個線程拿到了鎖,第二個線程也拿到了鎖,為了解決這個就需要引入紅鎖

1. 導入依賴,這里導入依賴可能會和原先的redis依賴沖突,所以只能留下一個,不然可能會出錯

去除spring-boot-starter-data-redis

  <!-- 集成Redis--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency>

添加redisson

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

2. 修改配置文件,將之前的配置緩存redisson的

spring:data:redis: # redis配置url: redis://:127.0.0.1:6379

3. 開始分布式鎖-看門狗策略,找到高頻訪問的業務添加以下代碼

在業務方法開始的頭添加

在方法末尾添加釋放鎖,別忘了添加try-catch-finally塊


這是一段完整的分布式處理,有需要直接copy后修改即可

  public void doConfirm(ConfirmOrderDoReq req) {String lockKey = DateUtil.formatDate(req.getDate()) + "-" + req.getTrainCode();RLock lock = null;try {lock = redissonClient.getLock(lockKey);boolean tryLock = lock.tryLock(0, TimeUnit.SECONDS);if (tryLock) {LOG.info("搶到鎖,開始處理訂單");} else {LOG.info("很遺憾,沒有搶到鎖");//當前搶票人數多,請稍后再試throw new BusinessException(BusinessExceptionEnum.CONFIRM_ORDER_LOCK_FAIL);}//業務處理。。。。} catch (InterruptedException e) {LOG.error("搶票失敗", e);throw new BusinessException(BusinessExceptionEnum.CONFIRM_ORDER_LOCK_FAIL);} finally {LOG.info("鎖被釋放了");// 釋放鎖if (lock != null && lock.isHeldByCurrentThread()){lock.unlock();}}}

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/bicheng/71550.shtml
繁體地址,請注明出處:http://hk.pswp.cn/bicheng/71550.shtml
英文地址,請注明出處:http://en.pswp.cn/bicheng/71550.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

新數據結構(12)——代理

什么是代理 在進行操作時有時不希望用戶直接接觸到目標&#xff0c;這時需要使用代理讓用戶間接接觸到目標 給目標對象提供一個代理對象&#xff0c;并且由代理對象控制著對目標對象的引用 圖解&#xff1a; 代理的目的 控制訪問&#xff1a;通過代理對象的方式間接的訪問目…

Unity Shader Graph 2D - Procedural程序化圖形之夾心圓環

前言 本文將使用Unity Shader Graph的節點來繪制一個夾心圓環,分成三部分外環、內環和中心環。通過制作一個夾心圓環能夠更好地理解和實踐Shader Graph中的基礎節點以及思維。 創建一個Ring的Shader Graph文件,再創建一個對應的材質球M_Ring以及一個Texture2D的MainT…

緩存三大問題及其解決方案

緩存三大問題及其解決方案 1. 前言 ? 在現代系統架構中&#xff0c;緩存與數據庫的結合使用是一種經典的設計模式。為了確保緩存中的數據與數據庫中的數據保持一致&#xff0c;通常會給緩存數據設置一個過期時間。當系統接收到用戶請求時&#xff0c;首先會訪問緩存。如果緩…

【算法】----多重背包問題I,II(動態規劃)

&#x1f339;作者:云小逸 &#x1f4dd;個人主頁:云小逸的主頁 &#x1f4dd;Github:云小逸的Github &#x1f91f;motto:要敢于一個人默默的面對自己&#xff0c;強大自己才是核心。不要等到什么都沒有了&#xff0c;才下定決心去做。種一顆樹&#xff0c;最好的時間是十年前…

LeetCode-524. 通過刪除字母匹配到字典里最長單詞

1、題目描述&#xff1a; 給你一個字符串 s 和一個字符串數組 dictionary &#xff0c;找出并返回 dictionary 中最長的字符串&#xff0c;該字符串可以通過刪除 s 中的某些字符得到。 如果答案不止一個&#xff0c;返回長度最長且字母序最小的字符串。如果答案不存在&#x…

TikTok賬戶安全指南:如何取消兩步驗證?

TikTok賬戶安全指南&#xff1a;如何取消兩步驗證&#xff1f; 在這個數字化的時代&#xff0c;保護我們的在線賬戶安全變得尤為重要。TikTok&#xff0c;作為全球流行的社交媒體平臺&#xff0c;其賬戶安全更是不容忽視。兩步驗證作為一種增強賬戶安全性的措施&#xff0c;雖…

面試題之箭頭函數和普通函數有什么區別?

箭頭函數&#xff08;Arrow Function&#xff09;和普通函數&#xff08;Regular Function&#xff09;是 JavaScript 中兩種不同的函數定義方式&#xff0c;它們在語法、上下文&#xff08;this&#xff09;、原型鏈等方面存在顯著區別。以下是它們的主要區別&#xff1a; 1. …

Llama 3.1 本地電腦部署 Linux系統 【輕松簡易】

本文分享在自己的本地電腦部署 llama3.1&#xff0c;而且輕松簡易&#xff0c;快速上手。 這里借助Ollama工具&#xff0c;在Linux系統中進行大模型部署~ Llama3.1&#xff0c;有三個版本&#xff1a;8B、70B、405B Llama 3.1 405B 是第一個公開可用的模型&#xff0c;在常識…

工業安全的智能哨兵:AI如何筑起生產線的“數字防火墻“

工業安全的智能哨兵:AI如何筑起生產線的"數字防火墻" (本文共1420字,閱讀約需4分鐘) 去年某石化廠的反應釜壓力數據出現異常波動,傳統監測系統在15分鐘后才發出警報——而AI模型在23秒前就已預警。這場未遂事故揭示了一個殘酷現實:工業安全監測正在經歷從&qu…

【Bert】自然語言(Language Model)入門之---Bert

every blog every motto: Although the world is full of suffering&#xff0c; it is full also of the overcoming of it 0. 前言 對bert進行梳理 論文&#xff1a; BERT: Pre-training of Deep Bidirectional Transformers for Language Understanding 時間&#xff1a;…

Linux中使用Docker安裝DIFY搭建本地支持庫和Agent

Dify 是一款開源的大語言模型(LLM) 應用開發平臺。它融合了后端即服務&#xff08;Backend as Service&#xff09;和 LLMOps 的理念&#xff0c;使開發者可以快速搭建生產級的生成式 AI 應用。即使你是非技術人員&#xff0c;也能參與到 AI 應用的定義和數據運營過程中。 然而…

開源工具推薦--思維導圖、流程圖等繪制

1. 前言 在工作中&#xff0c;經常要用到各種不同的工具&#xff0c;隨著系統的升級&#xff0c;有些工具也在不斷更新升級。這里收集整理一些好用的開源工具推薦&#xff0c;遵循以下一些基本原則&#xff1a;開源免費&#xff0c;商業工具的有效平替&#xff0c;輕量級&…

Ubuntu 下 nginx-1.24.0 源碼分析 - ngx_create_pool函數

ngx_create_pool 聲明在 src\core\ngx_palloc.h 中 ngx_pool_t *ngx_create_pool(size_t size, ngx_log_t *log); 實現在 src\core\ngx_palloc.c 中 ngx_pool_t * ngx_create_pool(size_t size, ngx_log_t *log) {ngx_pool_t *p;p ngx_memalign(NGX_POOL_ALIGNMENT, size, lo…

ac的dhcp池里option43配錯導致ap無法上線問題排查過程

dhcp池里ac地址配錯&#xff0c;導致ap無法上線問題排查過程 問題&#xff1a;ap手動設置ac的ip正常注冊在線&#xff0c;但dhcp獲得ip和ac地址發現無法在ac上注冊成功。 組網&#xff1a; ac旁路結構&#xff0c;路由器lan口地址172.16.1.1&#xff0c;開dhcp服務&#xff0…

IntelliJ IDEA中Maven配置全指南

一、環境準備與基礎配置 1.1 Windows 環境下載并配置 Maven 見此篇博文&#xff1a;環境配置 1.2 IDEA配置步驟 打開設置面板&#xff1a;File → Settings → Build → Build Tools → Maven 關鍵配置項&#xff1a; Maven home path E:\apache-maven-3.9.9 &#xff08;…

存儲區域網絡(SAN)管理

存儲區域網絡&#xff08;Storage Area Network&#xff0c;SAN&#xff09;采用網狀通道&#xff08;Fibre Channel &#xff0c;簡稱FC&#xff09;技術&#xff0c;通過FC交換機連接存儲陣列和服務器主機&#xff0c;建立專用于數據存儲的區域網絡。SAN提供了一種與現有LAN連…

使用vue-office報錯TypeError: ft.createElementVNode is not a function

支持多種文件(.docx、.xlsx、.xls、.pdf、.pptx)預覽的vue組件庫&#xff0c;支持vue2/3。也支持非Vue框架的預覽。 不支持.doc、.ppt&#xff08;2003年及以前的版本&#xff09; 官網&#xff1a;https://www.npmjs.com/package/vue-office/excel?activeTabreadme 官方有實…

Ubuntu部署ktransformers

準備工作 一臺服務器 CPU&#xff1a;500G GPU&#xff1a;48G&#xff08;NVIDIA4090&#xff09; 系統&#xff1a;Ubuntu20.04&#xff08;github的文檔好像用的是22.04&#xff09; 第一步&#xff1a;下載權重文件 1.下載hfd wget https://hf-mirror.com/hfd/hfd.s…

C++初階——簡單實現vector

目錄 1、前言 2、Vector.h 3、Test.cpp 1、前言 簡單實現std::vector類模板。 相較于前面的string&#xff0c;vector要注意&#xff1a; 深拷貝&#xff0c;因為vector的元素可能是類類型&#xff0c;類類型元素可以通過賦值重載&#xff0c;自己實現深拷貝。 迭代器失效…

全志A133 android10 適配SLM770A 4G模塊

一&#xff0c;模塊基本信息 1.官方介紹 SLM770A是美格智能最新推出的一款LTE Cat.4無線通訊模組&#xff0c;最大支持下行速率150Mbps及上行速率50Mbps。同時向下兼容現有的3G和2G網絡&#xff0c;以確保即使在偏遠地區也可以進行網絡通信。 SLM770A模組支持分集接收和MIMO技…