注意：
這個(gè)是 MixPHP V1 的范例郵件發(fā)送是很常見的需求，由于發(fā)送郵件的操作一般是比較耗時(shí)的，所以我們一般采用異步處理來提升用戶體驗(yàn)，而異步通常我們使用消息隊(duì)列來實(shí)現(xiàn)。
傳統(tǒng) MVC 框架由于缺少多進(jìn)程開發(fā)能力，通常是采用同一個(gè)腳本執(zhí)行多次，產(chǎn)生多個(gè)進(jìn)程的方式，mixphp 封裝了 TaskExecutor 專用于多進(jìn)程開發(fā)，用戶能非常簡單的開發(fā)出功能完善的高可用多進(jìn)程應(yīng)用。
推薦：
《PHP視頻教程》下面演示一個(gè)異步郵件發(fā)送系統(tǒng)的開發(fā)過程，涉及知識點(diǎn)：
異步消息隊(duì)列多進(jìn)程守護(hù)進(jìn)程如何使用消息隊(duì)列實(shí)現(xiàn)異步PHP 使用消息隊(duì)列通常是使用中間件來實(shí)現(xiàn)，常用的消息中間件有：
redisrabbitmqkafka本次我們選用 redis 來實(shí)現(xiàn)異步郵件發(fā)送，redis 的數(shù)據(jù)類型中有一個(gè) list 類型，可實(shí)現(xiàn)消息隊(duì)列，使用以下命令：
// 入列 $redis->lpush($key, $data);
// 出列 $data = $redis->rpop($key);
// 阻塞出列 $data = $redis->brpop($key, 10);
架構(gòu)設(shè)計(jì)本實(shí)例由傳統(tǒng) MVC 框架投遞郵件發(fā)送需求，MixPHP 多進(jìn)程執(zhí)行發(fā)送任務(wù)。
郵件發(fā)送庫選型以往我們通常使用框架提供的郵件發(fā)送庫，或者網(wǎng)上下載別的用戶分享的庫，composer 出現(xiàn)后，https://packagist.org/ 上有大量優(yōu)質(zhì)的庫，我們只需選擇一個(gè)最好的即可，本例選擇 swiftmailer。
由于發(fā)送任務(wù)是由 MixPHP 執(zhí)行，所以 swiftmailer 是安裝在 MixPHP 項(xiàng)目中，在項(xiàng)目根目錄中執(zhí)行以下命令安裝：
composer require swiftmailer/swiftmailer生產(chǎn)者開發(fā)在郵件發(fā)送這個(gè)需求中生產(chǎn)者是指投遞發(fā)送任務(wù)的一方，這一方通常是一個(gè)接口或網(wǎng)頁，這個(gè)部分并不一定需 mixphp 開發(fā)，TP、CI、YII 這些都可以，只需在接口或網(wǎng)頁中把任務(wù)信息投遞到消息隊(duì)列中即可。
在傳統(tǒng) MVC 框架的控制器中增加如下代碼：
通常框架中使用 redis 會安裝一個(gè)類庫來使用，本例使用原生代碼，便于理解。
// 連接 $redis = new Redis();
if (!$redis->connect('
127.0.0.1'
, 6379)) {
throw new Exception('
Redis Connect Failure'
);
}
$redis->auth('
'
);
$redis->select(0);
// 投遞任務(wù) $data = [ '
to'
=> ['
***@qq.com'
=> '
A name'
], '
body'
=> '
Here is the message itself'
, '
subject'
=> '
The title content'
, ];
$redis->lpush('
queue:email'
, serialize($data));
通常異步開發(fā)中，投遞完成后就會立即響應(yīng)一個(gè)消息給用戶，當(dāng)然此時(shí)該任務(wù)并沒有執(zhí)行。
消費(fèi)者開發(fā)本例我們使用 MixPHP 的多進(jìn)程開發(fā)工具 TaskExecutor 來完成這個(gè)需求，通常使用常駐進(jìn)程來處理隊(duì)列的消費(fèi)，所以我們使用 TaskExecutor 的 TYPE_DAEMON 類型，MODE_PUSH 模式。
TaskExecutor 的 MODE_PUSH 模式有二種進(jìn)程：
左進(jìn)程：
負(fù)責(zé)從消息隊(duì)列取出任務(wù)數(shù)據(jù)，投放給中進(jìn)程。
中進(jìn)程：
負(fù)責(zé)執(zhí)行郵件發(fā)送任務(wù)。
PushCommand.php 代碼如下：
use mixconsoleExitCode;
use mixfacadesInput;
use mixfacadesRedis;
use mix askCenterProcess;
use mix askLeftProcess;
use mix askTaskExecutor;
/** * 推送模式范例 * @author 劉健 */ 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();
// 設(shè)置pidfile $this->pidFile = "/var/run/{
$this->programName}
.pid";
}
/** * 獲取服務(wù) * @return TaskExecutor */ public function getTaskService() {
return create_object( [ // 類路徑 '
class'
=> '
mix askTaskExecutor'
, // 服務(wù)名稱 '
name'
=> "mix-daemon: {
$this->programName}
", // 執(zhí)行類型 '
type'
=> mix askTaskExecutor::TYPE_DAEMON, // 執(zhí)行模式 '
mode'
=> mix askTaskExecutor::MODE_PUSH, // 左進(jìn)程數(shù) '
leftProcess'
=> 1, // 中進(jìn)程數(shù) '
centerProcess'
=> 5, // 任務(wù)超時(shí)時(shí)間 (秒) '
timeout'
=> 5, ] );
}
// 啟動 public function actionStart() {
// 預(yù)處理 if (!parent::actionStart()) {
return ExitCode::UNSPECIFIED_ERROR;
}
// 啟動服務(wù) $service = $this->getTaskService();
$service->on('
LeftStart'
, [$this, '
onLeftStart'
]);
$service->on('
CenterStart'
, [$this, '
onCenterStart'
]);
$service->start();
// 返回退出碼 return ExitCode::OK;
}
// 左進(jìn)程啟動事件回調(diào)函數(shù) public function onLeftStart(LeftProcess $worker) {
try {
// 模型內(nèi)使用長連接版本的數(shù)據(jù)庫組件，這樣組件會自動幫你維護(hù)連接不斷線 $queueModel = Redis::getInstance();
// 保持任務(wù)執(zhí)行狀態(tài)，循環(huán)結(jié)束后當(dāng)前進(jìn)程會退出，主進(jìn)程會重啟一個(gè)新進(jìn)程繼續(xù)執(zhí)行任務(wù)，這樣做是為了避免長時(shí)間執(zhí)行內(nèi)存溢出 for ($j = 0;
$j $j++) {
// 從消息隊(duì)列中間件阻塞獲取一條消息 $data = $queueModel->brpop('
queue:email'
, 10);
if (empty($data)) {
continue;
}
list(, $data) = $data;
// 將消息推送給中進(jìn)程去處理，push有長度限制 (https://wiki.swoole.com/wiki/page/290.html) $worker->push($data, false);
}
}
catch (Exception $e) {
// 休息一會，避免 CPU 出現(xiàn) 100% sleep(1);
// 拋出錯(cuò)誤 throw $e;
}
}
// 中進(jìn)程啟動事件回調(diào)函數(shù) public function onCenterStart(CenterProcess $worker) {
// 保持任務(wù)執(zhí)行狀態(tài)，循環(huán)結(jié)束后當(dāng)前進(jìn)程會退出，主進(jìn)程會重啟一個(gè)新進(jìn)程繼續(xù)執(zhí)行任務(wù)，這樣做是為了避免長時(shí)間執(zhí)行內(nèi)存溢出 for ($j = 0;
$j $j++) {
// 從進(jìn)程消息隊(duì)列中搶占一條消息 $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ù)到消息隊(duì)列 $worker->rollback($data);
// 休息一會，避免 CPU 出現(xiàn) 100% sleep(1);
// 拋出錯(cuò)誤 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 => '
**網(wǎng)'
]) ->setTo($data['
to'
]) ->setBody($data['
body'
]);
// Send the message $result = $mailer->send($message);
return $result;
}
}
測試1.在 shell 中啟動 push 常駐程序。
[root@localhost bin]# ./mix-daemon push start mix-daemon '
push'
start successed.1.調(diào)用接口往消息隊(duì)列投放任務(wù)。
此時(shí) shell 終端將打?。?br>成功收到測試郵件：
MixPHPGitHub: https://github.com/mix-php/mix官網(wǎng)：
http://www.mixphp.cn/以上就是教你使用mixphp打造多進(jìn)程異步郵件發(fā)送的詳細(xì)內(nèi)容，更多請關(guān)注php中文網(wǎng)其它相關(guān)文章！
微信
分享相關(guān)標(biāo)簽：
mixphp本文轉(zhuǎn)載于：
segmentfault，如有侵犯，請聯(lián)系[email protected]刪除
上一篇：
【記錄】PHP-fpm占CPU 100%修復(fù)
下一篇：
值得一看！高級PHP工程師必備的編碼技巧及思維相關(guān)文章相關(guān)視頻使用 mixphp 打造多進(jìn)程異步郵件發(fā)送如何使用MixPHP來開發(fā)API接口詳解PHP使用gearman進(jìn)行異步的郵件或短信發(fā)...php異步調(diào)用方法是什么教你使用mixphp打造多進(jìn)程異步郵件發(fā)送數(shù)據(jù)表的連接與新增操作2數(shù)據(jù)表的連接與新增操作1數(shù)組常用函數(shù)-3數(shù)組常用函數(shù)-2 [溫州做網(wǎng)站PHP教程]