thinkphp5+swoole實現異步郵件羣發（SMTP方式）

一、環境說明

阿里雲centos7
thinkphp5.0.11
swoole2.0.8

二、tp實現郵件發送

在項目下創建以下的文件目錄：

其中SendMail.php是咱們實際調用的發送郵件的文件。如下是主要代碼：

namespace app\library\utils\mail;
use app\library\utils\mail\PhpMailer;
use app\library\utils\mail\Smtp;
use think\Log;

error_reporting(E_STRICT);
date_default_timezone_set('Asia/Shanghai');

class SendMail
{
    static function postmail($to,$subject = '',$body = ''){
        $mail = new PhpMailer();
        $mail->CharSet    = config('mail.CharSet');
        $mail->IsSMTP();
        $mail->SMTPDebug  = config('mail.SMTPDebug');
        $mail->SMTPAuth   = config('mail.SMTPAuth');
        $mail->SMTPSecure = config('mail.SMTPSecure');
        $mail->Host       = config('mail.Host');
        $mail->Port       = config('mail.Port');
        $mail->Username   = config('mail.Username');
        $mail->Password   = config('mail.Password');
        $mail->SetFrom(config('mail.From'), config('mail.Name'));
        $mail->Subject    = $subject;
        $mail->MsgHTML($body);
        $address = $to;
        $mail->AddAddress($address, '');
        if(!$mail->Send()) {
            Log::write('send to '.$to.'error info:'.$mail->ErrorInfo);
            return false;
        } else {
            return true;
        }
    }
}

裏面的config配置項，咱們放在項目底下的config.php文件中，具體配置內容以下:

//郵箱設置
    'mail'=>[
        'CharSet'=>'UTF-8',
        'SMTPDebug'=>0,// 啓用SMTP調試功能 0關閉
        'SMTPAuth'=>true,// 啓用 SMTP 驗證功能
        'SMTPSecure'=>'ssl',// 安全協議
        'Host'=>'smtp.163.com',// SMTP 服務器
        'Port'=>465,// SMTP服務器的端口號
        'Username'=>'**********',// SMTP服務器用戶名
        'Password'=>'**********',// SMTP服務器密碼
        'From'=>'*********@163.com',// 發件人郵箱
        'Name'=>'blue',// 發件人郵箱
    ]

2.1

這裏咱們只是實現了smtp協議發送的demo，因此在封裝的層面上沒有作到很全面，不是很靈活。圖中其餘兩個文件（PhpMailer.php和Smtp.php）是Phpmailer郵件發送類的核心文件，爲了簡化調用，抽取了出來，詳細的用法和參數設置，能夠參考gayhub的使用說明phpmailer

2.2 注意點

在此步驟中，咱們須要注意幾點：1是你設置的郵件發送的帳號是否已經開啓SMTP而且找對對應的安全協議和端口號。二、當前服務器是否支持SMTP服務，這邊不少時候會受一些socket函數的影響，遇到問題的時候，咱們應該把SMTPDebug參數設置爲1，而後根據debug信息去細心調試。三、發出的郵件有些會被放入垃圾箱，注意查收。

2.3 調用

創建以下的文件目錄結構：

在Index.php中調用發送郵件的方法,具體代碼以下

public function sendMail(){
        if(SendMail::postmail('937069176@qq.com','test','123')){
            echo 'send success';
        }else{
            echo 'send fail';
        }
    }

2.4 調用結果

咱們能夠在QQ郵箱的垃圾箱中找到咱們剛剛發送的一封郵件

三、結合swoole實現異步羣發

3.1安裝swoole

swoole擴展安裝的詳細步驟官網上面都有，再也不贅述，swoole文檔傳送門
安裝完swoole以後，建議爲本身的IDE加上swoole的代碼提示，配置IDE提示swoole代碼的傳送門

3.2實現異步羣發

咱們先實現異步的服務端：

/**
     * description:服務端
     */
    public function syncSend(){
        $serv = new \swoole_server('0.0.0.0',8082);

        $serv->set(array('task_worker_num' => 4));

        $serv->on('receive', function($serv, $fd, $from_id, $data) {
            $task_id = $serv->task($data);
            echo "開始投遞異步任務 id=$task_id\n";
        });

        $serv->on('task', function ($serv, $task_id, $from_id, $data) {
            echo "接收異步任務[id=$task_id]".PHP_EOL;
            for ($i = 0 ; $i<20;$i++){
                if(SendMail::postmail('937069176@qq.com','test',$data)){
                    echo 'send'.$i.' success'."\n";
                }else{
                    echo 'send'.$i.' fail'."\n";
                }
        }
        $serv->finish('');
        });

        $serv->on('finish', function ($serv, $task_id, $data) {
            echo "異步任務[id=$task_id]完成".PHP_EOL;
        });

        $serv->start();
    }

在服務端，咱們用了一個20的loop來模擬了羣發，實際換成不一樣的email地址就可。
下面咱們實現客戶端

/**
     * description:客戶端
     */
    public function index()
    {
        $client = new \swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_SYNC);
        $ret = $client->connect("127.0.0.1", 8082);
        if(empty($ret)){
            echo 'error!connect to swoole_server failed';
        } else {
            $client->send('blue');//這裏只是簡單的實現了發送的內容
        }
    }

3.3開啓服務端

這裏必需要用CLI方式，咱們進入項目的根目錄。
執行

netstat -apn | grep 8082

先監測一下8082端口是否被佔用，若是佔用則

kill -9 PID(進程號)

殺死進程

而後咱們執行

php public/index.php index/index/syncSend

這條命令的做用是用cli模式來使咱們的8082端口處於監聽狀態。且保持這個終端處於活躍狀態，這樣方便咱們查看發送的結果。

接着咱們能夠用CLI或者瀏覽器訪問的方式來訪問咱們的客戶端

php public/index.php index/index/index

當咱們執行一次的時候客戶端的時候，咱們能夠在服務端的終端看到屏幕上面出現以下的畫面：

說明咱們已經正常羣發了。
下面，咱們就來測試異步，由於163服務器會對IP進行檢測，若是在某個時間發送也別頻繁的話，會出現發送失敗的狀況，因此咱們測試的時候，採用連續執行4次客戶端的方式
下面是執行的結果：

從圖中發送的順序來看，咱們能夠很容易的判斷，咱們已經實現了異步的發送。
郵箱裏面也接收到了剛剛發送的郵件。

四、後記~

swoole是一種想要熟悉和熟練使用的擴展，可是限於網絡編程知識的不足，因此仍是要多多測試和學習，demo中有不足的地方，還請指出QAQ