Thinkphp5 + Swoole实现邮箱异步通知

news/2024/12/23 6:59:30/

 在 ThinkPHP 中实现邮箱异步通知的常见做法是通过队列系统来处理异步任务,结合 Swoole 来处理异步发送邮件的请求。这样可以避免同步处理邮件发送导致的阻塞,提高响应速度。

以下是基于 ThinkPHP5 框架和 Swoole 的异步邮件通知实现步骤:

一、安装 Swoole

首先,你需要确保 Swoole 已经正确安装,可以通过 Composer 安装:

pecl install swoole

二、邮件发送配置

和 Redis 队列的方案一样,我们需要先配置邮件发送,还是使用 PHPMailer 或者其他的邮件库来发送邮件。

在项目的 config.php 中配置邮件相关信息:

php">return ['email' => ['host' => 'smtp.example.com','username' => 'your-email@example.com','password' => 'your-password','port' => 465,'from' => 'your-email@example.com','from_name' => 'Your Name',],
];

三、创建邮件服务类

邮件服务类 MailService 负责处理邮件发送的逻辑。这里使用 PHPMailer 作为邮件发送工具。

application/common/service/MailService.php

php"><?phpnamespace app\common\service;use PHPMailer\PHPMailer\PHPMailer;
use think\facade\Config;class MailService
{public static function sendMail($to, $subject, $body){$mail = new PHPMailer(true);try {$mail->isSMTP();$mail->Host       = Config::get('email.host');$mail->SMTPAuth   = true;$mail->Username   = Config::get('email.username');$mail->Password   = Config::get('email.password');$mail->SMTPSecure = 'ssl'; $mail->Port       = Config::get('email.port');$mail->setFrom(Config::get('email.from'), Config::get('email.from_name'));$mail->addAddress($to);$mail->isHTML(true);$mail->Subject = $subject;$mail->Body    = $body;$mail->send();return true;} catch (\Exception $e) {return $mail->ErrorInfo;}}
}

四、使用 Swoole 实现异步任务

1. 创建 Swoole Server

在项目的 command 目录下创建 SwooleServer.php,用于处理 Swoole 的服务和任务。

php"><?phpnamespace app\command;use Swoole\Server;
use app\common\service\MailService;
use think\console\Command;
use think\console\Input;
use think\console\Output;class SwooleServer extends Command
{protected function configure(){$this->setName('swoole:server')->setDescription('Start Swoole Server');}protected function execute(Input $input, Output $output){$server = new Server("127.0.0.1", 9501);// 设置 Swoole 的配置$server->set(['worker_num' => 4,'task_worker_num' => 4,]);// 当有客户端连接时触发$server->on('receive', function (Server $server, $fd, $reactor_id, $data) {// 处理客户端发送的任务数据$taskData = json_decode($data, true);if ($taskData && isset($taskData['to'], $taskData['subject'], $taskData['body'])) {// 投递任务给 Task Worker$server->task($taskData);}$server->send($fd, "Mail task received.");});// 处理异步任务$server->on('task', function (Server $server, $task_id, $from_worker_id, $data) {// 使用 MailService 发送邮件$result = MailService::sendMail($data['to'], $data['subject'], $data['body']);// 返回任务处理结果$server->finish($result);});// 任务处理完成时触发$server->on('finish', function (Server $server, $task_id, $data) {// 任务完成后的逻辑});$output->writeln('Swoole Server started.');// 启动 Swoole Server$server->start();}
}
2. 注册 Swoole 命令

application/command.php 中注册 SwooleServer 命令:

php">return ['app\command\SwooleServer',
];
3. 启动 Swoole Server

使用命令行启动 Swoole Server:

php">php think swoole:server

Swoole 服务器启动后,它将监听 127.0.0.1:9501,客户端可以通过这个端口向服务器发送任务请求。

五、在控制器中使用 Swoole 异步发送邮件

现在我们可以在控制器中通过向 Swoole Server 发送请求来处理异步邮件通知。

application/controller/UserController.php

php"><?phpnamespace app\controller;use Swoole\Client;
use think\Controller;class UserController extends Controller
{public function register(){// 用户注册逻辑$email = 'user@example.com';$subject = '欢迎注册';$body = '感谢您注册我们的网站!';// 创建一个 Swoole 客户端$client = new Client(SWOOLE_SOCK_TCP);// 连接到 Swoole Serverif ($client->connect('127.0.0.1', 9501, 0.5)) {// 发送任务数据到 Swoole Server$client->send(json_encode(['to' => $email,'subject' => $subject,'body' => $body]));// 接收 Swoole Server 的反馈$response = $client->recv();$client->close();return json(['message' => $response]);} else {return json(['error' => 'Unable to connect to Swoole Server']);}}
}

六、总结

通过 Swoole 实现的异步任务处理机制,可以将耗时操作如发送邮件等操作放入后台异步执行,提升用户体验和系统性能。Swoole 的 Task 机制非常适合处理这种场景,结合 ThinkPHP 使得开发异步任务更加简单高效。


http://www.ppmy.cn/news/1526515.html

相关文章

数据结构(2):LinkedList和链表[2]

我们在上一篇文章中着重讨论了单链表的实现。其中我们要注意单链表进行遍历时一步一步走的思想。那么这篇文章我们将继续讨论链表的更多内容&#xff0c;那就让我们开始吧。 1.经典单链表算法题 我们将通过几个经典的题对单链表进行进一步的认识。 (1)反转链表 206. 反转链…

安全区域边界等保测评

1.边界防护 应保证跨越边界的访问和数据流通过边界设备提供的受控接口进行通信。 [测评方法] 1)应核查在网络边界处是否部署访问控制设备;网闸和防火墙2)应核查设备配置信息是否指定端口进行跨越边界的网络通信,指定端口是否配置并启用了安全策略acl 3)应采用其他技术手…

解锁全球机遇:澳大利亚服务器租用市场的独特魅力

在浩瀚的全球数字版图中&#xff0c;澳大利亚以其独特的地理位置、丰富的资源禀赋、以及日益增长的数字经济活力&#xff0c;成为了众多互联网企业竞相布局的重要市场。特别是当谈及服务器租用这一关键环节时&#xff0c;澳大利亚以其稳定的网络环境、先进的基础设施和开放的市…

算法提高模板强连通分量tarjan算法

AC代码&#xff1a; #include<bits/stdc.h>using namespace std;typedef long long ll; const int MOD 998244353; const int N 2e5 10;//强联通分量模板 //tarjan算法 vector<int>e[N]; int n, m, cnt; int dfn[N], low[N], ins[N], idx; int bel[N];//记录每…

图分类!!!

deepwalk 使用图中节点与节点的共现关系来学习节点的向量表示。那么关键的问题就是如何来描述节点与节点的共现关系&#xff0c;DeepWalk给出的方法是使用随机游走(RandomWalk)的方式在图中进行节点采样,RandomWalk是一种可重复访问已访问节点的深度优先遍历算法。给定当前访问…

机器学习1--概述

机器学习概述 一、概述二、发展历程三、主要分支四、工作流程五、算法分类六、模型评估 一、概述 人工智能的应用&#xff1a;交通、网络安全、电子商务、人工智能发展三要素&#xff1a;数据、算法、计算力。 CPU,GPU,TPUCPU主要适合I\O密集型任务GPU主要适合计算密集型任务 …

OpenCV结构分析与形状描述符(21)计算包围给定点集的最小面积三角形函数minEnclosingTriangle()的使用

操作系统&#xff1a;ubuntu22.04 OpenCV版本&#xff1a;OpenCV4.9 IDE:Visual Studio Code 编程语言&#xff1a;C11 算法描述 找到一个包围二维点集的最小面积三角形&#xff0c;并返回其面积。 该函数找到一个包围给定的二维点集的最小面积三角形&#xff0c;并返回其面…

数据结构之栈(数组实现)

数据结构之栈 一、栈的概念与结构。 1、概念&#xff1a;栈是限定仅在表尾进行插入和删除操作的线性表。栈中的数据元素遵守后进先出原则&#xff0c;即LIFO(Last In First Out)的原则。 2、栈的插入操作&#xff1a;进栈/压栈/入栈 ​ 栈的删除操作: 出栈/弹栈 3、进栈出…