一、一個簡單的守護進程示例

<?php
$redis = new \Redis();
$redis->connect('localhost', 6379);
$redis->auth('xxxxx'); // Redis 密碼如果沒有設(shè)置為空字符串。
$redis->select(1);

$queueKey    = 'redis_queue_services_key';     // 業(yè)務(wù)數(shù)據(jù)隊列。
$queueIngKey = 'redis_queue_services_ing_key'; // 處理中的隊列。

try {
    while (true) {
        $element = $redis->bRPopLPush($queueKey, $queueIngKey, 60);
        if ($element) {
            $data = json_decode($element, true);
            /**
             *
             ...... 此處省略業(yè)務(wù)邏輯 ......
             *
             */
        } else {
            usleep(100000); // 睡眠 0.1 秒。
        }
    }
} catch (\Exception $e) {
    exit("Error:{$e->getMessage()}");
}

這段代碼我們很容易看懂。

它就是通過Redis的阻塞方法bRPopLPush循環(huán)從 Redis 隊列中取出數(shù)據(jù)并處理。如果沒有取到數(shù)據(jù)就休眠一秒。之所以休眠是為了保證 CPU 能得到充分的利用。因為，我們已經(jīng)使用了阻塞方法阻塞 60 秒。所以，這個位置休眠與否并不重要。

當(dāng)我們的業(yè)務(wù)出現(xiàn)任何錯誤，我們通過try catch進行異常捕獲然后將錯誤信息直接輸出并退當(dāng)前腳本。

博主寒冰第一次編寫常駐后臺運行的守護進程時，就是如上這種方式寫的代碼。結(jié)果，這段代碼運行到 30s 的時候報錯了。提示我們 socket 流超時。于是我在這個腳本頭部加了如下代碼：

ini_set('default_socket_timeout', -1);

這樣我們的PHP就不會主動段掉我們與 Redis 的 socket 連接了。

但是，好景不長。過了一段時間，大概半個月吧。運維同學(xué)告訴我 Redis 隊列的數(shù)據(jù)出現(xiàn)了未消費的情況。然后，我查看了消費日志。的確沒有產(chǎn)生新的消費日志。因為我有一個習(xí)慣，每個消費消費的時候都會把成功消費的日志寫到文件中。消費失敗的也寫入日志文件中。這樣，我就知道失敗的具體原因。

但是，這次我真的沒有發(fā)現(xiàn)有任何的錯誤發(fā)生。

• 常駐后臺進程處理存活狀態(tài)。并沒有變成孤兒進程。
• 常駐后臺進程內(nèi)存也沒有出現(xiàn)泄漏。
• 系統(tǒng) CPU/內(nèi)存 資源都處理正在狀態(tài)。
• 系統(tǒng)打開的句柄資源也是低消狀態(tài)。
• 帶寬也處理低消狀態(tài)。
• 其它常駐進程也處理正常消費的工作狀態(tài)。也就排除了 Redis 故障的問題。

我當(dāng)時也懷疑過是不是像MySQL一樣常時間連接不進行任何操作，服務(wù)器端會主動斷開連接。但是，MySQL 服務(wù)器端主動段掉連接會提示：MySQL server has gone away的錯誤。但是，我們的 Redis 服務(wù)器端沒有給我們報任何錯誤信息呀。

我們公司用的是阿里云的 Redis 產(chǎn)品。我懷疑是不是 Redis 版本太低造成的這個隱性 BUG。于是，我們將阿里云的 Redis 服務(wù)升級到了阿里云支持的最新版本。

結(jié)果還是失敗了。我們的 Redis 還是假死了?；蛘哒f我們的 Redis 處于偽活狀態(tài)。

你認(rèn)為 Redis 活著，其實它早已經(jīng)死了。你認(rèn)為 Redis 死了，但是它卻沒有死亡的特征。

最后，我冷靜下來。

我假定此時的 Redis 已經(jīng)死了。只是沒有告訴客戶端而已。那么我只需要每次檢測一下 Redis 連接是否存活就好了。

于是，我翻看了 Redis 的 API。發(fā)現(xiàn)它提供了一個ping()的方法來檢測連接是否存活。

二、一個不再假死(偽活)的 Redis 常駐進程示例

<?php

$redis = new \Redis();
$redis->connect('localhost', 6379);
$redis->auth('xxxxx'); // Redis 密碼如果沒有設(shè)置為空字符串。
$redis->select(1);

$queueKey    = 'redis_queue_services_key';     // 業(yè)務(wù)數(shù)據(jù)隊列。
$queueIngKey = 'redis_queue_services_ing_key'; // 處理中的隊列。

try {
    while (true) {
        $element = $redis->bRPopLPush($queueKey, $queueIngKey, 60);
        if ($element) {
            $data = json_decode($element, true);
            /**
             *
             ...... 此處省略業(yè)務(wù)邏輯 ......
             *
             */
        } else {
            $pong = $redis->ping();
            if ($pong != '+PONG') {
                throw new \Exception('Redis ping failure!', 500);
            }
            usleep(100000); // 睡眠 0.1 秒。
        }
    }
} catch (\Exception $e) {
    exit("Error:{$e->getMessage()}");
}

通過代碼對比，我們在第一版代碼的基礎(chǔ)上加了如下代碼：

$pong = $redis->ping();
if ($pong != '+PONG') {
    throw new \Exception('Redis ping failure!', 500);
}

我們向 Redis 服務(wù)器發(fā)送ping的時候，服務(wù)器會返回+PONG字符串。當(dāng)然，這個是 Redis 擴展封裝過的方法。真正的 ping 是不會有 + 號的。

當(dāng)我們每次 ping 的時候，Redis 服務(wù)器就會認(rèn)為我們的 Redis 客戶端連接處于存活狀態(tài)。就不會斷掉我們的連接了。

把代碼進行改造之后，假死頭痛的問題再也沒出現(xiàn)了。

以上就是詳解PHP解決守護進程Redis假死的詳細(xì)內(nèi)容，更多關(guān)于PHP解決守護進程Redis假死的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論