目錄
NoSQL
Redis
首頁 資料庫 Redis 如何使用Redis解決高並發

如何使用Redis解決高並發

Jun 03, 2023 pm 03:43 PM
redis

NoSQL

Not Only SQL的簡稱。 NoSQL是解決傳統的RDBMS在處理某些問題時比較乏力而提出的。

即非關係型資料庫,它們不保證關係資料的ACID特性,資料之間一般沒有關聯,在擴展上就非常容易實現,並且擁有較高的效能。

Redis

redis是nosql的典型代表,也是目前網路公司的必用技術。

Redis主要採用哈希表來實現鍵值對儲存。大多時候是直接以快取的形式被使用,使得請求不直接存取到磁碟,所以效率方面是很不錯的,完全能滿足中小型企業的使用需求。

常用資料型別

  • 字串string

  • 雜湊hash

  • #清單list

  • 集合sets

  • #有序集合sort set

##使用頻率上string和hash會高一些,各類型有各自的操作指令,無非增刪改查,具體的指令後面我會整理一份。

痛點

web應用程式在眾多請求同時發生時,可能會導致資料讀取、儲存體上出現錯誤,即發生髒讀、髒資料產生。

在分散式專案下,會出現更多的問題。

思路

並發時,本質其實就是多個請求同時進來了,沒辦法正確的去進行處理。

可以將所有的請求放在 一個佇列,讓請求們依照一個順序,挨個進來執行業務邏輯。使用訊息佇列是目前可行的解決方案,我將在下次整理一篇關於如何處理高並發的訊息佇列文章

還有一個方法是直接將並行轉為串行,Java提供了synchronized,即同步,不過這個在效率要求比較苛刻的地方或者分散式專案下還是不太合適的方案,這裡就引出了使用redis來實現分散式鎖,從而解決並發問題。

分散式鎖定

在分散式項目中,使用一個唯一、通用、效率高的標識,來表示鎖定和解鎖。

redis實作起來很簡單,也就是對一個key是否存在來表示是否上鎖、是否解鎖。

以string型別舉例:

Integer stock = goodsMapper.getStock();
if (stock > 0) {
    stock =- 1;
    goodsMapper.updateStock(stock);
}
登入後複製

以上是最簡單的秒殺偽程式碼,我們嘗試用redis實作分散式鎖定。

// 这里是错误代码,只是一个思考过程,请耐心看完哦
String key = "REDIS_DISTRIBUTION_LOCKER"; // 分布式锁名称
String value = jedisUtils.get(key);
if (value != null) { // 未上锁
    // wingzingliu
    jedisUtils.set(key, 1); // 上锁
    Integer stock = goodsMapper.getStock();
    if (stock > 0) {
        stock =- 1;
        goodsMapper.updateStock(stock);
        jedisUtils.del(key); // 释放锁
    }
}
登入後複製

以上程式碼可能會出現一個問題,就是當同時多個請求進來,某次多個請求都拿到value為空,線程A進入if 走到// wingzingliu這裡的時候,還未上鎖,其他請求也進來了,這樣就會出現髒資料了。

這裡的程式碼問題就是出在沒有考慮原子性問題。

所以我們要使用到redis的一個setNx指令,本質也是設定值,但是這是一個原子操作,執行之後會回傳是否設定成功。

redis> SETNX job "programmer"    # job 设置成功
(integer) 1
 
redis> SETNX job "code-farmer"   # 尝试覆盖 job ,失败
(integer) 0
 
redis> GET job                   # 没有被覆盖
"programmer"
登入後複製

重點關注 當有值時,會失敗,回傳0。所以我們的程式碼會改造成以下這個樣子。

// 这里是错误代码,只是一个思考过程,请耐心看完哦
String key = "REDIS_DISTRIBUTION_LOCKER"; // 分布式锁名称
Long result = jedisUtils.setNx(key, 1);
if (result > 0) { // 上锁成功,进入逻辑
    // wingzingliu1
    Integer stock = goodsMapper.getStock();
    if (stock > 0) {
        stock =- 1;
        goodsMapper.updateStock(stock);
 
        System.out.println("购买成功!");
    } else {
        System.out.println("没有库存了!");
    }
    // wingzingliu2
    jedisUtils.del(key); // 释放锁
}
登入後複製

以上我們就可以保證原子性,能正確的依序去處理。

可是還有一個隱藏的問題,就是當某個執行緒執行上鎖成功後,在wingzingliu1到wingzingliu2之間時,程式拋異常了,那麼程式終止了,就無法釋放鎖,其他執行緒也都進不來了。

解決方案是加上try catch finally區塊,在finally裡面去釋放鎖定。

可是那如果是宕機呢?上鎖之後宕機了,finally裡面的依然不會執行,鎖沒有得到釋放,不手動處理的情況下,以後所有線程也無法進入。

所以引入了redis的過期時間,到了某個時間自動解鎖。

// 这里是不够完善的代码,请耐心看完哦
try {
    String key = "REDIS_DISTRIBUTION_LOCKER"; // 分布式锁名称
    Long result = jedisUtils.setNx(key, 1, 30); // 假设处理逻辑需要20s左右,设置了30秒自动过期
    if (result > 0) { // 上锁成功,进入逻辑
        Integer stock = goodsMapper.getStock();
        if (stock > 0) {
            stock =- 1;
            goodsMapper.updateStock(stock);
 
            System.out.println("购买成功!");
        } else {
            System.out.println("没有库存了!");
        }
    }
} catch (Exception e) {
    
} finally {
    jedisUtils.del(key); // 释放锁
}
登入後複製

以上是比較完善的分散式鎖了,但是還有一個小瑕疵,就是假設某一次請求A處理的很慢,預計20s但是跑了35s,到了30s的時候鎖過期了,其他請求就自然進來了。

這不僅會導致一次並發執行,而且在請求A處理完後,仍會繼續執行釋放鎖定操作,從而實際上將鎖定交給了下一個執行緒。以此類推,整個並發控制就亂了。

理論上可以設定一個更大的key過期時間,但並不是最好的解決方案。這裡就引出一個概念:鎖續命。

鎖續命

如其名,給鎖續命。實現就是 當鎖快過期的時候,去延長鎖的時間。假設使用一個30秒的鎖,每10秒進行一次檢測以確認鎖是否仍然存在。如果鎖依然存在,則將鎖繼續保持在30秒。這樣就避免掉了上面的這個可能出現的問題。

這裡使用一個定時任務,週期性的呼叫即可。

擴充

剛剛對key設定的value是1,其實能使用請求ID來進行保存,這樣就能知道鎖是由哪個請求上的,在解鎖的時候也可以避免解鎖了其他線程上的鎖。具體由前端傳遞,或是由服務端以某種規則產生都可以。

以上是如何使用Redis解決高並發的詳細內容。更多資訊請關注PHP中文網其他相關文章!

本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發環境

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

熱門話題

Java教學
1653
14
CakePHP 教程
1413
52
Laravel 教程
1304
25
PHP教程
1251
29
C# 教程
1224
24
redis集群模式怎麼搭建 redis集群模式怎麼搭建 Apr 10, 2025 pm 10:15 PM

Redis集群模式通過分片將Redis實例部署到多個服務器,提高可擴展性和可用性。搭建步驟如下:創建奇數個Redis實例,端口不同;創建3個sentinel實例,監控Redis實例並進行故障轉移;配置sentinel配置文件,添加監控Redis實例信息和故障轉移設置;配置Redis實例配置文件,啟用集群模式並指定集群信息文件路徑;創建nodes.conf文件,包含各Redis實例的信息;啟動集群,執行create命令創建集群並指定副本數量;登錄集群執行CLUSTER INFO命令驗證集群狀態;使

redis數據怎麼清空 redis數據怎麼清空 Apr 10, 2025 pm 10:06 PM

如何清空 Redis 數據:使用 FLUSHALL 命令清除所有鍵值。使用 FLUSHDB 命令清除當前選定數據庫的鍵值。使用 SELECT 切換數據庫,再使用 FLUSHDB 清除多個數據庫。使用 DEL 命令刪除特定鍵。使用 redis-cli 工具清空數據。

redis怎麼讀取隊列 redis怎麼讀取隊列 Apr 10, 2025 pm 10:12 PM

要從 Redis 讀取隊列,需要獲取隊列名稱、使用 LPOP 命令讀取元素,並處理空隊列。具體步驟如下:獲取隊列名稱:以 "queue:" 前綴命名,如 "queue:my-queue"。使用 LPOP 命令:從隊列頭部彈出元素並返回其值,如 LPOP queue:my-queue。處理空隊列:如果隊列為空,LPOP 返回 nil,可先檢查隊列是否存在再讀取元素。

centos redis如何配置Lua腳本執行時間 centos redis如何配置Lua腳本執行時間 Apr 14, 2025 pm 02:12 PM

在CentOS系統上,您可以通過修改Redis配置文件或使用Redis命令來限制Lua腳本的執行時間,從而防止惡意腳本佔用過多資源。方法一:修改Redis配置文件定位Redis配置文件:Redis配置文件通常位於/etc/redis/redis.conf。編輯配置文件:使用文本編輯器(例如vi或nano)打開配置文件:sudovi/etc/redis/redis.conf設置Lua腳本執行時間限制:在配置文件中添加或修改以下行,設置Lua腳本的最大執行時間(單位:毫秒)

redis過期策略怎麼設置 redis過期策略怎麼設置 Apr 10, 2025 pm 10:03 PM

Redis數據過期策略有兩種:定期刪除:定期掃描刪除過期鍵,可通過 expired-time-cap-remove-count、expired-time-cap-remove-delay 參數設置。惰性刪除:僅在讀取或寫入鍵時檢查刪除過期鍵,可通過 lazyfree-lazy-eviction、lazyfree-lazy-expire、lazyfree-lazy-user-del 參數設置。

redis命令行怎麼用 redis命令行怎麼用 Apr 10, 2025 pm 10:18 PM

使用 Redis 命令行工具 (redis-cli) 可通過以下步驟管理和操作 Redis:連接到服務器,指定地址和端口。使用命令名稱和參數向服務器發送命令。使用 HELP 命令查看特定命令的幫助信息。使用 QUIT 命令退出命令行工具。

redis計數器怎麼實現 redis計數器怎麼實現 Apr 10, 2025 pm 10:21 PM

Redis計數器是一種使用Redis鍵值對存儲來實現計數操作的機制,包含以下步驟:創建計數器鍵、增加計數、減少計數、重置計數和獲取計數。 Redis計數器的優勢包括速度快、高並發、持久性和簡單易用。它可用於用戶訪問計數、實時指標跟踪、遊戲分數和排名以及訂單處理計數等場景。

如何優化debian readdir的性能 如何優化debian readdir的性能 Apr 13, 2025 am 08:48 AM

在Debian系統中,readdir系統調用用於讀取目錄內容。如果其性能表現不佳,可嘗試以下優化策略:精簡目錄文件數量:盡可能將大型目錄拆分成多個小型目錄,降低每次readdir調用處理的項目數量。啟用目錄內容緩存:構建緩存機制,定期或在目錄內容變更時更新緩存,減少對readdir的頻繁調用。內存緩存(如Memcached或Redis)或本地緩存(如文件或數據庫)均可考慮。採用高效數據結構:如果自行實現目錄遍歷,選擇更高效的數據結構(例如哈希表而非線性搜索)存儲和訪問目錄信

See all articles