PHP / MySQL-同时进行多个查询

Question

我有24个数据库，其中的表标记为email_queue。

我有另一个数据库，其中包含该表的所有数据库的列表email_queue。

我遍历数据库列表并查询我的email_queue表以为每个数据库发送邮件。

这个问题是，PHP脚本被搁置了，比方说，第3个数据库，同时发送500封电子邮件，然后离开其他数据库等待轮到他们。

我试图弄清楚如何同时查询所有24个数据库并同时发送电子邮件队列。

有什么建议？

Answer 1

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