小編給大家分享一下使用mixphp打造多進(jìn)程異步郵件發(fā)送的方法，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！
10余年專注成都網(wǎng)站制作，成都定制網(wǎng)站，個(gè)人網(wǎng)站制作服務(wù)，為大家分享網(wǎng)站制作知識(shí)、方案，網(wǎng)站設(shè)計(jì)流程、步驟,成功服務(wù)上千家企業(yè)。為您提供網(wǎng)站建設(shè),網(wǎng)站制作,網(wǎng)頁(yè)設(shè)計(jì)及定制高端網(wǎng)站建設(shè)服務(wù),專注于成都定制網(wǎng)站,高端網(wǎng)頁(yè)制作,對(duì)成都辦公窗簾等多個(gè)領(lǐng)域，擁有豐富的網(wǎng)站運(yùn)維經(jīng)驗(yàn)。
注意：這個(gè)是 MixPHP V1 的范例
郵件發(fā)送是很常見(jiàn)的需求，由于發(fā)送郵件的操作一般是比較耗時(shí)的，所以我們一般采用異步處理來(lái)提升用戶體驗(yàn)，而異步通常我們使用消息隊(duì)列來(lái)實(shí)現(xiàn)。
傳統(tǒng) MVC 框架由于缺少多進(jìn)程開(kāi)發(fā)能力，通常是采用同一個(gè)腳本執(zhí)行多次，產(chǎn)生多個(gè)進(jìn)程的方式，mixphp 封裝了 TaskExecutor 專用于多進(jìn)程開(kāi)發(fā)，用戶能非常簡(jiǎn)單的開(kāi)發(fā)出功能完善的高可用多進(jìn)程應(yīng)用。
下面演示一個(gè)異步郵件發(fā)送系統(tǒng)的開(kāi)發(fā)過(guò)程，涉及知識(shí)點(diǎn)：
PHP 使用消息隊(duì)列通常是使用中間件來(lái)實(shí)現(xiàn)，常用的消息中間件有：
本次我們選用 redis 來(lái)實(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ā)送庫(kù)選型
以往我們通常使用框架提供的郵件發(fā)送庫(kù)，或者網(wǎng)上下載別的用戶分享的庫(kù)，composer 出現(xiàn)后，https://packagist.org/ 上有大量?jī)?yōu)質(zhì)的庫(kù)，我們只需選擇一個(gè)最好的即可，本例選擇 swiftmailer。
由于發(fā)送任務(wù)是由 MixPHP 執(zhí)行，所以 swiftmailer 是安裝在 MixPHP 項(xiàng)目中，在項(xiàng)目根目錄中執(zhí)行以下命令安裝：
composer require swiftmailer/swiftmailer
生產(chǎn)者開(kāi)發(fā)
在郵件發(fā)送這個(gè)需求中生產(chǎn)者是指投遞發(fā)送任務(wù)的一方，這一方通常是一個(gè)接口或網(wǎng)頁(yè)，這個(gè)部分并不一定需 mixphp 開(kāi)發(fā)，TP、CI、YII 這些都可以，只需在接口或網(wǎng)頁(yè)中把任務(wù)信息投遞到消息隊(duì)列中即可。
在傳統(tǒng) MVC 框架的控制器中增加如下代碼：
通?？蚣苤惺褂?redis 會(huì)安裝一個(gè)類庫(kù)來(lái)使用，本例使用原生代碼，便于理解。
重慶分公司
重慶分公司
// 連接
$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));通常異步開(kāi)發(fā)中，投遞完成后就會(huì)立即響應(yīng)一個(gè)消息給用戶，當(dāng)然此時(shí)該任務(wù)并沒(méi)有執(zhí)行。
消費(fèi)者開(kāi)發(fā)
本例我們使用 MixPHP 的多進(jìn)程開(kāi)發(fā)工具 TaskExecutor 來(lái)完成這個(gè)需求，通常使用常駐進(jìn)程來(lái)處理隊(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 代碼如下：
*/
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\task\TaskExecutor',
// 服務(wù)名稱
'name' => "mix-daemon: {$this->programName}",
// 執(zhí)行類型
'type' => \mix\task\TaskExecutor::TYPE_DAEMON,
// 執(zhí)行模式
'mode' => \mix\task\TaskExecutor::MODE_PUSH,
// 左進(jìn)程數(shù)
'leftProcess' => 1,
// 中進(jìn)程數(shù)
'centerProcess' => 5,
// 任務(wù)超時(shí)時(shí)間 (秒)
'timeout' => 5,
]
);
}
// 啟動(dòng)
public function actionStart()
{
// 預(yù)處理
if (!parent::actionStart()) {
return ExitCode::UNSPECIFIED_ERROR;
}
// 啟動(dòng)服務(wù)
$service = $this->getTaskService();
$service->on('LeftStart', [$this, 'onLeftStart']);
$service->on('CenterStart', [$this, 'onCenterStart']);
$service->start();
// 返回退出碼
return ExitCode::OK;
}
// 左進(jìn)程啟動(dòng)事件回調(diào)函數(shù)
public function onLeftStart(LeftProcess $worker)
{
try {
// 模型內(nèi)使用長(zhǎng)連接版本的數(shù)據(jù)庫(kù)組件，這樣組件會(huì)自動(dòng)幫你維護(hù)連接不斷線
$queueModel = Redis::getInstance();
// 保持任務(wù)執(zhí)行狀態(tài)，循環(huán)結(jié)束后當(dāng)前進(jìn)程會(huì)退出，主進(jìn)程會(huì)重啟一個(gè)新進(jìn)程繼續(xù)執(zhí)行任務(wù)，這樣做是為了避免長(zhǎng)時(shí)間執(zhí)行內(nèi)存溢出
for ($j = 0; $j < 16000; $j++) {
// 從消息隊(duì)列中間件阻塞獲取一條消息
$data = $queueModel->brpop('queue:email', 10);
if (empty($data)) {
continue;
}
list(, $data) = $data;
// 將消息推送給中進(jìn)程去處理，push有長(zhǎng)度限制 (https://wiki.swoole.com/wiki/page/290.html)
$worker->push($data, false);
}
} catch (\Exception $e) {
// 休息一會(huì)，避免 CPU 出現(xiàn) 100%
sleep(1);
// 拋出錯(cuò)誤
throw $e;
}
}
// 中進(jìn)程啟動(dòng)事件回調(diào)函數(shù)
public function onCenterStart(CenterProcess $worker)
{
// 保持任務(wù)執(zhí)行狀態(tài)，循環(huán)結(jié)束后當(dāng)前進(jìn)程會(huì)退出，主進(jìn)程會(huì)重啟一個(gè)新進(jìn)程繼續(xù)執(zhí)行任務(wù)，這樣做是為了避免長(zhǎng)時(shí)間執(zhí)行內(nèi)存溢出
for ($j = 0; $j < 16000; $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);
// 休息一會(huì)，避免 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;
}
}測(cè)試
1.在 shell 中啟動(dòng) push 常駐程序。
[root@localhost bin]# ./mix-daemon push start mix-daemon 'push' start successed.
1.調(diào)用接口往消息隊(duì)列投放任務(wù)。
此時(shí) shell 終端將打?。?/p>
成功收到測(cè)試郵件：
以上是使用mixphp打造多進(jìn)程異步郵件發(fā)送的方法的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！
