我有24个数据库,其中的表标记为email_queue。
email_queue
我有另一个数据库,其中包含该表的所有数据库的列表email_queue。
我遍历数据库列表并查询我的email_queue表以为每个数据库发送邮件。
这个问题是,PHP脚本被搁置了,比方说,第3个数据库,同时发送500封电子邮件,然后离开其他数据库等待轮到他们。
我试图弄清楚如何同时查询所有24个数据库并同时发送电子邮件队列。
有什么建议?
使用curl_multi_open可以做到这一点
将您的脚本分成两部分,您可以使一个php文件(例如email_out.php)具有数据库名称(或一些用于查找数据库名称的变量,该开关将位于for循环中或位于email_out.php中) ,然后基于该脚本进行大量电子邮件发送。
第二部分使用curl_multi_open多次打开email_out.php脚本,有效地创建了到不同数据库的多个单独连接,这些脚本都可以在不同时间解析,因为它们都是并行运行的。本质上,您的循环现在是使用不同的参数多次将脚本添加到curl_multi_open,然后异步执行所有脚本。
class Fork { private $_handles = array(); private $_mh = array(); function __construct() { $this->_mh = curl_multi_init(); } function add($url) { $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $url); curl_setopt($ch, CURLOPT_HEADER, 0); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_TIMEOUT, 30); curl_multi_add_handle($this->_mh, $ch); $this->_handles[] = $ch; return $this; } function run() { $running=null; do { curl_multi_exec($this->_mh, $running); usleep (250000); } while ($running > 0); for($i=0; $i < count($this->_handles); $i++) { $out = curl_multi_getcontent($this->_handles[$i]); $data[$i] = json_decode($out); curl_multi_remove_handle($this->_mh, $this->_handles[$i]); } curl_multi_close($this->_mh); return $data; } }
(来自http://gonzalo123.com/2010/10/11/speed-up-php-scripts-with-asynchronous- database-queries/)
因此,您的循环将如下所示:
$fork = new Fork; for ($i = 0; $i < 24; $i++) { $fork->add("email_out.php?t=" . $i); } $fork->run();