详解thinkphp5+swoole实现异步邮件群发（SMTP方式）

2018-09-07 12:06

阅读：673

　　本文介绍了thinkphp5+swoole实现异步邮件群发（SMTP方式），分享给大家，具体如下：

　　1、环境说明

　　阿里云centos7 thinkphp5.0.11 swoole2.0.8

　　2、tp实现邮件发送

　　在项目下建立如下的文件目录：

　　其中SendMail.php是我们实际调用的发送邮件的文件。以下是主要代码：

　　里面的config配置项，我们放在项目底下的config.php文件中，具体配置内容如下:

　　 //邮箱设置 mail=>[ CharSet=>UTF-8, SMTPDebug=>0,// 启用SMTP调试功能 0关闭 SMTPAuth=>true,// 启用 SMTP 验证功能 SMTPSecure=>ssl,// 安全协议// SMTP 服务器 Port=>465,// SMTP服务器的端口号 Username=>**********,// SMTP服务器用户名 Password=>**********,// SMTP服务器密码,// 发件人邮箱 Name=>blue,// 发件人邮箱 ]

　　2.1这里我们只是实现了smtp协议发送的demo，所以在封装的层面上没有做到很全面，不是很灵活。图中其他两个文件（PhpMailer.php和Smtp.php）是Phpmailer邮件发送类的核心文件，为了简化调用，抽取了出来，详细的用法和参数设置，可以参考gayhub的使用说明phpmailer

　　2.2 注意点

　　在此步骤中，我们需要注意几点：1是你设置的邮件发送的账号是否已经开启SMTP并且找对对应的安全协议和端口号。2、当前服务器是否支持SMTP服务，这边很多时候会受一些socket函数的影响，遇到问题的时候，我们应该把SMTPDebug参数设置为1，然后根据debug信息去细心调试。3、发出的邮件有些会被放入垃圾箱，注意查收。

　　2.3 调用

　　建立如下的文件目录结构：

　　在Index.php中调用发送邮件的方法,具体代码如下

　　2.4 调用结果

　　我们可以在QQ邮箱的垃圾箱中找到我们刚刚发送的一封邮件

　　3、结合swoole实现异步群发3.1安装swoole

　　swoole扩展安装的详细步骤官网上面都有，不再赘述，swoole文档传送门

　　安装完swoole之后，建议为自己的IDE加上swoole的代码提示，配置IDE提示swoole代码的传送门

　　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(task, function ($serv, $task_id, $from_id, $data) { echo 接收异步任务test,$data)){ echo send.$i. success.\n; }else{ echo send.$i. fail.\n; } } $serv->finish(); }); $serv->on(finish, function ($serv, $task_id, $data) { echo 异步任务[id=$task_id]完成.PHP_EOL; }); $serv->start(); }

　　在服务端，我们用了一个20的loop来模拟了群发，实际换成不同的email地址就可。

　　下面我们实现客户端

　　 /** * 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