当前位置:  开发笔记 > 编程语言 > 正文

线程池 - 想用php发邮件然后记录发送结果,目前用的redis,用一个脚本执行发送和记录操作,很慢,有什么更好的方法吗

目前是用的一个php脚本,执行请求外部接口发邮件,然后等邮件返回,得到处理结果,然后往自己的数据库记录发送结果。。一个小时大概能处理2w条,太慢了。。老板说用线程池来做,我现在又是一脸懵逼。。不太懂具
目前是用的一个php脚本,执行请求外部接口发邮件,然后等邮件返回,得到处理结果,然后往自己的数据库记录发送结果。。
一个小时大概能处理2w条,太慢了。。

老板说用线程池来做,我现在又是一脸懵逼。。不太懂具体的做法,有大神能说一下大概的过程吗?是用Thread这个扩展吗?

回复内容:

目前是用的一个php脚本,执行请求外部接口发邮件,然后等邮件返回,得到处理结果,然后往自己的数据库记录发送结果。。
一个小时大概能处理2w条,太慢了。。

老板说用线程池来做,我现在又是一脸懵逼。。不太懂具体的做法,有大神能说一下大概的过程吗?是用Thread这个扩展吗?

刚好做过类似的事情,可以提点意见。
2w/h ≈ 5.55 QPS,的确不高。

如果按你老板的思路,一个单线程的脚本执行慢,那就多几个。那么你需要的是 pthreads 扩展(多线程),或者直接开多个进程处理(pcntl扩展甚至直接 exec 都可以)。

但从你的需求看,使得占用处理时间的主要内容是外部 IO 等待。可以考虑使用并发同时发送多封邮件(比如 multi_curl),或者异步发送邮件(比如 curl 的 async),或者整体使用个异步服务(比如 swoole 扩展)

数据表增加一个字段 process_id
插入数据库记录的时候随机给 process_id 赋值 mt_rand(1,10)
开启 10 个 PHP 脚本,
第一个脚本处理 process_id 为 1 的记录:select * from send_email_list where process_id=1 and status=0
第二个脚本处理 process_id 为 2 的记录:select * from send_email_list where process_id=2 and status=0
这样同时 10 个进程处理,这是最简单直接的方法,让你的处理速度直接提升 10 倍。

多线程,multi_curl 并发, swoole 异步都是可行解决方案。但上面的方案只需要在现有基础上进行简单改动便可以实现,可能更加适合题主。

用nodejs来做后台发送邮件服务

推荐阅读
sx-March23
这个屌丝很懒,什么也没留下!
DevBox开发工具箱 | 专业的在线开发工具网站    京公网安备 11010802040832号  |  京ICP备19059560号-6
Copyright © 1998 - 2020 DevBox.CN. All Rights Reserved devBox.cn 开发工具箱 版权所有