laravel異步監(jiān)控定時(shí)調(diào)度器實(shí)例詳解

定時(shí)調(diào)度器是什么

laravel默認(rèn)提供了一個(gè)命令定時(shí)任務(wù)的功能，在其他的php框架下面，沒(méi)有這個(gè)定時(shí)任務(wù)，我們要跑一些異步腳本怎么操作呢，只能依賴我們系統(tǒng)提供的crontab來(lái)做，這就導(dǎo)致我們每次發(fā)版本新增定時(shí)任務(wù)都要去服務(wù)器更改crontab代碼，獲取更新這個(gè)配置。

執(zhí)行命令是php artisan schedule:run 來(lái)執(zhí)行，那放在哪里執(zhí)行呢，沒(méi)錯(cuò)這個(gè)調(diào)起還是需要依賴我們crontab來(lái)執(zhí)行，但是只需要配置一次，后續(xù)所有定時(shí)任務(wù)都在我們業(yè)務(wù)代碼進(jìn)行控制

場(chǎng)景

我們有一個(gè)導(dǎo)入數(shù)據(jù)的定時(shí)任務(wù)

//每分鐘導(dǎo)入庫(kù)數(shù)據(jù)
$schedule->command(self::SIGNATURE)->withoutOverlapping()->everyMinute()->runInBackground();

這里導(dǎo)入長(zhǎng)時(shí)間最好使用runInBackground(),表示異步執(zhí)行，其實(shí)就是在shell腳本的末尾加上 符號(hào)，在linux上完全依賴系統(tǒng)的方式完成。

這里使用了withoutOverlapping() 表示在同一時(shí)刻只能有一個(gè)任務(wù)執(zhí)行，主要邏輯使用的是排它鎖實(shí)現(xiàn)，依賴于我們cache的driver，我這里使用的是redis，后面作為鎖的過(guò)期直接redis提供的key過(guò)期來(lái)做。

出現(xiàn)問(wèn)題

這個(gè)任務(wù)在正常情況下都是非常完美的，因?yàn)橥粫r(shí)刻只有一個(gè)再跑，跑完就可以，但是一個(gè)場(chǎng)景出現(xiàn)
有一天我們的qa同學(xué)剛部署環(huán)境后，我們服務(wù)端就在默默的導(dǎo)入庫(kù)了，因?yàn)槭褂?code>withoutOverlapping($expire_at=1440)這個(gè)時(shí)候在redis就有一個(gè)鎖產(chǎn)生了，這個(gè)默認(rèn)帶參數(shù)是鎖的過(guò)期時(shí)間，默認(rèn)是一天，然后因?yàn)槲覀僤ocker環(huán)境需要更改參數(shù)然后進(jìn)行后端server服務(wù)的重啟，我們重啟也是比較暴力，就是直接發(fā)送kill的信號(hào)，導(dǎo)致所有在里面跑的進(jìn)程瞬間kill，而這時(shí)候我們的redis的鎖缺還存在，而且是1440分鐘左右，那當(dāng)我們server再啟動(dòng)后，發(fā)現(xiàn)鎖一直存在，沒(méi)辦法進(jìn)行后續(xù)的操作了，只能等著。

解決

那我把鎖的時(shí)間減少行不行，原來(lái)1天，我改成30分鐘，沒(méi)問(wèn)題，開始第一版方案我們也是這樣做，官方也是可以這樣做的。

后來(lái)我們一想，能否做到一個(gè)監(jiān)控程序呢，進(jìn)程退出后立馬監(jiān)控到過(guò)期呢，這樣就不用固定一個(gè)時(shí)間，這當(dāng)然是所有軟件開發(fā)者理想狀態(tài)：要你開你就開，我掛了鎖也就去掉了，不論正常與否。

解決方案

說(shuō)明：

• 這里命令啟動(dòng)時(shí)候，獲取進(jìn)程的pid，然后fork子進(jìn)程，可以將這個(gè)pid傳遞給子進(jìn)程。
• 子進(jìn)程每隔10s進(jìn)行一個(gè)探活，獲取父進(jìn)程的id與傳入的pid是否一致，這里普及一個(gè)知識(shí)點(diǎn)，如果父進(jìn)程異常退出，這個(gè)子進(jìn)程未退出就會(huì)被init進(jìn)程(pid=1)接管，那么這就是一個(gè)孤兒進(jìn)程。
• 同時(shí)子進(jìn)程每次探活的時(shí)候就會(huì)更改redis的鎖的過(guò)期時(shí)間，如果探活時(shí)間間隔是10s，那么我們的過(guò)期時(shí)間設(shè)置就是14s，多冗余一點(diǎn)時(shí)間。

代碼實(shí)現(xiàn)

代碼實(shí)現(xiàn)總是那么蒼白無(wú)力哈，這里就寫一個(gè)laravel的擴(kuò)展來(lái)做，好處就是不影響我們主體的任何代碼就完成了，我們的laravel可以隨意升級(jí)。

github地址:github.com/zzh78727258…

composer地址：packagist.org/packages/ze…

總結(jié)

整體實(shí)現(xiàn)沒(méi)有使用判斷進(jìn)程是否存在的ps grep等命令，因?yàn)槲覀僤ocker環(huán)境不一定支持這些命令，只是用簡(jiǎn)單的pid與parent_id做對(duì)比。

laravel的在命令開始于結(jié)束都進(jìn)行鉤子方式，我們?cè)贚istener下面進(jìn)行監(jiān)聽即可

public function subscribe($events)
 {
  $events->listen(
   [
    CommandStarting::class, // 命令開始的時(shí)候
   ],
   __CLASS__ . '@handle'
  );
 }

整體代碼是基于laravel擴(kuò)展化的，不會(huì)影響laravel的升級(jí)操作。

好了，以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，謝謝大家對(duì)腳本之家的支持。