Swoole 自定義項目初始化事件處理的實現

MrZONT 發布于2019-07-01 12:30 / 1397人閱讀

摘要：最近使用基于開發的框架開發項目，碰到一個需求，就是想要做項目初始化處理。當初始化處理完成前，不想讓處理請求。事件定義是一個從之間的數字，表示這個進程的那這個就好辦了，直接判斷為的去觸發項目初始化事件。

最近使用基于 Swoole 開發的 imi 框架開發項目，碰到一個需求，就是想要做項目初始化處理。當初始化處理完成前，不想讓 Swoole 處理請求。因為可能有一些值沒有加載進來，處理請求極有可能出現問題。

下面給出了思考過程及解決問題的demo代碼。

首先分析了一下，Swoole 是多進程模式運行的，分為 Master、Manager、Worker 進程。

Master 進程就是我們啟動服務的 cli 命令文件所在進程，在這里面初始化有一個問題，這里所有加載的類、全局變量，其它 Worker 進程里都可以使用，無法熱重啟生效。

Manager 進程的情況基本和上面差不多。

那么只有在 Worker 進程做處理了，但如果寫在 WorkerStart 事件里，每個 Worker 進程都會去執行。

WorkerStart 事件定義：

function onWorkerStart(swoole_server $server, int $worker_id);

$worker_id是一個從0-$worker_num之間的數字，表示這個Worker進程的ID

那這個就好辦了，直接判斷workerid為0的去觸發項目初始化事件。剩下還有一個問題就是，如何在初始化執行完成前，讓所有 Worker 進程暫時都不處理請求。

思考并嘗試了一下，這個問題可以通過協程掛起來解決，demo 代碼如下：

on("WorkerStart", function(swoole_http_server $server, $workerId){
    $initFlagFile = __DIR__ . "/init.flag";
    if(0 === $server->worker_id && (!is_file($initFlagFile) || file_get_contents($initFlagFile) != $server->manager_pid))
    {
        // 處理項目初始化事件
        initApp();
        // 寫入文件，保證不再重復觸發項目初始化事件
        file_put_contents($initFlagFile, $server->manager_pid);
        // 當前worker進程恢復協程
        resumeCos();
        // 通知其它worker進程
        for($i = 1; $i < $server->setting["worker_num"]; ++$i)
        {
            $server->sendMessage("init", $i);
        }
    }
});

$http->on("PipeMessage", function(swoole_http_server $server, $srcWorkerId, $data) {
    if(0 === $srcWorkerId && "init" === $data && !defined("APP_INITED"))
    {
        // 其它worker進程恢復協程
        resumeCos();
    }
});

$http->on("request", function (swoole_http_request $request, swoole_http_response $response) {
    // 判斷未初始化完畢，則掛起協程
    if(!defined("APP_INITED"))
    {
        $GLOBALS["WORKER_START_END_RESUME_COIDS"][] = Coroutine::getuid();
        Coroutine::suspend();
    }
    $response->header("content-type", "text/html;charset=utf-8");
    $response->end("IMI 是一款基于 Swoole 開發的協程 PHP 開發框架，擁有常駐內存、協程異步非阻塞IO等優點。官方網站：https://imiphp.com");
});

$http->start();

/**
 * 處理項目初始化事件，比如這里延時5秒，模擬初始化處理
 *
 * @return void
 */
function initApp()
{
    $count = 5;
    for($i = 0; $i < $count; ++$i)
    {
        echo "initing ", ($i + 1), "/", $count, PHP_EOL;
        sleep(1);
    }
}

/**
 * 恢復協程
 *
 * @return void
 */
function resumeCos()
{
    define("APP_INITED", true);
    $coids = $GLOBALS["WORKER_START_END_RESUME_COIDS"] ?? [];
    fwrite(STDOUT, "suspend co count: " . count($coids) . PHP_EOL);
    foreach($coids as $id)
    {
        Coroutine::resume($id);
    }
}

通過在 request 事件中判斷是否初始化完畢，如果沒有初始化完成，則掛起當前協程，將協程ID加入全局變量。

當第0個 worker 進程執行完初始化后，通過向其他 worker 進程發送消息，喚醒曾經掛起的協程們，在初始化期間進來的請求，這時候會被執行。

原文地址：https://blog.yurunsoft.com/a/...

GPU云服務器云服務器自定義view的實現自定義事件 js 自定義觸發事件實現自定義手勢

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://m.specialneedsforspecialkids.com/yun/30870.html

swoolefy-基于swoole擴展實現的高性能的常駐內存型API和Web應用服務框架

摘要：是一個基于擴展實現的輕量級高性能的常駐內存型的和應用服務框架高度封裝了，，服務器，以及基于實現可擴展的服務，同時支持包方式安裝部署項目?；趯嵱?，抽象事件處理類，實現與底層的回調的解耦，支持同步異步調用，內置等常用組件等。 swoolefy swoolefy是一個基于swoole擴展實現的輕量級高性能的常駐內存型的API和Web應用服務框架,高度封裝了http，websocket，ud...

lewinlee 2019-06-28 18:17 評論0 收藏0
Swoft 源碼剖析 - Swoole和Swoft的那些事 (Http/Rpc服務篇)

摘要：和服務關系最密切的進程是中的進程組，絕大部分業務處理都在該進程中進行。隨后觸發一個事件各組件通過該事件進行配置文件加載路由注冊。事件每個請求到來時僅僅會觸發事件。服務器生命周期和服務基本一致，詳情參考源碼剖析功能實現作者：bromine鏈接：https://www.jianshu.com/p/4c0...來源：簡書著作權歸作者所有，本文已獲得作者授權轉載，并對原文進行了重新的排版。S...

張漢慶 2019-07-01 10:18 評論0 收藏0
Swoft 源碼解讀

摘要：官網源碼解讀號外號外歡迎大家我們開發組定了一個就線下聚一次的小目標里面的框架算是非常重的了這里的重先不具體到性能層面主要是框架的設計思想和框架集成的服務讓框架可以既可以快速解決很多問題又可以輕松擴展中的框架有在應該無出其右了這次解讀的源碼官網: https://www.swoft.org/源碼解讀: http://naotu.baidu.com/file/8... 號外號外, 歡迎大...

weij 2019-06-28 18:23 評論0 收藏0
EasySwoole 服務啟動過程以及主體設計流程源碼解析

摘要：以上是服務啟動過程中的主體設計，其中包括了各種組件的實例化，如對象池等。 EasySwoole 服務啟動過程以及主體設計流程源碼解析本文主要講解EasySwoole 服務的啟動過程，會通過源碼片段講解主體的設計流程命令啟動當我們通過php easyswoole start啟動EasySwoole 服務時，命令真正到達的文件是 easyswoole項目vendoreasyswool...

huayeluoliuhen 2019-07-01 10:05 評論0 收藏0
Swoft 源碼剖析 - 連接池

摘要：基于擴展實現真正的數據庫連接池這種方案中，項目占用的連接數僅僅為。一種是連接暫時不再使用，其占用狀態解除，可以從使用者手中交回到空閑隊列中這種我們稱為連接的歸隊。源碼剖析系列目錄作者：bromine鏈接：https://www.jianshu.com/p/1a7...來源：簡書著作權歸作者所有，本文已獲得作者授權轉載，并對原文進行了重新的排版。Swoft Github: https:...

rozbo 2019-07-01 10:15 評論0 收藏0