詳解thinkphp5+swoole實(shí)現(xiàn)異步郵件群發(fā)（SMTP方式）

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;
  }
 }
}

//郵箱設(shè)置
 'mail'=>[
  'CharSet'=>'UTF-8',
  'SMTPDebug'=>0,// 啟用SMTP調(diào)試功能 0關(guān)閉
  'SMTPAuth'=>true,// 啟用 SMTP 驗(yàn)證功能
  'SMTPSecure'=>'ssl',// 安全協(xié)議
  'Host'=>'smtp.163.com',// SMTP 服務(wù)器
  'Port'=>465,// SMTP服務(wù)器的端口號
  'Username'=>'**********',// SMTP服務(wù)器用戶名
  'Password'=>'**********',// SMTP服務(wù)器密碼
  'From'=>'*********@163.com',// 發(fā)件人郵箱
  'Name'=>'blue',// 發(fā)件人郵箱
 ]

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

 /**
  * description:服務(wù)端
  */
 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 "開始投遞異步任務(wù) id=$task_id\n";
  });

  $serv->on('task', function ($serv, $task_id, $from_id, $data) {
   echo "接收異步任務(wù)[id=$task_id]".PHP_EOL;
   for ($i = 0 ; $i20;$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 "異步任務(wù)[id=$task_id]完成".PHP_EOL;
  });

  $serv->start();
 }

 /**
  * 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');//這里只是簡單的實(shí)現(xiàn)了發(fā)送的內(nèi)容
  }
 }

netstat -apn | grep 8082

kill -9 PID(進(jìn)程號)

php public/index.php index/index/syncSend

php public/index.php index/index/index