使用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();