PHP同步阻塞函数、异步非阻塞函数 同步阻塞函数mysql、mysqli、pdo以及其他DB操作函数sleep、usleepcurlstream、socket扩展的函数swoole_client同步模式memcache、redis扩展函数file_get_contents/fread等文件读取函数swoole_server->taskwaitswoole_server->sendwaitswoole_server的PHP代码中有上述函数，Server就是同步服务器代码中没有上述函数就是异步服务器异步非阻塞函数swoole_client异步模式mysql-async库redis-async库swoole_timer_tick/swoole_timer_afterswoole_event系列函数swoole_table/swoole_atomic/swoole_bufferswoole_server->task/finish函数

php中mysql数据库异步查询实现 php中mysql数据库异步查询实现问题通常一个web应用的性能瓶颈在数据库。因为，通常情况下php中mysql查询是串行的。也就是说，如果指定两条sql语句时，第二条sql语句会等到第一条sql语句执行完毕再去执行。这个时候，如果执行2条sql语句，每条执行时间为50ms，全部执行完毕可能需要100ms。既然，主要原因是sql的串行执行导致。那我们是不是可以改变执行方式来提高性能呢？答案是，可以的。我们可以通过异步执行的方式来提高性能。异步如果通过异步的方式去执行，可能性能会有很大提升。如果是采用异步的方式，两条sql语句会并发执行，可能就需要60ms就可以执行完毕。实现mysqli + mysqlnd。php官方实现的mysqlnd中提供了异步查询的方法。分别是：mysqlnd_async_query 发送查询请求mysqlnd_reap_async_query 获取查询结果这样就可以不必每次发送完查询请求后，一直阻塞等待查询结果了。实现代码如下：1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677<?php$host = '127.0.0.1';$user = 'root';$password = '';$database = 'test';/**期望得到额结果array(1 => int,2 => int,3 => int) */$result = array(1=>0, 2=>0, 3=>0);//异步方式[并发请求]$time_start = microtime(true);$links = array();foreach ($result as $key=>$value) {$obj = new mysqli($host, $user, $password, $database); $links[spl_object_hash($obj)] = array('value'=>$key, 'link'=>$obj);}$done = 0;$total = count($links);foreach ($links as $value) {$value['link']->query("SELECT COUNT(*) AS `total` FROM `demo` WHERE `value`={$value['value']}", MYSQLI_ASYNC);}do {$tmp = array(); foreach ($links as $value) { $tmp[] = $value['link']; } $read = $errors = $reject = $tmp; $re = mysqli_poll($read, $errors, $reject, 1); if (false === $re) { die('mysqli_poll failed'); } elseif ($re < 1) { continue; } foreach ($read as $link) { $sql_result = $link->reap_async_query(); if (is_object($sql_result)) { $sql_result_array = $sql_result->fetch_array(MYSQLI_ASSOC);//只有一行 $sql_result->free(); $hash = spl_object_hash($link); $key_in_result = $links[$hash]['value']; $result[$key_in_result] = $sql_result_array['total']; } else { echo $link->error, "\n"; } $done++; } foreach ($errors as $link) { echo $link->error, "1\n"; $done++; } foreach ($reject as $link) { printf("server is busy, client was rejected.\n", $link->connect_error, $link->error); //这个地方别再$done++了。 }} while ($done<$total);var_dump($result);echo "ASYNC_QUERY_TIME:", microtime(true)-$time_start, "\n";$link = end($links);$link = $link['link'];echo "\n";结语mysql数据库对于每个查询请求都是单独启动一个线程进行处理。如果mysql服务器启动线程过多，必然会造成线程切换引起系统负载过高。如果在mysql数据库负载不高的情况下，使用异步查询还是不错的选择。

PHP实现真正的异步MySQL PHP实现真正的异步MySQLnode.js之类的语言可以实现异步的数据库查询功能，执行SQL语句之后不必等待数据库返回结果。继续去执行其他的代码，当数据库返回结果是再对数据进行处理，如渲染页面，并将HTML页面发送给客户端。这样应用程序完全不需要阻塞等待。这种方式运行效率非常高。PHP中是否可以实现类似的异步非阻塞MySQL查询呢？使用github搜索发现一个项目貌似是做此功能的，https://github.com/kaja47/async-mysql，查看代码是基于React.PHP.的。但并不是真正的异步SQL。实现的原理是设置一个定时器，每0.02秒轮询一次。虽然也可以用，但这样很浪费CPU资源。不是真正的异步MYSQL。现在Swoole1.6.2提供了swoole_event_add和swoole_get_mysqli_sock 2个新的函数，使用它完全可以实现真正的PHP异步MySQL。下面讲一下具体的实现。代码：$db = new mysqli; $db->connect('127.0.0.1', 'root', 'root', 'test'); $db->query("show tables", MYSQLI_ASYNC); swoole_event_add(swoole_get_mysqli_sock($db), function($db_sock) { global $db; $res = $db->reap_async_query(); var_dump($res->fetch_all(MYSQLI_ASSOC)); swoole_event_exit(); });首先连接mysql，连接成功后执行SQL语句，要在第二个参数指定MYSQLI_ASYNC。表示此查询为异步。query函数会立即返回，这时候并没有得到mysqli_result。然后调用swoole_get_mysqli_sock函数取到mysql连接的socket，并调用swoole_event_add将它加入到swoole的epoll事件循环中。当数据库返回结果是会回调我们刚才制定的函数。这时候再调用mysqli_reap_async_query得到result，调用fetch_all函数得到数据。这个过程是完全异步非阻塞的，不存在任何浪费CPU的代码。这个代码还可以用在服务器端程序上，具体代码实现后续会再写一篇文章详细介绍。

关于PHP你可能不知道的－PHP的事件驱动化设计 关于PHP你可能不知道的－PHP的事件驱动化设计最近在做一个需要用到异步PHP的项目， 翻阅PHP源码的时候，发现了三个没有用过的模块，sysvsem,sysvshm,sysvmsg,一番研究以后，受益非浅。在PHP中有这么一族函数，他们是对UNIX的V IPC函数族的包装。它们很少被人们用到，但是它们却很强大。巧妙的运用它们，可以让你事倍功半。它们包括：信号量(Semaphores)共享内存(Shared Memory)进程间通信(Inter-Process Messaging, IPC)基于这些，我们完全有可能将PHP包装成一基于消息驱动的系统。但是，首先，我们需要介绍几个重要的基础:ftokint ftok ( string pathname, string proj )//ftok将一个路径名pathname和一个项目名(必须为一个字符), 转化成一个整形的用来使用系统V IPC的keyticksTicks是从PHP 4.0.3开始才加入到PHP中的，它是一个在declare代码段中解释器每执行N条低级语句就会发生的事件。N的值是在declare中的directive部分用ticks=N来指定的。function getStatus($arg){ print_r connection_status(); debug_print_backtrace();}reigster_tick_function("getStatus", true);declare(ticks=1){ for($i =1; $i<999; $i++){ echo "hello"; }}unregister_tick_function("getStatus");这个就基本相当于：function getStatus($arg){ print_r connection_status(); debug_print_backtrace();}reigster_tick_function("getStatus", true);declare(ticks=1){ for($i =1; $i<999; $i++){ echo "hello"; getStatus(true); }}unregister_tick_function("getStatus");消息，我现在用一个例子来说明，如何结合Ticks来实现PHP的消息通信。$mesg_key = ftok(__FILE__, 'm');$mesg_id = msg_get_queue($mesg_key, 0666);function fetchMessage($mesg_id){ if(!is_resource($mesg_id)){ print_r("Mesg Queue is not Ready"); } if(msg_receive($mesg_id, 0, $mesg_type, 1024, $mesg, false, MSG_IPC_NOWAIT)){ print_r("Process got a new incoming MSG: $mesg "); }}register_tick_function("fetchMessage", $mesg_id);declare(ticks=2){ $i = 0; while(++$i < 100){ if($i%5 == 0){ msg_send($mesg_id, 1, "Hi: Now Index is :". $i); } }}//msg_remove_queue($mesg_id);在这个例子中，首先将我们的PHP执行Process加入到一个由ftok生成的Key所获得的消息队列中。然后，通过Ticks，没隔俩个语句，就去查询一次消息队列。然后模拟了消息发送。在浏览器访问这个脚本，结果如下：Process got a new incoming MSG: s:19:"Hi: Now Index is :5";Process got a new incoming MSG: s:20:"Hi: Now Index is :10";Process got a new incoming MSG: s:20:"Hi: Now Index is :15";Process got a new incoming MSG: s:20:"Hi: Now Index is :20";Process got a new incoming MSG: s:20:"Hi: Now Index is :25";Process got a new incoming MSG: s:20:"Hi: Now Index is :30";Process got a new incoming MSG: s:20:"Hi: Now Index is :35";Process got a new incoming MSG: s:20:"Hi: Now Index is :40";Process got a new incoming MSG: s:20:"Hi: Now Index is :45";Process got a new incoming MSG: s:20:"Hi: Now Index is :50";Process got a new incoming MSG: s:20:"Hi: Now Index is :55";Process got a new incoming MSG: s:20:"Hi: Now Index is :60";Process got a new incoming MSG: s:20:"Hi: Now Index is :65";Process got a new incoming MSG: s:20:"Hi: Now Index is :70";Process got a new incoming MSG: s:20:"Hi: Now Index is :75";Process got a new incoming MSG: s:20:"Hi: Now Index is :80";Process got a new incoming MSG: s:20:"Hi: Now Index is :85";Process got a new incoming MSG: s:20:"Hi: Now Index is :90";Process got a new incoming MSG: s:20:"Hi: Now Index is :95";看到这里是不是，大家已经对怎么模拟PHP为事件驱动已经有了一个概念了？ 别急，我们继续完善。信号量信号量的概念，大家应该都很熟悉。通过信号量，可以实现进程通信，竞争等。 再次就不赘述了，只是简单的列出PHP中提供的信号量函数集。sem_acquire -- Acquire a semaphoresem_get -- Get a semaphore idsem_release -- Release a semaphoresem_remove -- Remove a semaphore具体信息，可以翻阅PHP手册。内存共享PHP sysvshm提供了一个内存共享方案:sysvshm，它是和sysvsem,sysvmsg一个系列的，但在此处，我并没有使用它，我使用的shmop系列函数，结合TIcksfunction memoryUsage(){ printf("%s: %s<br/>", date("H:i:s", $now), memory_get_usage()); //var_dump(debug_backtrace()); //var_dump(__FUNCTION__); //debug_print_backtrace();}register_tick_function("memoryUsage");declare(ticks=1){$shm_key = ftok(__FILE__, 's');$shm_id = shmop_open($shm_key, 'c', 0644, 100);}printf("Size of Shared Memory is: %s<br/>", shmop_size($shm_id));$shm_text = shmop_read($shm_id, 0, 100);eval($shm_text);if(!empty($share_array)){ var_dump($share_array); $share_array['id'] += 1;}else{ $share_array = array('id' => 1);}$out_put_str = "$share_array = " . var_export($share_array, true) .";";$out_put_str = str_pad($out_put_str, 100, " ", STR_PAD_RIGHT);shmop_write($shm_id, $out_put_str, 0);?>运行这个例子，不断刷新，我们可以看到index在递增。单单使用这个shmop就能完成一下，PHP脚本之间共享数据的功能：以及，比如缓存，计数等等。