Mix PHP V2 實(shí)例：AliCloud 短信協(xié)程池異步發(fā)送守護(hù)程序

qc1iu 發(fā)布于2019-07-01 12:49 / 521人閱讀

摘要：前些時(shí)間我們發(fā)布了實(shí)例協(xié)程池異步郵件發(fā)送守護(hù)程序范例，這一次我們提供一個(gè)使用大廠通過協(xié)程化來并行執(zhí)行短信發(fā)送任務(wù)，本文是一個(gè)代碼簡單性能極強(qiáng)的范例。

前些時(shí)間我們發(fā)布了 Mix PHP V2 實(shí)例：協(xié)程池異步郵件發(fā)送守護(hù)程序范例，這一次我們提供一個(gè)使用大廠 SDK 通過 Swoole Hook 協(xié)程化來并行執(zhí)行短信發(fā)送任務(wù)，本文是一個(gè)代碼簡單、IO 性能極強(qiáng)的范例。

請先升級到 mix-framework >= v2.0.5。

本范例依然使用消息隊(duì)列的方式接收短信發(fā)送任務(wù)，消息中間件使用：

redis

生產(chǎn)者

通?？蚣苤惺褂?Redis 會(huì)安裝一個(gè)類庫來使用，本例使用原生代碼，便于理解。

// 連接
$redis = new Redis();
if (!$redis->connect("127.0.0.1", 6379)) {
    throw new Exception("Redis connect failed.");
}
$redis->auth("");
$redis->select(0);
// 投遞任務(wù)
for($i = 0; $i < 3; $i++){
    $data = [
        "phone"         => "***",
        "templateCode"  => "SMS_***",
        "templateParam" => ["code" => 123456],
    ];
    $redis->lpush("queue:sms", serialize($data));
}

消費(fèi)者

使用的是 ali 云的短信服務(wù)，查看官方 PHP SDK 文檔，使用的庫為：

composer require alibabacloud/client

通過查看該庫的 composer 依賴文件，我們得知該庫基于 guzzlehttp 開發(fā)，因?yàn)?Mix PHP 提供了無需修改代碼就可 Hook Guzzle 庫可在協(xié)程中使用的工具 Mix PHP V2 生態(tài)：讓 Guzzle 支持 Swoole 的 Hook 協(xié)程，所以能基本確定該庫可在 Swoole 協(xié)程中使用。

首先我們安裝 https://github.com/mix-php/guzzle-hook 讓 alibabacloud/client 可在協(xié)程中使用：

composer require mix/guzzle-hook

然后在項(xiàng)目的 composer.json 文件中增加 extra 配置項(xiàng)，如下：

"extra": {
    "include_files": [
      "vendor/mix/guzzle-hook/src/functions_include.php"
    ]
}

更新自動(dòng)加載：

composer dump-autoload

下面我們采用 Mix PHP V2 的守護(hù)程序、協(xié)程池來完成一個(gè)超高性能的短信發(fā)送程序。

首先我們在配置 applications/console/config/main.php 中注冊一個(gè)命令：

// 命令
"commands"         => [

        "smser" => [
            "Smser",
            "description" => "SMS send daemon demo.",
            "options"     => [
                [["d", "daemon"], "description" => "Run in the background"],
            ],
        ],

],

注冊的命令中指定的 Smser 命令類，接下來我們編寫一個(gè) SmserCommand 類：

applications/console/src/Commands/SmserCommand.php


 */
class SmserCommand
{

    const ACCESS_KEY = "***";
    const ACCESS_SECRET = "***";

    /**
     * 退出
     * @var bool
     */
    public $quit = false;

    /**
     * 主函數(shù)
     */
    public function main()
    {
        // 守護(hù)處理
        $daemon = Flag::bool(["d", "daemon"], false);
        if ($daemon) {
            ProcessHelper::daemon();
        }
        // 捕獲信號
        ProcessHelper::signal([SIGHUP, SIGINT, SIGTERM, SIGQUIT], function ($signal) {
            $this->quit = true;
            ProcessHelper::signal([SIGHUP, SIGINT, SIGTERM, SIGQUIT], null);
        });
        // 設(shè)置ali云全局參數(shù)
        AlibabaCloud::accessKeyClient(static::ACCESS_KEY, static::ACCESS_SECRET)->regionId("cn-hangzhou")->asDefaultClient();
        // 手動(dòng)關(guān)閉Swoole文件Hook，因?yàn)閍li云依賴的uuid庫有文件hook協(xié)程兼容問題，Swoole 4.4已經(jīng)適配該問題
        Coroutine::enableHook(SWOOLE_HOOK_ALL ^ SWOOLE_HOOK_FILE);
        // 協(xié)程池執(zhí)行任務(wù)
        xgo(function () {
            $maxWorkers = 20;
            $maxQueue   = 20;
            $jobQueue   = new Channel($maxQueue);
            $dispatch   = new Dispatcher([
                "jobQueue"   => $jobQueue,
                "maxWorkers" => $maxWorkers,
            ]);
            $dispatch->start(SmserWorker::class);
            // 投放任務(wù)
            $redis = app()->redisPool->getConnection();
            while (true) {
                if ($this->quit) {
                    $dispatch->stop();
                    return;
                }
                try {
                    $data = $redis->brPop(["queue:sms"], 3);
                } catch (Throwable $e) {
                    $dispatch->stop();
                    return;
                }
                if (!$data) {
                    continue;
                }
                $data = array_pop($data); // brPop命令最后一個(gè)鍵才是值
                $jobQueue->push($data);
            }
        });
        // 等待事件
        Event::wait();
    }

}

從 $data = $redis->brPop(["queue:sms"], 3); 外部的異常捕獲可得知，當(dāng) Redis 連接出錯(cuò)時(shí)，比如 Redis 重啟、連接異常時(shí)協(xié)程池會(huì)安全退出，也就是說當(dāng)進(jìn)程異常退出后用戶需使用 supervisor、pm2 等工具重啟守護(hù)進(jìn)程。

上面是一個(gè) Mix PHP 協(xié)程池的使用代碼，基本可以直接復(fù)制使用，框架默認(rèn)包含了協(xié)程池的 Demo，本次實(shí)例只是修改了協(xié)程池的 Worker，本命令主要是完成從 Redis 隊(duì)列中獲取消息然后 push 到 jobQueue 中，jobQueue 中的數(shù)據(jù)會(huì)被 20 個(gè) Worker 實(shí)例中某一個(gè)搶占后并行執(zhí)行，本例的發(fā)送代碼邏輯就在 SmserWorker 類中：

applications/console/src/Libraries/SmserWorker.php


 */
class SmserWorker extends AbstractWorker implements WorkerInterface
{

    /**
     * 郵件發(fā)送器
     * @var Smser
     */
    public $smser;

    /**
     * 初始化事件
     */
    public function onInitialize()
    {
        parent::onInitialize(); // TODO: Change the autogenerated stub
        // 實(shí)例化一些需重用的對象
        $this->smser = new Smser();
    }

    /**
     * 處理
     * @param $data
     */
    public function handle($data)
    {
        // TODO: Implement handle() method.
        $data = unserialize($data);
        if (empty($data)) {
            return;
        }
        try {
            $result = $this->smser->send($data["phone"], $data["templateCode"], $data["templateParam"]);
            app()->log->info("SMS sent successfully：phone {phone} templateCode {templateCode} result {result}", array_merge($data, ["result" => json_encode($result, JSON_UNESCAPED_UNICODE)]));
        } catch (Throwable $e) {
            app()->log->error("SMS failed to send：phone {phone} templateCode {templateCode} error {error}", array_merge($data, ["error" => $e->getMessage()]));
        }
    }

}

由以上代碼可見，Worker 在初始化時(shí)，新增了一個(gè) Smser 類的屬性，當(dāng) jobQueue 消息投遞過來時(shí)消息會(huì)傳遞到 handle 方法，在該方法中使用 Mailer 類的實(shí)例完成郵件發(fā)送任務(wù)，所以我們要編寫了一個(gè) Smser 發(fā)送程序：

applications/console/src/Libraries/Smser.php


 */
class Smser
{

    /**
     * 配置信息
     */
    const SIGN_NAME = "***";

    /**
     * Smser constructor.
     */
    public function __construct()
    {
        // 開啟協(xié)程鉤子
        Coroutine::enableHook();
    }

    /**
     * 發(fā)送
     * @param $phone
     * @param $templateCode
     * @param $templateParam
     * @return array
     * @throws ClientException
     * @throws ServerException
     */
    public function send($phone, $templateCode, $templateParam)
    {
        $result = AlibabaCloud::rpc()
            ->product("Dysmsapi")
            // ->scheme("https") // https | http
            ->version("2017-05-25")
            ->action("SendSms")
            ->method("POST")
            ->options([
                "query" => [
                    "PhoneNumbers"  => $phone,
                    "SignName"      => static::SIGN_NAME,
                    "TemplateCode"  => $templateCode,
                    "TemplateParam" => json_encode($templateParam),
                ],
            ])
            ->request();
        return $result->toArray();
    }

}

以上就完成了全部的代碼邏輯，現(xiàn)在我們開始測試，先啟動(dòng)消費(fèi)者守護(hù)程序：

[root@localhost bin]# ./mix-console smser

將上文的生產(chǎn)者腳本命名為 push.php 然后在 CLI 中執(zhí)行 (開一個(gè)新終端)：

[root@localhost bin]# php /tmp/push.php

消費(fèi)者守護(hù)程序結(jié)果：

[root@localhost bin]# ./mix-console smser
[info] 2019-05-24 12:03:32 <101014> [message] SMS sent successfully：phone *** templateCode SMS_*** result {"Message":"OK","RequestId":"4071D031-6D9E-4F70-9269-6C1979080858","BizId":"939807358670612546^0","Code":"OK"}
[info] 2019-05-24 12:03:32 <101014> [message] SMS sent successfully：phone *** templateCode SMS_*** result {"Message":"觸發(fā)分鐘級流控Permits:1","RequestId":"490B73D7-317E-4362-B2DD-5E2153A7B891","Code":"isv.BUSINESS_LIMIT_CONTROL"}
[info] 2019-05-24 12:03:32 <101014> [message] SMS sent successfully：phone *** templateCode SMS_*** result {"Message":"觸發(fā)分鐘級流控Permits:1","RequestId":"1FD22EDB-BAA4-4416-8FF9-242EDCF34359","Code":"isv.BUSINESS_LIMIT_CONTROL"}

命令行終端打印了發(fā)送成功的日志，發(fā)送完成。

GPU云服務(wù)器云服務(wù)器 python協(xié)程池異步協(xié)程框架 PHP發(fā)送短信發(fā)送短信php

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

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

發(fā)表評論

登陸后可評論

0條評論

qc1iu

男|高級講師

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

TA的文章

聯(lián)盛德W806-KIT開發(fā)板試用評測系列之二：ADC 功能使用與測試

閱讀 2183·2021-11-24 09:39
Sparkedhost：美國邁阿密AMD Ryzen高性能VPS/免費(fèi)100G高防/2G內(nèi)存/1核/

閱讀 2802·2021-07-29 13:49
Linux下node-sass安裝失敗的解決方法與簡單使用

閱讀 2328·2019-08-29 14:15
3D 高逼格動(dòng)畫制作

閱讀 2244·2019-08-29 12:40
JavaScript 之類

閱讀 3323·2019-08-26 13:42
實(shí)現(xiàn)element-ui對話框可拖拽功能

閱讀 643·2019-08-26 12:13
vuejs構(gòu)建的單頁面應(yīng)用history模式子頁面微信分享在iOS中遇到的問題

閱讀 2077·2019-08-26 11:41
【leetcode】3. 無重復(fù)字符的最長子串

閱讀 3355·2019-08-23 18:32

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

資訊專欄INFORMATION COLUMN

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

Mix PHP V2 實(shí)例：AliCloud 短信協(xié)程池異步發(fā)送守護(hù)程序

相關(guān)文章

Mix PHP V2 實(shí)例：協(xié)程池異步郵件發(fā)送守護(hù)程序

Mix PHP V2 新特性：協(xié)程、定時(shí)器

***Mix* PHP V2 生態(tài)：讓 Guzzle 支持 Swoole 的 Hook *協(xié)程***

**swoole通用協(xié)程池的實(shí)現(xiàn)**

Python協(xié)程（真才實(shí)學(xué)，想學(xué)的進(jìn)來）

發(fā)表評論

0條評論

qc1iu

男|高級講師

TA的文章

聯(lián)盛德W806-KIT開發(fā)板試用評測系列之二：ADC 功能使用與測試

Sparkedhost：美國邁阿密AMD Ryzen高性能VPS/免費(fèi)100G高防/2G內(nèi)存/1核/

Linux下node-sass安裝失敗的解決方法與簡單使用

3D 高逼格動(dòng)畫制作

JavaScript 之類

實(shí)現(xiàn)element-ui對話框可拖拽功能

vuejs構(gòu)建的單頁面應(yīng)用history模式子頁面微信分享在iOS中遇到的問題

【leetcode】3. 無重復(fù)字符的最長子串

最新活動(dòng)

資訊專欄INFORMATION COLUMN

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

Mix PHP V2 實(shí)例：AliCloud 短信協(xié)程池異步發(fā)送守護(hù)程序

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動(dòng)

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