mixphp를 사용하여 다중 프로세스 비동기 이메일 전송 생성

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

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

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

Asynchronous
Message Queue
다중 프로세스
Daemon
사용 방법 메시지 대기열 비동기식

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

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

Architecture design

이 예에서는 기존 MVC 프레임워크를 사용하여 이메일 보내기 요구 사항을 전달하고 MixPHP 다중 전송 작업을 수행하는 프로세스입니다.

• 이메일 전송 라이브러리 선택

예전에는 프레임워크에서 제공하는 이메일 전송 라이브러리를 주로 사용했거나 온라인에서 다른 사용자가 공유하는 라이브러리를 다운로드했는데, Composer가 등장한 이후에는 https에 고품질 라이브러리가 많이 있습니다. //packagist.org/. 우리는 가장 좋은 것을 선택합니다. 이 경우에는 Swiftmailer입니다.

• 전송 작업은 MixPHP에 의해 실행되므로, Swiftmailer는 MixPHP 프로젝트에 설치됩니다. 설치하려면 프로젝트 루트 디렉토리에서 다음 명령을 실행하십시오.

  composer require swiftmailer/swiftmailer

Producer development

• 이메일 전송 요구 사항에서 생산자는 다음을 참조합니다. 전달 및 전송 작업 이 부분은 일반적으로 mixphp로 개발할 필요는 없습니다. TP, CI 및 YII는 모두 허용됩니다. 인터페이스 또는 웹 페이지.

기존 MVC 프레임워크의 컨트롤러에 다음 코드를 추가합니다.

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

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

}

Test

쉘에서 푸시 상주 프로그램을 시작합니다.

• [root@localhost bin]# ./mix-daemon push start
  mix-daemon 'push' start successed.

인터페이스를 호출하여 작업을 메시지 대기열에 넣습니다.
이때 쉘 터미널은 다음을 인쇄할 것입니다:

성공적으로 테스트 이메일을 받았습니다:

위 내용은 모든 사람의 학습에 도움이 되기를 바랍니다. 더 많은 관련 내용을 보시려면 PHP 중국어 홈페이지를 주목해주세요!

관련 권장사항:

1. 공유 메모리를 구현하려면 PHP용 shmop 확장을 활성화하세요.

php는 공유 메모리 프로세스 통신 기능(_shm)을 구현합니다.

위 내용은 mixphp를 사용하여 다중 프로세스 비동기 이메일 전송 생성의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!