目錄前言：場景一，緩存失效回調(diào)。1. 設(shè)置Redis回調(diào)事件方法。2. 訂閱redis某個庫的鍵失效的頻道名。3. 設(shè)置有限期4. 查看鍵失效回調(diào)訂閱的命令窗口是否出現(xiàn)失效的鍵名。5. 代碼實(shí)現(xiàn)鍵名的失效事件訂閱。6. 通過PHP-cli運(yùn)行該腳本7. 緩存失效應(yīng)用展開。場景二，接口冪等性。場景三，庫存超賣。前言：

在實(shí)際開發(fā)項(xiàng)目中，產(chǎn)品一旦推廣開來，總能遇到一些小問題。比如某個接口突然就請求崩掉了，某個提交接口明明做了限制為什么就多出了好多重復(fù)的記錄。還有是某個記錄超過限制進(jìn)行修改了，以下就以這幾個小問題總結(jié)一下平時采取的解決方法。

1.緩存失效場景，就比如某個接口做了數(shù)據(jù)緩存，緩存過期導(dǎo)致突然某個時刻大量請求直接讀數(shù)據(jù)庫。解決方法設(shè)置redis緩存回調(diào)事件，訂閱失效頻道。所以這個也可以用來處理某些業(yè)務(wù)場景到期處理方式。

2.接口冪等性場景，就比如注冊接口，通過手機(jī)號查詢是否存在記錄。但有時出現(xiàn)網(wǎng)絡(luò)延遲用戶連點(diǎn)等情況，會出現(xiàn)數(shù)據(jù)庫出現(xiàn)幾條一樣的用戶數(shù)據(jù)記錄。

3.商品庫存超賣場景，比如某個活動商品下單，多個用戶同時下一個商品的訂單，從而導(dǎo)致庫存超賣的現(xiàn)象。解決方法可以使用樂觀鎖或者悲觀鎖解決此問題。

場景一，緩存失效回調(diào)。1. 設(shè)置Redis回調(diào)事件方法。

(1). 打開Redis客戶終端，輸入命令非持久性的回調(diào)事件設(shè)置

config set notify-keyspace-events Ex

(2). windows平臺打開Redis安裝目錄中找到"redis.windows-service.conf"，然后打開編輯找到notify-keyspace-events那一行，去掉"#"，改為notify-keyspace-events “Ex"。

(3). 其中Redis還可以設(shè)置訂閱鍵名的回調(diào)，比如訂閱某個鍵名的del操作等，可以在conf中設(shè)置不同的，方法網(wǎng)上也有的。

2. 訂閱redis某個庫的鍵失效的頻道名。

可以在命令測試，也可以通過PHP代碼訂閱然后cli環(huán)境下運(yùn)行腳本。

命令：subscribe __keyevent@0__:expired3. 設(shè)置有限期

重新打開一個新的redis客戶終端輸入一個帶有效期的鍵值對，如下(鍵名test_key_name, 時間30s， 值ceshi)

命令：setex test_key_name 30 ceshi4. 查看鍵失效回調(diào)訂閱的命令窗口是否出現(xiàn)失效的鍵名。

5. 代碼實(shí)現(xiàn)鍵名的失效事件訂閱。<?php//設(shè)置php腳本執(zhí)行時間set_time_limit(0);//設(shè)置socket連接超時時間ini_set('default_socket_timeout', -1);class redisSubscribe { protected $config = ['host' => '127.0.0.1','password' => '6379' ]; protected $redis; public function __construct() {try { $this->redis = new \Redis(); $this->redis->pconnect($this->config['host'],$this->config['password']);} catch(\Exception $e) { echo 'redis錯誤：'.$e->getMessage().PHP_EOL;} } // 普通消息訂閱 public function normal() {//聲明頻道名稱$channelName = 'test';try { $this->redis->subscribe([$channelName], function ($redis, $channel, $msg) {echo 'channel:' . $channel . ',message:' . $msg . PHP_EOL;file_put_contents('subscribe.log','\n-'.$msg.'-\n',FILE_APPEND); });} catch (\Exception $e) { echo $e->getMessage();} } // 訂閱Key失效事件的頻道 public function keyNotify() {echo 'wathc keyNotify start~~'.PHP_EOL;// Key事件回調(diào)//$channel = '__keyevent@0__:expired';// 0號庫的Key過期事件頻道名$channel = '__keyevent@*__:expired';// 所有庫的Key過期事件頻道名try { $this->redis->subscribe([$channel], function ($redis, $channel, $msg) {echo 'channel:' . $channel . '===========' . ',message:' . $msg . PHP_EOL;file_put_contents('subscribe.log','\n-'.$msg.'-\n',FILE_APPEND); });} catch (\Exception $e) { echo $e->getMessage();} }}(new redisSubscribe())->keyNotify();?>6. 通過PHP-cli運(yùn)行該腳本

然后也可以setex一個短時間的鍵，然后查看命令是否輸出該失效的鍵名。

7. 緩存失效應(yīng)用展開。

(1). 代碼中設(shè)置的所有鍵名都配置到項(xiàng)目的全局配置文件中。

(2). 服務(wù)器中開一個守護(hù)進(jìn)程(持續(xù)運(yùn)行訂閱某個庫或者所有庫的鍵失效回調(diào)事件腳本)。

(3). 當(dāng)該腳本有回調(diào)時，取出鍵名去全局緩存鍵名數(shù)組中匹配。

(4). 規(guī)則業(yè)務(wù)可以自行設(shè)計。

(5). 比如取出一個"cate5"的鍵名，則可以取資訊表中查詢分類ID為5的所有數(shù)據(jù)然后再進(jìn)行緩存。

(6). 緩存失效事件還一個高端玩法，就是取代某些定時任務(wù)。比如可以將某個訂單作為鍵名緩存，當(dāng)該鍵名失效就可以取出鍵名拿到ID去數(shù)據(jù)庫中將訂單狀態(tài)修改為失效。

場景二，接口冪等性。

接口重復(fù)數(shù)據(jù)也就是在高并發(fā)下的數(shù)據(jù)添加場景。最典型的是注冊接口，用戶在網(wǎng)絡(luò)延遲大或者信號不穩(wěn)定的情況下。并且同時大量用戶在進(jìn)行注冊操作，用戶點(diǎn)擊了一次沒反應(yīng)然后再次點(diǎn)擊多個。

在沒有做冪等性處理只是拿到手機(jī)號查詢數(shù)據(jù)庫是否存在，用戶表又沒分庫分表，查詢緩慢，查詢出來后，多條并發(fā)的請求都繞過了手機(jī)號已經(jīng)存在的條件判斷，所以就出現(xiàn)了ID不同，但是其他字段一樣的記錄。

對于高并發(fā)數(shù)據(jù)添加，可以使用Redis的setnx。setnx是設(shè)置鍵并且在有效期內(nèi)有值時，再次對該鍵名進(jìn)行重復(fù)賦值無法進(jìn)行，會返回0。

可以代碼在對某些條件查詢是否存在時，可以將條件組成鍵名賦值。添加記錄時再次對鍵名重新賦值，返回null則表示已經(jīng)存在。以下代碼是項(xiàng)目中的一個測試方法，使用的redis是封裝的，借鑒需要修改。/** * @Notes: 高并發(fā)防止重復(fù)提交（插入數(shù)據(jù)） 【保證接口的冪等性】 * @Interface preventRepeatSubmit * @return mixed * @author: bqs * @Time: 2020/6/19 14:56 */ public function preventRepeatSubmit() {/* 比如查詢某條(什么條件)記錄是否存在，分布式鎖機(jī)制[redis的原子性setnx] * 1. 通過條件拼接為唯一的鍵名，將鍵名setnx設(shè)置一個30s有效期的值 * 2. setnx設(shè)置鍵名不成功(返回0)表示已經(jīng)存在，接口則直接返回記錄已經(jīng)存在 * 3. 根據(jù)該條件查詢數(shù)據(jù)庫記錄，如果存在，接口再返回記錄已經(jīng)存在 * 【只要添加記錄前需要查詢什么是否存在則都需要考慮高并發(fā)情況，則通過此方案】*/$redis = Redis::db(0);$no = date('YmdHis',time()).mt_rand(1000,9999);//$no = 202006191537447811;// 是否添加鎖表$addLock = false;if ($redis->setnx($no,1)) { $redis->expire($no,30); //設(shè)置30s過期時間} else { $addLock = true;// 訂單已經(jīng)存在則鎖住}// 數(shù)據(jù)庫查詢是否存在$isExist = Db::name('ztest')->where(['no'=>$no])->find();if ($isExist) { $addLock = true;}if (!$addLock) { $data = ['no' => $no,'tab_num' => 2,'stock' => 20,'create_time' => time() ]; $res = Db::name('ztest')->insertGetId($data);}return '添加數(shù)據(jù)成功'; }場景三，庫存超賣。

庫存超賣是一個很常見的秒殺或者其他高并發(fā)場景下的數(shù)據(jù)更新問題。網(wǎng)絡(luò)上的解決方法也是多種多樣，對該問題延伸的數(shù)據(jù)庫樂觀鎖，悲觀鎖的知識點(diǎn)也是數(shù)不勝數(shù)。

所以，這里我也不再介紹數(shù)據(jù)庫的存儲引擎機(jī)制，事務(wù)，表鎖等概念。直接以代碼展現(xiàn)，以下是以樂觀鎖實(shí)現(xiàn)的數(shù)據(jù)庫更新問題。

高并發(fā)下，對單條記錄的修改。一般修改前會對某字段進(jìn)行判斷，但是并發(fā)情況下，拿查詢的結(jié)果進(jìn)行攔截是極其的不靠譜。不過也可以對查詢進(jìn)行加鎖，但是需要在同一事務(wù)中。庫存字段添加無符號的字段約束，所以再大的并發(fā)在修改為0之后也不會出現(xiàn)負(fù)數(shù)了，在修改的操作時捕捉修改為負(fù)數(shù)時的數(shù)據(jù)庫異常。

表中添加version字段，這個也是網(wǎng)上盛傳的樂觀鎖經(jīng)典實(shí)例了，后面的原理和流程我就不介紹了，代碼也是這樣寫的，所以直接貼代碼了。/** * @Notes: 高并發(fā)樂觀鎖 - （更新數(shù)據(jù)） * @Interface testConcurrence * @return mixed * @author: bqs * @Time: 2020/6/19 14:25 */ public function testConcurrence() {// 開啟事務(wù)Db::startTrans();// 查詢ID25當(dāng)前的庫存和版本號$curr = Db::name('ztest')->field('stock,version')->where(['id'=>25])->find();// 判斷庫存是否小于0if ($curr && $curr['stock'] <= 0) { throw new \Exception('物品已售罄',302);}try { // 修改庫存 - 獲取ID25的行瑣 $updateRes = Db::name('ztest')->where(['id'=>25,'version'=>$curr['version']])->update(['stock'=>$curr['stock']-1,'version'=>$curr['version']+1]); // 標(biāo)識并發(fā)過來修改的，拿到的version太舊，事務(wù)回滾重新回到查詢再走一遍 if (!$updateRes) {Db::rollback(); }} catch(\Exception $e) { Db::rollback(); // 記錄日志，或者返回}// 事務(wù)提交Db::commit();return '購買成功了'; }

以上就是PHP高并發(fā)高負(fù)載下的3種實(shí)戰(zhàn)場景解決方法示例的詳細(xì)內(nèi)容，更多關(guān)于PHP高并發(fā)高負(fù)載場景的資料請關(guān)注好吧啦網(wǎng)其它相關(guān)文章！