国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

Swoole Task 的應(yīng)用

鄒立鵬 / 1776人閱讀

摘要:概述這是關(guān)于學(xué)習(xí)的第二篇文章的應(yīng)用。第一篇的應(yīng)用異步,主要實(shí)現(xiàn)調(diào)用異步任務(wù)的執(zhí)行。的實(shí)現(xiàn)方式是進(jìn)程處理數(shù)據(jù)請(qǐng)求,分配給進(jìn)程執(zhí)行。單進(jìn)程讀寫性能可達(dá)萬,不同的進(jìn)程使用不同的管道通信,可以最大化利用多核。

概述

這是關(guān)于 Swoole 學(xué)習(xí)的第二篇文章:Swoole Task 的應(yīng)用。

第一篇:Swoole Timer 的應(yīng)用

Swoole 異步Task,主要實(shí)現(xiàn)調(diào)用異步任務(wù)的執(zhí)行。

常用的場景:異步支付處理、異步訂單處理、異步日志處理、異步發(fā)送郵件/短信等。

Swoole 的實(shí)現(xiàn)方式是 worker 進(jìn)程處理數(shù)據(jù)請(qǐng)求,分配給 task 進(jìn)程執(zhí)行。

官方介紹:

task 底層使用Unix Socket管道通信,是全內(nèi)存的,沒有IO消耗。單進(jìn)程讀寫性能可達(dá)100萬/s,不同的進(jìn)程使用不同的管道通信,可以最大化利用多核。

本地版本:PHP 7.2.6、Swoole 4.3.1。

不多說,先看效果圖:

代碼 server.php
serv = new swoole_server("0.0.0.0", 9501);
        $this->serv->set([
            "worker_num"      => 2, //開啟2個(gè)worker進(jìn)程
            "max_request"     => 4, //每個(gè)worker進(jìn)程 max_request設(shè)置為4次
            "task_worker_num" => 4, //開啟4個(gè)task進(jìn)程
            "dispatch_mode"   => 2, //數(shù)據(jù)包分發(fā)策略 - 固定模式
        ]);

        $this->serv->on("Start", [$this, "onStart"]);
        $this->serv->on("Connect", [$this, "onConnect"]);
        $this->serv->on("Receive", [$this, "onReceive"]);
        $this->serv->on("Close", [$this, "onClose"]);
        $this->serv->on("Task", [$this, "onTask"]);
        $this->serv->on("Finish", [$this, "onFinish"]);

        $this->serv->start();
    }

    public function onStart($serv) {
        echo "#### onStart ####".PHP_EOL;
        echo "SWOOLE ".SWOOLE_VERSION . " 服務(wù)已啟動(dòng)".PHP_EOL;
        echo "master_pid: {$serv->master_pid}".PHP_EOL;
        echo "manager_pid: {$serv->manager_pid}".PHP_EOL;
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onConnect($serv, $fd) {
        echo "#### onConnect ####".PHP_EOL;
        echo "客戶端:".$fd." 已連接".PHP_EOL;
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onReceive($serv, $fd, $from_id, $data) {
        echo "#### onReceive ####".PHP_EOL;
        echo "worker_pid: {$serv->worker_pid}".PHP_EOL;
        echo "客戶端:{$fd} 發(fā)來的Email:{$data}".PHP_EOL;
        $param = [
            "fd"    => $fd,
            "email" => $data
        ];
        $rs = $serv->task(json_encode($param));
        if ($rs === false) {
            echo "任務(wù)分配失敗 Task ".$rs.PHP_EOL;
        } else {
            echo "任務(wù)分配成功 Task ".$rs.PHP_EOL;
        }
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onTask($serv, $task_id, $from_id, $data) {
        echo "#### onTask ####".PHP_EOL;
        echo "#{$serv->worker_id} onTask: [PID={$serv->worker_pid}]: task_id={$task_id}".PHP_EOL;

        //業(yè)務(wù)代碼
        for($i = 1 ; $i <= 5 ; $i ++ ) {
            sleep(2);
            echo "Task {$task_id} 已完成了 {$i}/5 的任務(wù)".PHP_EOL;
        }

        $data_arr = json_decode($data, true);
        $serv->send($data_arr["fd"] , "Email:".$data_arr["email"].",發(fā)送成功");
        $serv->finish($data);
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onFinish($serv,$task_id, $data) {
        echo "#### onFinish ####".PHP_EOL;
        echo "Task {$task_id} 已完成".PHP_EOL;
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onClose($serv, $fd) {
        echo "Client Close.".PHP_EOL;
    }
}

$server = new Server();
client.php
client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);

        $this->client->on("Connect", [$this, "onConnect"]);
        $this->client->on("Receive", [$this, "onReceive"]);
        $this->client->on("Close", [$this, "onClose"]);
        $this->client->on("Error", [$this, "onError"]);
    }

    public function connect() {
        if(!$fp = $this->client->connect("127.0.0.1", 9501 , 1)) {
            echo "Error: {$fp->errMsg}[{$fp->errCode}]".PHP_EOL;
            return;
        }
    }

    public function onConnect($cli) {
        fwrite(STDOUT, "輸入Email:");
        swoole_event_add(STDIN, function() {
            fwrite(STDOUT, "輸入Email:");
            $msg = trim(fgets(STDIN));
            $this->send($msg);
        });
    }

    public function onReceive($cli, $data) {
        echo PHP_EOL."Received: ".$data.PHP_EOL;
    }

    public function send($data) {
        $this->client->send($data);
    }

    public function onClose($cli) {
        echo "Client close connection".PHP_EOL;
    }

    public function onError() {

    }
}

$client = new Client();
$client->connect();
小結(jié)

一、上面的配置總共開啟了幾個(gè)進(jìn)程?

總共8個(gè)進(jìn)程(1個(gè)master進(jìn)程、1個(gè)manager進(jìn)程、4個(gè)task進(jìn)程、2個(gè)worker進(jìn)程)

重新運(yùn)行的可能與上圖進(jìn)程號(hào)不一致:

master進(jìn)程:22481

manager進(jìn)程:22485

task進(jìn)程:22488、22489、22490、22491

worker進(jìn)程:22492、22493

參考官方提供的進(jìn)程圖:

二、為什么執(zhí)行了5次后,worker進(jìn)程號(hào)發(fā)生了改變?

因?yàn)槲覀冊O(shè)了置worker進(jìn)程的max_request=4,一個(gè)worker進(jìn)程在完成最大請(qǐng)求次數(shù)任務(wù)后將自動(dòng)退出,進(jìn)程退出會(huì)釋放所有的內(nèi)存和資源,這樣的機(jī)制主要是解決PHP進(jìn)程內(nèi)存溢出的問題。

三、當(dāng)task執(zhí)行任務(wù)異常,我們kill一個(gè)task進(jìn)程,會(huì)再新增一個(gè)嗎?

會(huì)。

四、如何設(shè)置 task_worker_num ?

最大值不得超過 SWOOLE_CPU_NUM * 1000。

查看本機(jī) CPU 核數(shù):

echo "swoole_cpu_num:".swoole_cpu_num().PHP_EOL;

根據(jù)項(xiàng)目的任務(wù)量決定的,比如:1秒會(huì)產(chǎn)生200個(gè)任務(wù),執(zhí)行每個(gè)任務(wù)需要500ms。

想在1s中執(zhí)行完成200個(gè)任務(wù),需要100個(gè)task進(jìn)程。

100 = 200/(1/0.5)

五、如何設(shè)置 worker_num ?

默認(rèn)設(shè)置為本機(jī)的CPU核數(shù),最大不得超過 SWOOLE_CPU_NUM * 1000。

比如:1個(gè)請(qǐng)求耗時(shí)10ms,要提供1000QPS的處理能力,那就必須配置10個(gè)進(jìn)程。

10 = 0.01*1000

假設(shè)每個(gè)進(jìn)程占用40M內(nèi)存,10個(gè)進(jìn)程就需要占用400M的內(nèi)存。

擴(kuò)展

Server->taskwait

Server->taskWaitMulti

Server->taskCo

參考文檔

https://wiki.swoole.com/wiki/...

推薦閱讀

系統(tǒng)的講解 - SSO 單點(diǎn)登錄

系統(tǒng)的講解 - PHP WEB 安全防御

系統(tǒng)的講解 - PHP 緩存技術(shù)

系統(tǒng)的講解 - PHP 接口簽名驗(yàn)證

系統(tǒng)的講解 - PHP 浮點(diǎn)數(shù)高精度運(yùn)算

本文歡迎轉(zhuǎn)發(fā),轉(zhuǎn)發(fā)請(qǐng)注明作者和出處,謝謝!

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

轉(zhuǎn)載請(qǐng)注明本文地址:http://specialneedsforspecialkids.com/yun/31461.html

相關(guān)文章

  • php使用swoole應(yīng)用場景

    摘要:單進(jìn)程讀寫性能可達(dá)萬,不同的進(jìn)程使用不同的管道通信,可以最大化利用多核。但這任務(wù)如果是調(diào)用程序接口時(shí),由于網(wǎng)絡(luò)的延遲,增加的任務(wù)大于消費(fèi)的任務(wù)時(shí),內(nèi)存占用會(huì)不斷的增加,導(dǎo)致服務(wù)器的內(nèi)存被占滿。 應(yīng)用場景簡介 與硬件設(shè)備連接通訊(定位設(shè)備) IM系統(tǒng)(用于直播頁面的聊天通訊) 場景1 - 實(shí)時(shí)收集定位數(shù)據(jù)實(shí)時(shí)輸出(例 滴滴司機(jī)行駛軌跡) 說明:需要將所有的定位設(shè)備實(shí)時(shí)的接收,將實(shí)時(shí)的...

    jsliang 評(píng)論0 收藏0
  • swoole學(xué)習(xí)手記(四)異步任務(wù)task

    摘要:目錄初識(shí)創(chuàng)建服務(wù)器上創(chuàng)建服務(wù)器下異步任務(wù)持續(xù)更新中。。。什么是異步任務(wù)把當(dāng)前的任務(wù)異步投遞到進(jìn)程池中執(zhí)行,不影響接下來的事務(wù)。 目錄 初識(shí)Swoole 創(chuàng)建服務(wù)器(上) 創(chuàng)建服務(wù)器(下) 異步任務(wù)task 持續(xù)更新中。。。 什么是異步任務(wù)? 1.把當(dāng)前的任務(wù)異步投遞到TaskWorker進(jìn)程池中執(zhí)行,不影響接下來的事務(wù)。舉個(gè)栗子: showImg(https://segmentfa...

    vincent_xyb 評(píng)論0 收藏0
  • Swoole筆記(五)

    摘要:超過此數(shù)量后,新進(jìn)入的連接將被拒絕。表示連接最大允許空閑的時(shí)間。當(dāng)出錯(cuò)時(shí)底層會(huì)認(rèn)為是惡意連接,丟棄數(shù)據(jù)并強(qiáng)制關(guān)閉連接。在啟動(dòng)時(shí)自動(dòng)將進(jìn)程的寫入到文件,在關(guān)閉時(shí)自動(dòng)刪除文件。 配置說明 $server->set(array( daemonize => true, log_file => /www/log/swoole.log, reactor_num => 2, ...

    zgbgx 評(píng)論0 收藏0
  • Swoole RPC 實(shí)現(xiàn)

    摘要:概述這是關(guān)于學(xué)習(xí)的第七篇文章的實(shí)現(xiàn)。還有一些大佬加了微信,可能是出于對(duì)晚輩的提攜吧,偷偷告訴你,從大佬的朋友圈能學(xué)到很多東西。就到這了,上面的需要源碼的,加我微信。 概述 這是關(guān)于 Swoole 學(xué)習(xí)的第七篇文章:Swoole RPC 的實(shí)現(xiàn)。 第六篇:Swoole 整合成一個(gè)小框架 第五篇:Swoole 多協(xié)議 多端口 的應(yīng)用 第四篇:Swoole HTTP 的應(yīng)用 第三篇:Swo...

    FWHeart 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

閱讀需要支付1元查看
<