mixphp를 사용하여 다중 프로세스 비동기 이메일 전송 생성-PHP 튜토리얼-php.cn

이 글은 주로 mixphp를 사용하여 다중 프로세스 비동기 이메일 전송을 생성하는 방법을 소개합니다. 이제는 도움이 필요한 친구들이 참고할 수 있습니다. 이메일을 보내는 작업은 일반적으로 시간이 많이 걸리므로 사용자 경험을 향상시키기 위해 일반적으로 비동기 처리를 사용하며 비동기 처리는 일반적으로 메시지 대기열을 사용하여 구현됩니다.

다중 프로세스 개발 기능이 부족하기 때문에 기존 MVC 프레임워크는 일반적으로 동일한 스크립트를 여러 번 실행하여 여러 프로세스를 생성합니다. Mixphp는 TaskExecutor를 캡슐화하며 사용자가 쉽게 고급 프로세스 개발을 할 수 있습니다. 완전한 기능을 갖춘 고성능 애플리케이션을 사용할 수 있습니다.

다음은 지식 포인트를 포함하는 비동기식 이메일 전송 시스템의 개발 프로세스를 보여줍니다.

PHP의 메시지 대기열 사용을 구현하려면 일반적으로 사용되는 중간 전쟁은 다음과 같습니다. 보내는 중, 메시지 대기열을 구현할 수 있는 목록 형식이 있습니다. 다음 명령을 사용하세요:

// 入列
$redis->lpush($key, $data);
// 出列
$data = $redis->rpop($key);
// 阻塞出列
$data = $redis->brpop($key, 10);

로그인 후 복사

Architecture design

이메일 전송 라이브러리 선택
전송 작업은 MixPHP에 의해 실행되므로, Swiftmailer는 MixPHP 프로젝트에 설치됩니다. 설치하려면 프로젝트 루트 디렉토리에서 다음 명령을 실행하십시오.
```
composer require swiftmailer/swiftmailer
```
로그인 후 복사
이메일 전송 요구 사항에서 생산자는 다음을 참조합니다. 전달 및 전송 작업 이 부분은 일반적으로 mixphp로 개발할 필요는 없습니다. TP, CI 및 YII는 모두 허용됩니다. 인터페이스 또는 웹 페이지.

일반적으로 프레임워크에서 redis를 사용할 때 클래스 라이브러리를 설치하여 사용합니다. 이 예제에서는 이해하기 쉽도록 네이티브 코드를 사용합니다.

// 连接
$redis = new \Redis();
if (!$redis->connect(&#39;127.0.0.1&#39;, 6379)) {
    throw new \Exception(&#39;Redis Connect Failure&#39;);
}
$redis->auth(&#39;&#39;);
$redis->select(0);
// 投递任务
$data = [
    &#39;to&#39;      => [&#39;***@qq.com&#39; => &#39;A name&#39;],
    &#39;body&#39;    => &#39;Here is the message itself&#39;,
    &#39;subject&#39; => &#39;The title content&#39;,
];
$redis->lpush(&#39;queue:email&#39;, serialize($data));

로그인 후 복사

보통 비동기 개발에서는 전달이 완료된 후 즉시 사용자에게 메시지가 응답됩니다. 물론 이때 작업은 실행되지 않습니다.

소비자 개발

이 예에서는 MixPHP의 다중 프로세스 개발 도구 TaskExecutor를 사용하여 이 요구 사항을 완료합니다. 상주 프로세스는 일반적으로 대기열 소비를 처리하는 데 사용되므로 TaskExecutor의 TYPE_DAEMON 유형 및 MODE_PUSH 모드를 사용합니다.

TaskExecutor의 MODE_PUSH 모드에는 두 가지 프로세스가 있습니다.

왼쪽 프로세스: 메시지 큐에서 작업 데이터를 꺼내어 중간 프로세스에 넣는 역할을 담당합니다.

중간 프로세스: 이메일 전송 작업 실행을 담당합니다.

PushCommand.php 코드는 다음과 같습니다.

<?php

namespace apps\daemon\commands;

use mix\console\ExitCode;
use mix\facades\Input;
use mix\facades\Redis;
use mix\task\CenterProcess;
use mix\task\LeftProcess;
use mix\task\TaskExecutor;

/**
 * 推送模式范例
 * @author 刘健 <coder.liu@qq.com>
 */
class PushCommand extends BaseCommand
{

    // 配置信息
    const HOST = &#39;smtpdm.aliyun.com&#39;;
    const PORT = 465;
    const SECURITY = &#39;ssl&#39;;
    const USERNAME = &#39;****@email.***.com&#39;;
    const PASSWORD = &#39;****&#39;;

    // 初始化事件
    public function onInitialize()
    {
        parent::onInitialize(); // TODO: Change the autogenerated stub
        // 获取程序名称
        $this->programName = Input::getCommandName();
        // 设置pidfile
        $this->pidFile = "/var/run/{$this->programName}.pid";
    }

    /**
     * 获取服务
     * @return TaskExecutor
     */
    public function getTaskService()
    {
        return create_object(
            [
                // 类路径
                &#39;class&#39;         => &#39;mix\task\TaskExecutor&#39;,
                // 服务名称
                &#39;name&#39;          => "mix-daemon: {$this->programName}",
                // 执行类型
                &#39;type&#39;          => \mix\task\TaskExecutor::TYPE_DAEMON,
                // 执行模式
                &#39;mode&#39;          => \mix\task\TaskExecutor::MODE_PUSH,
                // 左进程数
                &#39;leftProcess&#39;   => 1,
                // 中进程数
                &#39;centerProcess&#39; => 5,
                // 任务超时时间 (秒)
                &#39;timeout&#39;       => 5,
            ]
        );
    }

    // 启动
    public function actionStart()
    {
        // 预处理
        if (!parent::actionStart()) {
            return ExitCode::UNSPECIFIED_ERROR;
        }
        // 启动服务
        $service = $this->getTaskService();
        $service->on(&#39;LeftStart&#39;, [$this, &#39;onLeftStart&#39;]);
        $service->on(&#39;CenterStart&#39;, [$this, &#39;onCenterStart&#39;]);
        $service->start();
        // 返回退出码
        return ExitCode::OK;
    }

    // 左进程启动事件回调函数
    public function onLeftStart(LeftProcess $worker)
    {
        try {
            // 模型内使用长连接版本的数据库组件，这样组件会自动帮你维护连接不断线
            $queueModel = Redis::getInstance();
            // 保持任务执行状态，循环结束后当前进程会退出，主进程会重启一个新进程继续执行任务，这样做是为了避免长时间执行内存溢出
            for ($j = 0; $j < 16000; $j++) {
                // 从消息队列中间件阻塞获取一条消息
                $data = $queueModel->brpop(&#39;queue:email&#39;, 10);
                if (empty($data)) {
                    continue;
                }
                list(, $data) = $data;
                // 将消息推送给中进程去处理，push有长度限制 (https://wiki.swoole.com/wiki/page/290.html)
                $worker->push($data, false);
            }
        } catch (\Exception $e) {
            // 休息一会，避免 CPU 出现 100%
            sleep(1);
            // 抛出错误
            throw $e;
        }
    }

    // 中进程启动事件回调函数
    public function onCenterStart(CenterProcess $worker)
    {
        // 保持任务执行状态，循环结束后当前进程会退出，主进程会重启一个新进程继续执行任务，这样做是为了避免长时间执行内存溢出
        for ($j = 0; $j < 16000; $j++) {
            // 从进程消息队列中抢占一条消息
            $data = $worker->pop();
            if (empty($data)) {
                continue;
            }
            // 处理消息
            try {
                // 处理消息，比如：发送短信、发送邮件、微信推送
                var_dump($data);
                $ret = self::sendEmail($data);
                var_dump($ret);
            } catch (\Exception $e) {
                // 回退数据到消息队列
                $worker->rollback($data);
                // 休息一会，避免 CPU 出现 100%
                sleep(1);
                // 抛出错误
                throw $e;
            }
        }
    }

    // 发送邮件
    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[&#39;subject&#39;]))
            ->setFrom([self::USERNAME => &#39;**网&#39;])
            ->setTo($data[&#39;to&#39;])
            ->setBody($data[&#39;body&#39;]);
        // Send the message
        $result = $mailer->send($message);
        return $result;
    }

}

로그인 후 복사