thinkphp5와 swoole을 이용한 비동기식 대량 메일링 구현 방법

이 글은 주로 thinkphp5와 swoole의 비동기 대량 메일링 구현 방법을 공유합니다. 도움이 되길 바랍니다.

1. 환경 설명

Alibaba Cloud centos7
thinkphp5.0.11
swoole2.0.8

2. tp는 이메일 전송을 구현합니다

프로젝트 아래에 다음 파일 디렉터리를 만듭니다.

그중 SendM ail.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의 사용법을 참조하세요. 지침 for 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 문서 포털
이 설치된 후 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(&#39;task&#39;, 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、后记~

swoole是一种想要熟悉和熟练使用的扩展，但是限于网络编程知识的不足，所以还是要多多测试和学习，demo中有不足的地方，还请指出。

위 내용은 thinkphp5와 swoole을 이용한 비동기식 대량 메일링 구현 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!