怎么用mysql处理这样的问题？

通常情况下在PHP中MySQL查询是串行的，如果能实现MySQL查询的异步化，就能实现多条SQL语句同时执行，这样就能大大地缩短MySQL查询的耗时，提高数据库查询的效率。目前MySQL的异步查询只在MySQLi扩展提供，查询方法分别是：

1、使用MYSQLI_ASYNC模式执行mysqli::query

2、获取异步查询结果：mysqli::reap_async_query

使用mysql异步查询，需要使用mysqlnd作为PHP的MySQL数据库驱动。

使用MySQL异步查询，因为需要给所有查询都创建一个新的连接，而MySQL服务端会为每个连接创建一个单独的线程进行处理，如果创建的线程过多，则会造成线程切换引起系统负载过高。Swoole中的异步MySQL其原理是通过MYSQLI_ASYNC模式查询，然后获取mysql连接的socket，加入到epoll事件循环中，当数据库返回结果时会回调指定函数，这个过程是完全异步非阻塞的。

这是关于php进阶到架构之 swoole 系列学习课程：第三节：mysql连接池

学习目标 ：

了解什么是mysql连接池，以及mysql使用场景。能在实际工作使用连接池（数据库连接池，redis连接池等等）解决高并发带来的问题。

场景 ：

每秒同时1000个并发，但mysql数据库同时只支持400个连接，这样mysql就会宕机

解决方案 ：

使用连接池，这个连接池建立了300个与mysql的连接对象，这1000个并发有序地共享连接池里的300个连接。

连接池的使用不但解决了mysql在高并发情况下宕机问题，还额外提高了性能。因为和mysql建立连接，消耗较大。使用连接池只需要连接一次mysql。

永不断开，需要程序常驻内存，这就需要借助swoole实现。

数据库连接池是程序启动时，建立足够的数据库连接，并将这些连接组成一个连接。由程序动态的对连接池中的连接进行申请，使用，释放和回补。

swoole扩展是PHP扩展。php swoole扩展，PHP语言的高性能网络通信框架，提供了PHP语言的异步多线程服务器，异步TCP/UDP网络客户端，异步MySQL，数据库连接池，AsyncTask，消息队列，毫秒定时器，异步文件读写，异步DNS查询。

1、下载swoole源码包 

[root@nginx ~]# wget

   

2、解压进入swoole文件夹  

[root@nginx ~]# tar -zxvf swoole-1.7.17-stable

[root@nginx ~]# cd swoole-src-swoole-1.7.17-stable/

   

3、编译安装swoole   

[root@nginx swoole-src-swoole-1.7.17-stable]# phpize

[root@nginx swoole-src-swoole-1.7.17-stable]# ./configure

[root@nginx swoole-src-swoole-1.7.17-stable]# make &&make install

   

4、php.ini配置文件加载swoole.so模块  

[root@nginx swoole-src-swoole-1.7.17-stable]# vi /usr/local/php/lib/php.ini

注意 php命令行运行和浏览器运行的配置文件不一样。

php 命令行的配置：

[root@nginx swoole-src-swoole-1.7.17-stable]# php --ini

Configuration File (php.ini) Path: /usr/local/lib

Loaded Configuration File: /usr/local/lib/php.ini//配置文件

Scan for additional .ini files in: (none)

Additional .ini files parsed: (none)

    

5、查看swoole模块是否已经安装成功

[root@nginx swoole-src-swoole-1.7.17-stable]# php -m

   

6、编写服务端httpServer.php文件并运行

$serv = new swoole_server("127.0.0.1", 9501)

$serv->on('connect', function ($serv, $fd){

echo "Client:Connect.\n"

})

$serv->on('receive', function ($serv, $fd, $from_id, $data) {

$serv->send($fd, 'Swoole: '.$data)

})

$serv->on('close', function ($serv, $fd) {

echo "Client: Close.\n"

})

$serv->start()

   

运行httpServer.php

[root@nginx swoole-src-swoole-1.7.17-stable]# php httpServer.php

   

7、用telnet测试

[root@nginx ~]# telnet 127.0.0.1 9501

Trying 127.0.0.1...

Connected to 127.0.0.1.

Escape character is '^]'.

hello 客户端

Swoole: hello 服务端

来源：PHP swoole扩展安装和使用-

   20170819 13:57

---