基于Swoole的Process進程管理模塊支付結(jié)果回調(diào)服務(wù)

wenzi 發(fā)布于2019-06-28 18:33 / 2362人閱讀

摘要：原先用的多線程實現(xiàn)的支付結(jié)果回調(diào)服務(wù)，在后期運行中出現(xiàn)了服務(wù)停止的問題，在學習的過程中，發(fā)現(xiàn)可以用的進程管理模塊實現(xiàn)多線程的功能，并且使用定時器功能實現(xiàn)進程監(jiān)控在子進程退出的時候進行重啟。

原先用PHP的Pthread多線程實現(xiàn)的支付結(jié)果回調(diào)服務(wù)，在后期運行中出現(xiàn)了服務(wù)停止的問題，在學習swoole的過程中，發(fā)現(xiàn)可以用swoole的Process進程管理模塊實現(xiàn)多線程的功能，并且使用swoole_time_tick定時器功能實現(xiàn)進程監(jiān)控在子進程退出的時候進行重啟。

1、開發(fā)環(huán)境

? ? Swoole版本：2.0.12

? ? PHP版本：7.1

? ? 服務(wù)器版本：Ubuntu 14.04 64位

2、業(yè)務(wù)場景

? ? 游戲APP在支付后，在支付寶，微信等回調(diào)支付結(jié)果后，將支付結(jié)果回調(diào)給游戲服務(wù)器。回調(diào)邏輯為：25 小時以內(nèi)完成 8 次通知（通知的間隔頻率一般是：0s,2m,10m,10m,1h,2h,6h,15h）。第一次通知在接收到結(jié)果時同時回調(diào)。所以另外7次間隔性回調(diào)由7個進程分別操作。每個進程服務(wù)運行時間不一致，當前業(yè)務(wù)時間間隔各為1s，2s，30s，30s，60s，300s，600s，600s一次

3、代碼實例

use SwooleProcess;

class MyProcess
{
    public $mpid = 0; // master pid, 即當前程序的進程ID
    public $works = []; // 記錄子進程的 pid
    public $maxProcessNum = 7;
    public $newIndex = 1;

    public function __construct()
    {
        try {
            swoole_set_process_name(" MyProcess : master");
            $this->mpid = posix_getpid();
            $this->run();
            $this->processWait();
        } catch (Exception $e) {
            die("Error: ". $e->getMessage());
        }
    }

    public function run()
    {
        //創(chuàng)建進程
        for ($i=0; $i<=$this->maxProcessNum; $i++) {
            $this->createProcess($i);
        }
    }


    public function createProcess($index = null)
    {
        if (is_null($index)) {
            $index = $this->newIndex;
            $this->newIndex++;
        }
        echo date("Y-m-d H:i:s") . "  |  createProcess index=".$index.PHP_EOL;
        $process = new swoole_process(function (swoole_process $worker) use($index) { // 子進程創(chuàng)建后需要執(zhí)行的函數(shù)
            swoole_set_process_name(" MyProcess : worker $index");
            //根據(jù)進程啟用不同時間間隔的定時器 $ms為毫秒 支付回調(diào)7次嘗試 7個進程回調(diào)服務(wù) 每次回調(diào)的間隔時間不一致，實行25 小時以內(nèi)完成 8 次通知（通知的間隔頻率一般是：2m,10m,10m,1h,2h,6h,15h）
            switch ($index) {
                case 0;
                    $ms = 1000;
                    break;
                case 1;
                    $ms = 2000;
                    break;
                case 2;
                    $ms = 30000;
                    break;
                case 3;
                    $ms = 30000;
                    break;
                case 4;
                    $ms = 60000;
                    break;
                case 5;
                    $ms = 300000;
                    break;
                case 6;
                    $ms = 600000;
                    break;
                case 7;
                    $ms = 600000;
                    break;
            }
            //啟用定時器
            $timer=swoole_timer_tick($ms,"MyProcess::deal_pay_notify", $index);

        }, false, false); // 不重定向輸入輸出; 不使用管道
        $pid = $process->start();
        $this->works[$index] = $pid;
        return $pid;
    }

    /*
        * 處理支付回調(diào)
        */
    function deal_pay_notify($timmerID, $params){
        echo date("Y-m-d H:i:s") . "  |  timmerID=".$timmerID." params=".$params.PHP_EOL;

        //支付結(jié)果回調(diào)操作
        //......

    }

    // 重啟子進程
    public function rebootProcess($pid)
    {
        $index = array_search($pid, $this->works);
        if ($index !== false) {
            //重新創(chuàng)建進程
            $newPid = $this->createProcess($index);
            echo "rebootProcess: {$index}={$pid}->{$newPid} Done
";
            return;
        }
        throw new Exception("rebootProcess error: no pid {$pid}");
    }


    // 監(jiān)控子進程
    public function processWait()
    {
        //定時器每秒監(jiān)控
        swoole_timer_tick(1000,"MyProcess::monitor_process", "");
        /*while (1) {
            if (count($this->works)) {
                $ret = Process::wait(); // 子進程退出
                if ($ret) {
                    $this->rebootProcess($ret["pid"]);
                }
            } else {
                break;
            }
        }*/
    }

    //檢測進程
    public function monitor_process($timmerID, $params){
        foreach($this->works as $pid){
            if (!Process::kill($pid, 0)) { // 0 可以用來檢測進程是否存在
                $this->rebootProcess($pid); //重啟進程
                echo date("Y-m-d H:i:s") . "  |  monitor_process pid=".$pid. " restart".PHP_EOL;
            }
        }
    }
}

new MyProcess();

gitee：https://gitee.com/oydm/codes/...

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/28404.html

發(fā)表評論

登陸后可評論

0條評論

wenzi

男|高級講師

我要關(guān)注我要私信

TA的文章

DediPath：美國圣何塞VPS/Hybrid Servers五折,1Gbps無限流量服務(wù)器月付3

閱讀 2013·2021-11-23 10:08
BREW應(yīng)用自動安裝

閱讀 2348·2021-11-22 15:25
不用看網(wǎng)課就能學到python的文章（第五天）

閱讀 3282·2021-11-11 16:55
WordPress插件漏洞影響100萬個站點，或可永久刪除幾乎所有數(shù)據(jù)庫內(nèi)容

閱讀 781·2021-11-04 16:05
OpenAI 以 10 億美元出售「靈魂」，網(wǎng)友熱評不再「Open」

閱讀 2618·2021-09-10 10:51
CSS層疊機制

閱讀 719·2019-08-29 15:38
css中底部sticky footer

閱讀 1593·2019-08-29 14:11
canvas繪制經(jīng)典星空連線效果

閱讀 3492·2019-08-29 12:42

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

基于Swoole的Process進程管理模塊支付結(jié)果回調(diào)服務(wù)

相關(guān)文章

PHP多進程系列筆記（五）

Swoole 在 Swoft 中的應(yīng)用

**Swoft 源碼剖析 - Swoole和Swoft的那些事(Task投遞/定時任務(wù)篇)**

Swoole 源碼分析——進程管理 Swoole_Process

***swoole入門4-初識swoole***

發(fā)表評論

0條評論

wenzi

男|高級講師

TA的文章

DediPath：美國圣何塞VPS/Hybrid Servers五折,1Gbps無限流量服務(wù)器月付3

BREW應(yīng)用自動安裝

不用看網(wǎng)課就能學到python的文章（第五天）

WordPress插件漏洞影響100萬個站點，或可永久刪除幾乎所有數(shù)據(jù)庫內(nèi)容

OpenAI 以 10 億美元出售「靈魂」，網(wǎng)友熱評不再「Open」

CSS層疊機制

css中底部sticky footer

canvas繪制經(jīng)典星空連線效果

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

基于Swoole的Process進程管理模塊支付結(jié)果回調(diào)服務(wù)

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！