참고: 이것은 MixPHP V1의 예입니다
이메일 전송 작업은 일반적으로 시간이 많이 걸리기 때문에 일반적으로 비동기 처리를 사용하여 사용자 경험을 향상시킵니다. 달성할 메시지 대기열.
다중 프로세스 개발 기능이 부족하기 때문에 기존 MVC 프레임워크는 일반적으로 동일한 스크립트를 여러 번 실행하여 여러 프로세스를 생성합니다. Mixphp는 TaskExecutor를 캡슐화하며 사용자가 쉽게 고급 프로세스 개발을 할 수 있습니다. 완전한 기능을 갖춘 고성능 애플리케이션을 사용할 수 있습니다.
권장: "PHP 비디오 튜토리얼"
다음은 지식 포인트와 관련된 비동기 이메일 전송 시스템의 개발 프로세스를 보여줍니다. 메시지 대기열 구현 비동기
- PHP는 일반적으로 미들웨어를 사용하는 메시지 대기열을 사용합니다. 일반적으로 사용되는 메시지 미들웨어는 다음과 같습니다.
- redis
- rabbitmq
- kafka
이번에는 비동기 이메일 전송을 구현하기 위해 redis를 선택했습니다. redis 목록이 있습니다. 메시지 대기열을 구현할 수 있는 데이터 유형을 입력하세요. 다음 명령을 사용하세요:
// 入列 $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/swiftmailerProducer 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 = 'smtpdm.aliyun.com';
const PORT = 465;
const SECURITY = 'ssl';
const USERNAME = '****@email.***.com';
const PASSWORD = '****';
// 初始化事件
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(
[
// 类路径
'class' => 'mix\task\TaskExecutor',
// 服务名称
'name' => "mix-daemon: {$this->programName}",
// 执行类型
'type' => \mix\task\TaskExecutor::TYPE_DAEMON,
// 执行模式
'mode' => \mix\task\TaskExecutor::MODE_PUSH,
// 左进程数
'leftProcess' => 1,
// 中进程数
'centerProcess' => 5,
// 任务超时时间 (秒)
'timeout' => 5,
]
);
}
// 启动
public function actionStart()
{
// 预处理
if (!parent::actionStart()) {
return ExitCode::UNSPECIFIED_ERROR;
}
// 启动服务
$service = $this->getTaskService();
$service->on('LeftStart', [$this, 'onLeftStart']);
$service->on('CenterStart', [$this, 'onCenterStart']);
$service->start();
// 返回退出码
return ExitCode::OK;
}
// 左进程启动事件回调函数
public function onLeftStart(LeftProcess $worker)
{
try {
// 模型内使用长连接版本的数据库组件，这样组件会自动帮你维护连接不断线
$queueModel = Redis::getInstance();
// 保持任务执行状态，循环结束后当前进程会退出，主进程会重启一个新进程继续执行任务，这样做是为了避免长时间执行内存溢出
for ($j = 0; $j < 16000; $j++) {
// 从消息队列中间件阻塞获取一条消息
$data = $queueModel->brpop('queue:email', 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['subject']))
->setFrom([self::USERNAME => '**网'])
->setTo($data['to'])
->setBody($data['body']);
// Send the message
$result = $mailer->send($message);
return $result;
}
}- Test1. 쉘에서 푸시 상주 프로그램을 시작합니다.
-
[root@localhost bin]# ./mix-daemon push start mix-daemon 'push' start successed.
1. 인터페이스를 호출하여 작업을 메시지 대기열에 넣습니다. 이제 쉘 터미널은 다음을 인쇄할 것입니다:
성공적으로 테스트 이메일을 받았습니다:
MixPHP
GitHub: https://github.com/mix-php /mix
공식 홈페이지: http://www.mixphp.cn/