Thinkphp5 및 swoole을 사용하여 SMTP를 사용하여 비동기 대량 메일링을 구현하는 예

이 글에서는 비동기식 대량 메일링(SMTP 방식)을 구현하기 위한 thinkphp5+swoole에 대한 자세한 설명을 주로 소개하며, 관심 있는 친구들은 참고할 수 있습니다.

이 글에서는 비동기식 대량 메일링을 구현하기 위한 thinkphp5+swoole의 구현 방법을 소개합니다. (SMTP 방식). 세부 사항은 다음과 같습니다.

1. 환경 설명

• Alibaba Cloud centos7

• thinkphp5.0.11

• swoole2.0.8

2.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.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 프로토콜이므로 패키징 수준에서는 그다지 포괄적이지 않고 유연성도 떨어집니다. 그림의 다른 두 파일(PhpMailer.php 및 Smtp.php)은 호출을 단순화하기 위해 Phpmailer 이메일 전송 클래스의 핵심 파일입니다. 자세한 사용법 및 매개변수 설정은 gayhub의 사용법을 참조하세요. 지침 phpmailer

2.2 주의 사항

이 단계에서는 몇 가지 사항에 주의해야 합니다. 1. 이메일을 보내도록 설정한 계정이 SMTP를 활성화했는지 여부와 해당 보안 프로토콜 및 포트 번호를 찾습니다. 2. 현재 서버가 일부 소켓 기능의 영향을 받는 경우가 많은 SMTP 서비스를 지원하는지 여부 문제가 발생하면 SMTPDebug 매개변수를 1로 설정한 다음 디버그 정보를 기반으로 신중하게 디버그해야 합니다. 3. 발송된 이메일 중 일부는 휴지통으로 들어가게 되므로 잘 확인하시기 바랍니다.

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를 사용하여 방금 보낸 이메일을 사서함의 휴지통에서 찾을 수 있습니다

3. swoole을 결합하여 비동기 대량 전송을 구현합니다. 3.1 swoole 설치

swoole 확장 설치에 ​​대한 자세한 단계는 공식 웹 사이트에서 확인할 수 있으므로 자세한 내용은 다루지 않겠습니다. swoole 문서 포털

swoole을 설치한 후 IDE에 swoole 코드 프롬프트를 추가하고 IDE 프롬프트 swoole code

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(&#39;937069176@qq.com&#39;,&#39;test&#39;,$data)){
     echo &#39;send&#39;.$i.&#39; success&#39;."\n";
    }else{
     echo &#39;send&#39;.$i.&#39; fail&#39;."\n";
    }
  }
  $serv->finish(&#39;&#39;);
  });

  $serv->on(&#39;finish&#39;, function ($serv, $task_id, $data) {
   echo "异步任务[id=$task_id]完成".PHP_EOL;
  });

  $serv->start();
 }

서버 측에서는 20의 루프를 사용하여 대량 전송을 시뮬레이션하고 실제로 다른 이메일 주소로 변경했습니다.

다음으로 클라이언트를 구현합니다.

 /**
  * 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번 연속으로 실행합니다. . 터미널 방법

실행 결과는 다음과 같습니다.

그림의 전송 순서를 보면 비동기 전송을 구현했음을 쉽게 알 수 있습니다.

방금 보낸 이메일도 메일함에 도착했어요.

4. Postscript~

swoole은 익숙해지고 능숙하게 사용하고 싶은 확장 기능이지만 네트워크 프로그래밍 지식이 부족하여 제한적이므로 아직 더 테스트하고 배워야 합니다. 데모에도 부족한 점이 있고, QAQ

에도 아직 부족한 부분이 있습니다.

위 내용은 Thinkphp5 및 swoole을 사용하여 SMTP를 사용하여 비동기 대량 메일링을 구현하는 예의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!