在 PHP 中使用 Promise + co/yield 协程
JanSpringfi
8年前
<p>摘要: 我们知道 JavaScript 自从有了 Generator 之后，就有了各种基于 Generator 封装的协程。其中 hprose 中封装的 Promise 和协程库实现了跟 ES2016 的 async/await 一样的功能，并且更加灵活。我们还知道 PHP 自从 5.5 之后，也引入了 Generator，同样也有了各种基于它封装的 PHP 协程库，hprose 同样也为 PHP 提供的跟 JavaScript 版本类似的 Promise 和协程库。下面我们就来看一下它跟 swoole 结合的效果。</p> <h2>为什么需要异步方式</h2> <p>一个函数执行之后，在它后面顺序编写的代码中，如果能够直接使用它的返回结果或者它修改之后的引用参数，那么我们通常认为该函数是同步的。</p> <p>而如果一个函数的执行结果或者其修改的引用参数，需要通过设置回调函数或者回调事件的方式来获取，而在其后顺序编写的代码中无法直接获取的话，那么我们通常认为这样的函数是异步的。</p> <p>PHP 提供的大部分函数都是同步的。通常我们会有一个误解，那就是容易把同步和阻塞当成同一个概念，但实际上同步代码不一定都是阻塞的，只是同步代码对阻塞天然友好，当同步代码和阻塞结合时，代码通常是简单易懂的。</p> <p>阻塞带来的问题是当前线程（或进程）会陷入等待，一直等到阻塞结束，这样就会造成线程（或进程）资源的浪费。所以，通常认为阻塞是不够高效的。</p> <p>但是如果要编写非阻塞代码，使用同步方式会变得有些复杂，且不够灵活。同步方式的非阻塞代码通常会使用 select 模式，例如 curl_multi_select , stream_select , socket_select 等就是 PHP 中提供的一些典型的 select 模式的函数。</p> <p>我们说它复杂且不够灵活是有理由的，例如使用上面的 select 模式编写同步的非阻塞代码时，我们需要先构造一个并发任务的列表，之后手动构造循环来执行这些并发的任务，在循环开始之后，虽然这几个任务可以并发，但是这个循环相对于其后的代码总体上仍然是阻塞的，我们要想拿到这些并发任务的结果时，仍然需要等待。 select 虽然可以同时等待多个任务中某一个或几个就位后，再执行后续操作，但仍然有一部分时间是被等待消耗掉的。而且如果是纯同步非阻塞的情况下，我们也很难在循环开始后，动态添加更多的任务到这个循环中去。</p> <p>所以，如果我们希望程序能够更加高效，更加灵活，就需要引入异步方式。</p> <h2>传统的异步方式有什么问题</h2> <p>一提到异步模式，大家脑子中的第一印象可能就是 <strong>回调、回调、回调</strong> 。是的，这是最简单最直接也是之前最常见的异步模式。只要在调用异步函数时设置一个或多个回调函数，函数就会在完成时自动调用回调函数。或者为一个对象设置一堆事件，之后调用该对象上的某个异步方法，虽然这个异步方法本身可能不再需要设置回调函数，但是设置的这堆事件实际上跟回调函数所起到的作用是一样的。</p> <p>如果你的程序逻辑够简单，简单的一两层回调也许并不会让你觉得异步方式的编程有什么麻烦。但如果你的程序逻辑一旦有些复杂，你可能就会被层层回调搞得疲惫不堪了。当然，实际上你的程序需要层层回调的原因，也许并不是你的程序逻辑真的复杂，而是你没有办法将回调函数中的参数结果传出来，所以，你就不得不将另一个回调函数传进去。</p> <p>我们来举一个简单的例子，假设我们有 1 个同步函数：</p> <pre> <code class="language-php">function sum($a, $b) { return $a + $b; }</code></pre> <p>然后我们按照下面的方式去调用它：</p> <pre> <code class="language-php">$a = sum(1, 2); $b = sum($a, 3); $c = sum($b, 4); var_dump(array($a, $b, $c));</code></pre> <p>虽然上面的代码很不精简，但我们要表达的意图很明确，而且代码看起来很清楚。</p> <p>那接下来我们把这个函数换成一个形式上的异步函数，例如：</p> <pre> <code class="language-php">function async_sum($a, $b, $callback) { $callback($a + $b); }</code></pre> <p>当然，它的执行并不是异步的，这里我们先不关心它的实现是不是真异步的。</p> <p>现在如果要做上面同样的操作，代码就要这样写了：</p> <pre> <code class="language-php">async_sum(1, 2, function($a) { async_sum($a, 3, function($b) use ($a) { async_sum($b, 4, function($c) use ($a, $b) { var_dump(array($a, $b, $c)); }); }); });</code></pre> <p>代码的执行结果是一样的。但异步的代码看起来显然更难读一些，虽然这已经是很简单的例子了。</p> <p>好了，看到这里，有些读者可能会觉的我上面的这个例子很糟糕。因为明明有同步的函数可以使用，并且代码清晰可读，为啥非要写个形似异步的函数，把本来同步可以做的很好的事情用异步方式复杂化呢？而且那个异步调用的方式，最后不还是想要实现同步化的结果吗？</p> <p>如果你这么想的话，一点都没错。但我们这里想要解决的问题是，如果我们拿到的只有一个异步函数，这个函数没有同步实现，我们也不知道这个异步函数的内部定义是怎样的，我们也没办法将这个异步函数改为同步函数实现。那我们有没有办法将上面的程序改的更可读一些呢？</p> <p>当然是可以的，所以，现在 Promise 要登场了。</p> <h2>为什么要引入 Promise</h2> <p>通常我们对 Promise 的一个误解就是，它要解决的是层层回调的问题，比如上面的问题看上去就是一个典型的层层回调的问题。</p> <p>然而实际上，Promise 要解决的并不是回调不回调的问题，如果你使用过 Promise 的话，你会发现使用 Promise 你仍然少不了要使用回调。Promise 要解决的问题是，如何将回调方法的参数从回调方法中传递出来，让它可以像同步函数的返回结果一样，在回调函数以外的控制范围内，可以传递和复用。</p> <p>我觉得这几篇文章讲的比较透彻，所以我就不重复文章中的内容了。</p> <p>下面我们来看上面的例子用 Promise 如何解。</p> <p>我们现在用最简单粗暴的方式来引入 Hprose 的库，直接复制源码而不是使用 composer。然后我们在代码中直接使用：</p> <pre> <code class="language-php"><?php require_once("Hprose.php"); use Hprose\Promise;</code></pre> <p>这种方式来引入 Hprose 的 Promise 库，当然你也可以写成：</p> <pre> <code class="language-php"><?php require_once("Hprose.php"); use Hprose\Future;</code></pre> <p>Future 库跟 Promise 库基本上是一样的，你可以认为 Future 是 Promise 的具体实现， Promise 只是 Future 实现的一个包装。这个区别你可以从源码中直接看出来，这里就不多做解释了。</p> <p>接下来，我们要把前面的 async_sum 函数 Promise 化，Hprose 提供了这样一个函数： Promisepromisify （或者 Futurepromisify ），它的作用就是将一个使用回调方式的异步函数变成一个返回 Promise 对象的异步函数。这样说，也许有些不好理解，下面直接上代码：</p> <pre> <code class="language-php"><?php require_once("Hprose.php"); use Hprose\Promise; function async_sum($a, $b, $callback) { $callback($a + $b); } $sum = Promise\promisify('async_sum'); $a = $sum(1, 2); $b = $a->then(function($a) use ($sum) { return $sum($a, 3); }); $c = $b->then(function($b) use ($sum) { return $sum($b, 4); }); Promise\all(array($a, $b, $c))->then(function($result) { var_dump($result); });</code></pre> <p>好了，看到这里，如果你对 Promise 的理解还不够深入的话，你的第一反应可能是：这不是把程序变得更复杂了吗？原来的程序是 3 个回调，现在仍然是 3 个回调，还多了包装，都玩出花来了，有意思吗？</p> <p>确实，从上面的代码来看，代码并没有被简化，但是你会发现，现在回调函数中的参数已经通过 Promise 返回值的方式传递出来了，而且可以在原本的回调函数控制范围以外被传递和复用了。</p> <p>但是你可能会说然并卵，程序不是仍然很复杂吗？那我们就来进一步简化一下：</p> <pre> <code class="language-php"><?php require_once("Hprose.php"); use Hprose\Promise; function async_sum($a, $b, $callback) { $callback($a + $b); } $sum = Promise\wrap(Promise\promisify('async_sum')); $var_dump = Promise\wrap('var_dump'); $a = $sum(1, 2); $b = $sum($a, 3); $c = $sum($b, 4); $var_dump(Promise\all(array($a, $b, $c)));</code></pre> <p>现在，代码中再也看不到回调了。因为我们把函数包装成了可以接收 Promise 变量的函数。当然，其实现细节略微有些复杂，如果你感兴趣，可以去看一下源码，这里就不做源码剖析了。如果感兴趣的读者多得话，以后有时间再写源码剖析。</p> <p>当然，如果你只是想把异步调用同步化，除了 Promisewrap 外，你还可以通过 co/yield 协程来实现。</p> <h2>Hprose 中的 co/yield 协程</h2> <p>还是上面的例子，如果你使用的是 PHP 5.5 或者更高版本，那么你可以这样来写代码了。</p> <pre> <code class="language-php"><?php require_once("Hprose.php"); use Hprose\Promise; function async_sum($a, $b, $callback) { $callback($a + $b); } Promise\co(function() { $sum = Promise\promisify('async_sum'); $a = (yield $sum(1, 2)); $b = (yield $sum($a, 3)); $c = (yield $sum($b, 4)); var_dump(array($a, $b, $c)); });</code></pre> <p>这代码比使用 Promisewrap 的又要简单了。这里，代码中的变量 $a , $b , $c 不再是 Promise 变量，而是实实在在的整数变量。也就是说， yield 把一个 Promise 变量变成了一个普通变量。</p> <p>现在 Promiseco 中的代码已经被实实在在的同步化了。</p> <p>现在你可能有新的疑问了，异步不是为了高效吗？现在把原本的异步代码同步化了，那还会高效吗？</p> <p>当然，对这个例子上来说，效率肯定是没有提高，反而是严重降低的。甚至在这个例子中，最原始的那个形似异步的实现也不比同步实现更高效。因为在这个例子中，并没有涉及到并发和 IO 阻塞的情况。</p> <p>下面我们就放到真实场景下来看看 Promise 和 co/yield 协程是怎么用的。</p> <h2>在 swoole 下使用 Promise 和 co/yield 协程</h2> <p>我们知道在 PHP 中，如果要让程序延时可以使用 sleep 函数（或者 usleep , time_nanosleep 函数）来让程序阻塞一会儿，但是这个阻塞会让整个进程都阻塞，所以在阻塞期间，什么都不能干。</p> <p>下面我们来看看使用 swoole_timer_after 实现的延时执行：</p> <pre> <code class="language-php"><?php require_once("Hprose.php"); use Hprose\Future; date_default_timezone_set('UTC'); function wait($time) { $wait = Future\promisify('swoole_timer_after'); for ($i = 0; $i < 5; $i++) { yield $wait($time); var_dump("wait ". ($time / 1000) . "s, now is " . date("H:i:s")); } } Future\co(wait(2000)); Future\co(wait(1000));</code></pre> <p>该程序执行结果如下：</p> <pre> <code class="language-php">string(24) "wait 1s, now is 13:48:25" string(24) "wait 2s, now is 13:48:26" string(24) "wait 1s, now is 13:48:26" string(24) "wait 1s, now is 13:48:27" string(24) "wait 2s, now is 13:48:28" string(24) "wait 1s, now is 13:48:28" string(24) "wait 1s, now is 13:48:29" string(24) "wait 2s, now is 13:48:30" string(24) "wait 2s, now is 13:48:32" string(24) "wait 2s, now is 13:48:34"</code></pre> <p>从结果中我们可以看出， wait(2000) 和 wait(1000) 各自都是顺序阻塞执行的，但是它们之间却是并发执行的。</p> <p>也就是说，协程之间并不会相互阻塞，虽然这几个并发的协程是在同一个进程内跑的。</p> <p>最后我们再来看一个用 co/yield 协程实现的并发抓图程序：</p> <pre> <code class="language-php"><?php require_once("Hprose.php"); use Hprose\Promise; function fetch($url) { $dns_lookup = Promise\promisify('swoole_async_dns_lookup'); $writefile = Promise\promisify('swoole_async_writefile'); $url = parse_url($url); list($host, $ip) = (yield $dns_lookup($url['host'])); $cli = new swoole_http_client($ip, isset($url['port']) ? $url['port'] : 80); $cli->setHeaders([ 'Host' => $host, "User-Agent" => 'Chrome/49.0.2587.3', ]); $get = Promise\promisify([$cli, 'get']); yield $get($url['path']); list($filename) = (yield $writefile(basename($url['path']), $cli->body)); echo "write $filename ok.\r\n"; $cli->close(); } $urls = array( 'http://b.hiphotos.baidu.com/baike/c0%3Dbaike116%2C5%2C5%2C116%2C38/sign=5f4519ba037b020818c437b303b099b6/472309f790529822434d08dcdeca7bcb0a46d4b6.jpg', 'http://f.hiphotos.baidu.com/baike/c0%3Dbaike116%2C5%2C5%2C116%2C38/sign=1c37718b3cc79f3d9becec62dbc8a674/38dbb6fd5266d016dc2eaa5c902bd40735fa358a.jpg', 'http://h.hiphotos.baidu.com/baike/c0%3Dbaike116%2C5%2C5%2C116%2C38/sign=edd05c9c502c11dfcadcb771024e09b5/d6ca7bcb0a46f21f3100c52cf1246b600c33ae9d.jpg', 'http://a.hiphotos.baidu.com/baike/c0%3Dbaike92%2C5%2C5%2C92%2C30/sign=4693756e8094a4c21e2eef796f9d70b0/54fbb2fb43166d22df5181f5412309f79052d2a9.jpg', 'http://a.hiphotos.baidu.com/baike/c0%3Dbaike92%2C5%2C5%2C92%2C30/sign=9388507144a98226accc2375ebebd264/faf2b2119313b07eb2cc820c0bd7912397dd8c45.jpg', ); foreach ($urls as $url) { Promise\co(fetch($url)); }</code></pre> <p>在这个程序中， fetch 函数内的代码是同步执行的，但是多个 fetch 之间却是并发执行的，从结果输出就可以看出来，输出顺序是不一定的。但最后，你总能得到所有的美图。</p> <p>总结：通过 swoole 跟 hprose 中的 Promise 和 co/yield 协程相结合，你可以方便的使用同步的方式来调用 swoole 中的异步函数和方法，并可以实现协程间的并发。</p> <p>因为篇幅所限，这里无法把 hprose 中 Promise 和 co/yield 协程的全部内容都介绍完，如果你想了解更多，可以参考下面两篇内容：</p> <p> </p> <p>来自：https://segmentfault.com/a/1190000007760513</p> <p> </p>