郵件發(fā)送是很常見的需求，由于發(fā)送郵件的操作一般是比較耗時的，所以我們一般采用異步處理來提升用戶體驗，而異步通常我們使用消息隊列來實現(xiàn)。

傳統(tǒng) MVC 框架由于缺少多進程開發(fā)能力，通常是采用同一個腳本執(zhí)行多次，產生多個進程的方式，mixphp 封裝了 TaskExecutor 專用于多進程開發(fā)，用戶能非常簡單的開發(fā)出功能完善的高可用多進程應用。

下面演示一個異步郵件發(fā)送系統(tǒng)的開發(fā)過程，涉及知識點：

異步

消息隊列

多進程

守護進程

PHP 使用消息隊列通常是使用中間件來實現(xiàn)，常用的消息中間件有：

redis

rabbitmq

kafka

本次我們選用 redis 來實現(xiàn)異步郵件發(fā)送，redis 的數(shù)據(jù)類型中有一個 list 類型，可實現(xiàn)消息隊列，使用以下命令：

// 入列$redis- lpush($key, $data);// 出列$data = $redis- rpop($key);// 阻塞出列$data = $redis- brpop($key, 10);

本實例由傳統(tǒng) MVC 框架投遞郵件發(fā)送需求，MixPHP 多進程執(zhí)行發(fā)送任務。

以往我們通常使用框架提供的郵件發(fā)送庫，或者網上下載別的用戶分享的庫，composer 出現(xiàn)后，http://packagist.org/ 上有大量優(yōu)質的庫，我們只需選擇一個最好的即可，本例選擇 swiftmailer。

由于發(fā)送任務是由 MixPHP 執(zhí)行，所以 swiftmailer 是安裝在 MixPHP 項目中，在項目根目錄中執(zhí)行以下命令安裝：

composer require swiftmailer/swiftmailer

在郵件發(fā)送這個需求中生產者是指投遞發(fā)送任務的一方，這一方通常是一個接口或網頁，這個部分并不一定需 mixphp 開發(fā)，TP、CI、YII 這些都可以，只需在接口或網頁中把任務信息投遞到消息隊列中即可。

在傳統(tǒng) MVC 框架的控制器中增加如下代碼：

// 連接$redis = new /Redis();if (!$redis- connect( 127.0.0.1 , 6379)) { throw new /Exception( Redis Connect Failure $redis- auth( $redis- select(0);// 投遞任務$data = [ to = [ ***@qq.com = A name ], body = Here is the message itself , subject = The title content ,$redis- lpush( queue:email , serialize($data));

通常異步開發(fā)中，投遞完成后就會立即響應一個消息給用戶，當然此時該任務并沒有執(zhí)行。

本例我們使用 MixPHP 的多進程開發(fā)工具 TaskExecutor 來完成這個需求，通常使用常駐進程來處理隊列的消費，所以我們使用 TaskExecutor 的 TYPE_DAEMON 類型，MODE_PUSH 模式。

TaskExecutor 的 MODE_PUSH 模式有二種進程：

左進程：負責從消息隊列取出任務數(shù)據(jù)，投放給中進程。

中進程：負責執(zhí)行郵件發(fā)送任務。

PushCommand.php 代碼如下：

 ?phpnamespace apps/daemon/commands;use mix/console/ExitCode;use mix/facades/Input;use mix/facades/Redis;use mix/task/CenterProcess;use mix/task/LeftProcess;use mix/task/TaskExecutor; * 推送模式范例 * @author 劉健 coder.liu@qq.com html' target='_blank'>class PushCommand extends BaseCommand // 配置信息 const HOST = smtpdm.aliyun.com  const PORT = 465; const SECURITY = ssl  const USERNAME = ****@email.***.com  const PASSWORD = ****  // 初始化事件 public function onInitialize() parent::onInitialize(); // TODO: Change the autogenerated stub // 獲取程序名稱 $this- programName = Input::getCommandName(); // 設置pidfile $this- pidFile = /var/run/{$this- programName}.pid  * 獲取服務 * @return TaskExecutor public function getTaskService() return create_object( // 類路徑 class = mix/task/TaskExecutor , // 服務名稱 name = mix-daemon: {$this- programName} , // 執(zhí)行類型 type = /mix/task/TaskExecutor::TYPE_DAEMON, // 執(zhí)行模式 mode = /mix/task/TaskExecutor::MODE_PUSH, // 左進程數(shù) leftProcess = 1, // 中進程數(shù) centerProcess = 5, // 任務超時時間 (秒) timeout = 5, // 啟動 public function actionStart() // 預處理 if (!parent::actionStart()) { return ExitCode::UNSPECIFIED_ERROR; // 啟動服務 $service = $this- getTaskService(); $service- on( LeftStart , [$this, onLeftStart  $service- on( CenterStart , [$this, onCenterStart  $service- start(); // 返回退出碼 return ExitCode::OK; // 左進程啟動事件回調函數(shù) public function onLeftStart(LeftProcess $worker) try { // 模型內使用長連接版本的數(shù)據(jù)庫組件，這樣組件會自動幫你維護連接不斷線 $queueModel = Redis::getInstance(); // 保持任務執(zhí)行狀態(tài)，循環(huán)結束后當前進程會退出，主進程會重啟一個新進程繼續(xù)執(zhí)行任務，這樣做是為了避免長時間執(zhí)行內存溢出 for ($j = 0; $j 16000; $j++) { // 從消息隊列中間件阻塞獲取一條消息 $data = $queueModel- brpop( queue:email , 10); if (empty($data)) { continue; list(, $data) = $data; // 將消息推送給中進程去處理，push有長度限制 (http://wiki.swoole.com/wiki/page/290.html) $worker- push($data, false); } catch (/Exception $e) { // 休息一會，避免 CPU 出現(xiàn) 100% sleep(1); // 拋出錯誤 throw $e; // 中進程啟動事件回調函數(shù) public function onCenterStart(CenterProcess $worker) // 保持任務執(zhí)行狀態(tài)，循環(huán)結束后當前進程會退出，主進程會重啟一個新進程繼續(xù)執(zhí)行任務，這樣做是為了避免長時間執(zhí)行內存溢出 for ($j = 0; $j 16000; $j++) { // 從進程消息隊列中搶占一條消息 $data = $worker- pop(); if (empty($data)) { continue; // 處理消息 try { // 處理消息，比如：發(fā)送短信、發(fā)送郵件、微信推送 var_dump($data); $ret = self::sendEmail($data); var_dump($ret); } catch (/Exception $e) { // 回退數(shù)據(jù)到消息隊列 $worker- rollback($data); // 休息一會，避免 CPU 出現(xiàn) 100% sleep(1); // 拋出錯誤 throw $e; // 發(fā)送郵件 public static function sendEmail($data) // Create the Transport $transport = (new /Swift_SmtpTransport(self::HOST, self::PORT, self::SECURITY)) - setUsername(self::USERNAME) - setPassword(self::PASSWORD); // Create the Mailer using your created Transport $mailer = new /Swift_Mailer($transport); // Create a message $message = (new /Swift_Message($data[ subject ])) - setFrom([self::USERNAME = **網 ]) - setTo($data[ to ]) - setBody($data[ body  // Send the message $result = $mailer- send($message); return $result;}

在 shell 中啟動 push 常駐程序。

[root@localhost bin]# ./mix-daemon push startmix-daemon push start successed.

調用接口往消息隊列投放任務。

此時 shell 終端將打?。?/p>

成功收到測試郵件：

以上就是本文的全部內容，希望對大家的學習有所幫助，更多相關內容請關注PHP ！

相關推薦：

給PHP開啟shmop擴展實現(xiàn)共享內存

php實現(xiàn)共享內存進程通信函數(shù)（_shm）

以上就是使用 mixphp 打造多進程異步郵件發(fā)送的詳細內容，PHP教程

鄭重聲明：本文版權歸原作者所有，轉載文章僅為傳播更多信息之目的，如作者信息標記有誤，請第一時間聯(lián)系我們修改或刪除，多謝。