php数据库连接swoole扩展

 PHP的MySQL扩展提供了长连接的API，但在访问数量较多，规模较大的情况下，mysql_connect非但不能节约MySQL资源，反而会加剧数据库的负荷。 

假设有100台PHP的应用服务器，每个机器需要启动100个apache或fpm工作进程，那每个进程都会产生一个长连接到MySQL。这一共会产生1万个My SQL连接。大家都知道MySQL是每个连接会占用1个线程。那MYSQL就需要创建1万个线程，这样大量的系统资源被浪费在线程间上下文切换上。而你的业务代码中并不是所有地方都在做数据库操作，所以这个就是浪费的。 

连接池就不同了，100个worker进程，公用10个数据库连接即可，当操作完数据库后，立即释放资源给其他worker进程。这样就算有100台PHP的服务器，那也只会创建1000个MySQL的连接，完全可以接受的。

以前确实没有好的办法来解决此问题的，现在有了swoole扩展，利用swoole提供的task功能可以很方便做出一个连接池来。

代码如下： 

$serv = new swoole_server("127.0.0.1", 9508);

$serv->set(array( 'worker_num' => 100, 'task_worker_num' => 10)); //MySQL连接的数量

function my_onReceive($serv, $fd, $from_id, $data) {

    //taskwait就是投递一条任务，这里直接传递SQL语句了 //然后阻塞等待SQL完成

    $result = $serv->taskwait("show tables");

    if ($result !== false) {

        list($status, $db_res) = explode(':', $result, 2);

        if ($status == 'OK') {

            //数据库操作成功了，执行业务逻辑代码，这里就自动释放掉MySQL连接的占用

            $serv->send($fd, var_export(unserialize($db_res), true) . "\n");

        } else {

            $serv->send($fd, $db_res);

        }

        return;

    } else {

        $serv->send($fd, "Error. Task timeout\n");

    }

}

function my_onTask($serv, $task_id, $from_id, $sql) {

    static $link = null;

    if ($link == null) {

        $link = mysqli_connect("127.0.0.1", "root", "root", "test");

        if (!$link) {

            $link = null;

            $serv->finish("ER:" . mysqli_error($link));

            return;

        }

    } 

    $result = $link->query($sql); 

    if (!$result) { 

        $serv->finish("ER:" . mysqli_error($link)); 

        return;

    } 

    $data = $result->fetch_all(MYSQLI_ASSOC); 

    $serv->finish("OK:" . serialize($data));

} 

function my_onFinish($serv, $data) { 

    echo "AsyncTask Finish:Connect.PID=" . posix_getpid() . PHP_EOL;

} 

$serv->on('Receive', 'my_onReceive'); 

$serv->on('Task', 'my_onTask'); 

$serv->on('Finish', 'my_onFinish'); 

$serv->start();

这里task_worker_num就是要启用的数据库连接池数量，worker进程为100时，连接池数量为10就可以设置为worker_num = 100, task_worker_num = 10。