了解PHP yield的高级用法-php教程

开篇

刚开端接触PHP 的 yield 的时分，觉得，yield 是甚么黑科技，baidu一下：yield——协程，天生器。不少文章都正在讲 Iterator ，Generater, 蛤～，这货色是 PHP 迭代器的一个增补。再翻几页，就是Go 协程。我出于猎奇点开看了下Go 协程, 外面都是 并发，线程，管道通信这种字眼，wc,nb, 这tm才是黑科技啊，再回来看PHP，分分钟想转 Go。

相干学习保举：PHP编程从入门到通晓

yield 语法退出 PHP

yield语法是正在版本5.5退出PHP的，合营迭代器应用，性能上就是 流程管制 代码，以及goto，return 相似。

如下就是民间提供的 yield 小例子，经过执行后果，咱们可剖析今世码执行到 yield $i 时,他会进行 return $i， 待 echo "$value\n" 后， goto for ($i = 1; $i <= 3; $i++) {， 对！PHP 的 yield 就是一个能出能进的语法。正在z代码中七进七出，把 $i 平淡安安患上送了进去。

<?phpfunction gen_one_to_three() {
    for ($i = 1; $i <= 7; $i++) {
        //留意变量$i的值正在没有同的yield之间是放弃通报的。
        yield $i;
    }}$generator = gen_one_to_three();foreach ($generator as $value) {
    echo "$value\n";}// output12...67

咱们遇到了甚么成绩

写代码就是处理成绩。咱们来看看他们遇到了甚么成绩：php民间呢，需求长篇累牍地把yield引见给各人。一局部网友呢，需求正在无限的资本内实现年夜文件操作。而咱们的鸟哥。面临的一群对当下yield的教程停留于高级而没有称心的phper，就以一个义务调剂器作为例子，给各人讲了一种yield初级用法。

php.net:天生器语法,
PHP若何读取年夜文件，
风雪之隅:正在PHP中应用协程完成多义务调剂.

提出成绩，再用yield来解答，看到以上谜底，我感觉呢，这PHP协程不外如斯（以及Go协程相比 ）。

有句话——一个好成绩比谜底更首要，今朝宽广网友尚未给yield提出更好，更艰难的成绩。

yield这个进进出出的语法，不少举例都是再让yield做迭代器啊，或许行使低内存读取超年夜文本的Excel，csv甚么的，再初级就是用它完成一个简略的义务调剂器，而且这个调剂器，一看代码都差没有多。

我来出道题

正如一个好的成绩，比谜底更有代价

1. 用PHP完成一个 Socket Server，他能接纳申请，并前往Server的工夫。

好，这是第一个成绩，铺垫。 民间谜底

2. 正在原来的代码上，咱们加个需要，该Socket Server 解决申请时，依赖其余 Socket Server，还需求有 Client 性能。也就是他能接纳申请，向其它Server发动申请。

这是第二个成绩，也是铺垫。

3. 原来的Socket Server同一工夫只能效劳一个客户，心愿能完成一个 非梗阻I/O Socket Server， 这个 Server 内有 Socket Client 性能，支持并发解决收到的申请，以及自动发动的申请。要求不必多线程，多过程。

这个成绩，仍是铺垫，这几个成绩很干，各人能够想想，2，3题的谜底，都放正在一个剧本里了：nio_server.php

以上这段代码，我罗列了一个详细的营业，就是用户申请购物车加购举措， 而购物车效劳呢，又需求以及 产物效劳，库存效劳，优惠效劳 交互，来验证加购举措可行性。有同步，异步形式申请，并做比照。

后续另有不少代码，我都放gitee链接了。应用办法，见readme.md

4. 最初一个成绩：正在PHP中，用同步写代码，顺序呢异步执行？需求怎样调整代码。

提醒：这个以及 PHP 的 yield 语法无关。

再提醒：yield 语法特色是甚么，进进出出!

看着咱们的代码，同步, 异步，进进出出 你想到了甚么？

看到代码，同步解决模式下，这三个函数checkInventory checkProduct checkPromo 时，发动申请，并顺次期待前往的后果，这三个函数执行后，再呼应客户申请。

异步解决模式下，这三个函数发动申请终了后，代码就跳出轮回了，而后是正在select()下的一个代码分支中接纳申请, 并搜集后果。每一次收到后果后判别能否实现，实现则呼应客户端。

那末能不克不及这样：正在异步解决的流程中，当 Server收到 本人发动的 client 无数据呼应后，代码跳到 nio_server.php 的 247行呢，这样咱们的收到申请校验相干的代码就能放到这里，编码能就是同步，容易了解。否则，client 的呼应解决放正在 280 行当前，欠亨过抓包，真的很难了解，执行了第 247 行代码后，紧接着是从 280 行开端的。

诶～这里是否是有 进进出出 那种觉得了～ 代码从 247 行进来，开端监听收回 Client 呼应，收到前往数据，带着数据再回到 247 行，持续进行逻辑校验，综合后果后，再呼应给客户端。

用yield来处理成绩

基于 yield 完成的，同步编码，"异步"I/O 的 Socket Server 就完成了。代码。

这里 “异步” 打了引号，年夜佬别扣这个字眼了。 该是非梗阻I/O

没有等各人的谜底了，先上我的后果代码吧，代码呢都放正在这个目次下了。

gitee https://gitee.com/xupaul/PHP-generator-yield-Demo/tree/master/yield-socket

运转测试代码

clone 代码到内陆后，需求拉起4个 co妹妹and 饬令顺序：

拉起3个第三方效劳

## 启动一个解决耗时2s的库存效劳$ php ./other_server.php 8081 inventory 2## 启动一个解决耗时4s的产物效劳$ php ./other_server.php 8082 product 4## 监听8083端口，解决一个申请 耗时6s的 promo 效劳$ php ./other_server.php 8083 promo 6

启动购物车效劳

## 启动一个非梗阻购物车效劳$ php ./async_cart_server.php 

## 或许启动一个普通购物车效劳$ php ./cart_server.php

发动用户申请

$ php ./user_client.php

运转后果呢以下，经过执行的工夫日记，可患上这三个申请是并发发动的，没有是梗阻通信。

正在看咱们的代码，三个函数，发动socket申请，不设置callback，而是经过yield from 接纳了三个socket的前往后果。

也就是达到了，同步编码，异步执行的成果。

运转后果

非梗阻模式

client 端日记：

经过以上 肇始工夫 以及 完结工夫 ，就看到这三个申请耗时统共就6s，也就依照耗时最长的promo效劳的耗时来的。也就是说三个第三方申请都是并发进行的。

cart server 端日记：

而 cart 打印的日记，能够看到三个申请一并发动，并一同期待后果前往。达到非梗阻并发申请的成果。

梗阻模式

client 端日记：

以上是梗阻形式申请，能够看到耗时 12s。也就是三个效劳加起来的耗时。

cart server 端日记：

cart 效劳，顺次梗阻形式申请第三方效劳，程序执行终了后，共耗时12s，当然假如第一个，获第二个效劳报错的话，会提前完结这个反省。会节约一点工夫。

工作原理

这里就是用到了 yield 的工作特性——进进出出，正在发动非梗阻socket申请后，没有是梗阻形式期待socket呼应，而是应用yield跳出以后执行天生器，期待有socket呼应后，正在挪用天生器的send办法回到发动socket申请的函数内，正在 yield from Async::all() 接纳数据呼应数据收集终了后，前往。

以及Golang比一比

思考到网速缘由，我这就放上一个国际教程链接：Go 并发 教程

php的协程是真协程，而Go是披着协程外套的轻量化线程（“协程”里，都玩上“锁”了，这就是线程）。

我集体偏幸，协程的，感觉线程的调剂有肯定随机性，因而需求锁机制来保障顺序的正确，带来了额定开支。协程的调剂（换入换出）交给了用户，保障了一段代码执行延续性（当然过程级上，仍是会有换入换出的，除了非是跨过程的资本拜访，或许跨机械的资本拜访，这时候，就要用到散布式锁了，这里没有开展探讨），同步编码，异步执行，只要要思考阿谁哪一个办法会有IO交互会协程跳出便可。

以及NodeJS比画一下

Javascript 以及 PHP 两个剧本言语有不少类似之处，弱类型，静态工具，复线程，正在Web畛域生态丰厚。没有同的是，Javascript正在阅读器端一开端就是异步的（假如js发动网络申请只能同步进行，那末你的网页衬着线程会卡住），例如Ajax，setTimeout，setInterval，这些都是异步+回调的形式工作。

基于V8引擎而降生的NodeJS，生成就是异步的，正在提供高功能网络效劳有很年夜的劣势，不外它的IO编码范式么。。。刚开端是 回调——毁掉天堂，起初有了Promise——屏幕竖起来看，和Generator——遇事不停yield一下吧，到如今的Async/Await——语法糖？真香！

能够说JS的委员十分勤快，正在异步编程范式的规范制订也做的很好（之前我测验考试写NodeJS时，几个回调就间接把我劝退了），2009年降生的NodeJS有点青出于蓝的意义。今朝PHP只是遇上了协程，等待PHP的Async/Await语法糖的完成吧。

PHP yield 应用留意事项

一旦应用上 yield 后，就必需留意挪用函数是，会失去函数后果，仍是 天生器工具。PHP 没有会主动帮你区分，需求你手动代码判别后果类型—— if ($re instanceof \Generator) {}， 假如你失去的是 天生器，但没有心愿去手动挪用 current() 去执行它，那末正在天生器前 应用 yield from 交给下游(框架)来处理。

爆改 Workerman

博客写到这，就开端手痒痒了，看到Workerman框架，我正在根底上二开，使其能——同步编码，异步执行。

代码已放到：PaulXu-cn/CoWorkerman.git

今朝仍是dev阶段，各人喜爱能够先 体验一波。

$ composer require paulxu-cn/co-workerman

一个简略的复线程 TCP Server

<?php// file: ./examples/example2/coWorkermanServer.php , 具体代码见github$worker = new CoWorker('tcp://0.0.0.0:8080');// 设置fork一个子过程$worker->count = 1;$worker->onConnect = function (CoTcpConnection  $connection) {
    try {
        $conName = "{$connection->getRemoteIp()}:{$connection->getRemotePort()}";
        echo PHP_EOL . "New Connection, {$conName} \n";

        $re = yield from $connection->readAsync(1024);
        CoWorker::safeEcho('get request msg :' . $re . PHP_EOL );

        yield from CoTimer::sleepAsync(1000 * 2);

        $connection->send(json_encode(array('productId' => 12, 're' =>true)));

        CoWorker::safeEcho('Response to :' . $conName . PHP_EOL . PHP_EOL);
    } catch (ConnectionCloseException $e) {
        CoWorker::safeEcho('Connection closed, ' . $e->getMessage() . PHP_EOL);
    }};CoWorker::runAll();

这里设置fork 一个worker线程，解决逻辑中带有一个sleep() 2s的操作，仍然没有影响他同时呼应多个申请。

启动测试顺序

## 启动CoWorker效劳$ php ./examples/example2/coWorkermanServer.php start## 启动申请线程$ php ./examples/example2/userClientFork.php

运转后果

绿色箭头——新的申请，白色箭头——呼应申请

从后果上看到，这一个worker线程，正在接纳新的申请同时，还正在回复以前的申请，各个衔接交织运转。而咱们的代码呢，看样子就是同步的，不回调。

CoWorker购物车效劳

好的，这里咱们做几个简略的微效劳模仿实际使用，这里模仿 用户申请端，购物车效劳，库存效劳，产物效劳。 模仿用户申请加购举措，购物车去辨别申请 库存，产物 校验用户能否能够加购，并呼应客户申请能否胜利。

代码我就没有贴了，过长了，费事移步 CoWorkerman/example/example5/coCartServer.php

运转饬令

## 启动库存效劳$ php ./examples/example5/otherServerFork.php 8081 inventory 1## 启动产物效劳$ php ./examples/example5/otherServerFork.php  8082 product 2

## 启动CoWorker 购物车效劳$ php ./examples/example5/coCartServer.php start

## 用户申请端$ php ./examples/example5/userClientFork.php

运转后果

黄色箭头——新的用户申请，蓝色箭头——购物车发动库存，产物反省申请，白色箭头——呼应用户申请

从图中看到也是用1个线程效劳多个衔接，交织运转。

好的，那末PHP CoWorkerman 也能像 NodeJS 那样用 Async/Await 那样同步编码，异步运转了。

快来尝尝这个 CoWorkerman 吧：

$ composer require paulxu-cn/co-workerman

工作原理

先上图：

图的上部是Workerman 的工作泳道图，图下部是CoWorkerman的工作泳道图。

workerman内的worker过程遇到梗阻函数的解决形式时，会期待IO前往，假如这个时分，又有了新的申请，那末闲的worker会竞争到这个新的衔接。

我正在上图worker5中，形容了一个AsyncTCPConnection应用状况，woker内发动了一个非梗阻申请，并注册了回调函数，而后顺序持续运转到完结。当异步申请呼应时，就需求经过其余形式去呼应（如本人再发动一个申请奉告申请方）。

正在下图中CoWorkerman，也是多个Worker竞争新的申请，当worker1收到一个新的申请，会孕育发生一个天生器，天生器内发动异步申请，并注册呼应回调，申请呼应后，回到该天生器跳出(yield)之处，持续执行代码。

发动异步申请，并注册回调函数，这些默许工作CoWorkerman框架内已做了，回调函数内工作是：收到数据，并发给 发动该申请的天生器。

这例子中，经过挪用 Promise:all() 发动多个申请，并监听后果前往，待一切的呼应前往再持续运转天生器

正在顺序yield跳出后，该worker就处于事情轮回状态($event->loop())，也就是多路监听：申请端口，第三方客户端申请呼应端口。这个时分假如：

1. 有新的申请来，他以及其余 worker 竞争新的申请，假如竞争到了，则该worker内又孕育发生一个新的 天生器。
2. 客户端有呼应，则挪用回调函数
3. 客户端都呼应了，持续运转 天生器顺序。

从1中，咱们可假定，假如就一个 Worker，那末该 Worker 能够正在上一个申请未实现状况下，持续承受解决下一个申请。也就是 CoWorkerman 能够正在单 Worker 下运转，并发解决多个申请。

当然，这里也有个条件，单 Worker 模式内不克不及运转梗阻函数，一旦梗阻，后续申请就会堵正在网卡。以是，除了非对本人的代码十分理解，假如用到第三方库，那末我仍是倡议你正在多 Worker 模式下运转 CoWorkerman，梗阻时，另有其余Worker兜住新申请。

CoWorkerman 的意思

1. 用同步的代码，发动异步申请，多个申请可并发，从IO串行期待，改成并行期待，缩小无畏的期待工夫。进步营业顺序的效率同时，没有升高代码可读性。
2. 正在一个线程内经过事情轮回，尽可能解决多个申请，减缓了一个申请一个线程带来的频仍线程切换，从外围上进步运转效率。

CoWorkerman 生态位

适宜解决纯Socket申请的使用，如Workerman Gateway，或许是 年夜前端 整合多个效劳RPC后果, 综合后返给前三页这样的场景.

日记记载是每一个顺序最根本需要，因为写文件函数是梗阻的，倡议用音讯行列步队，或许redis行列步队，更或许跳过Logstash间接丢Elasticsearch.

CoWorkerman有他的局限性，也有他本人地位。

总结

好～PHP 协程编码到 网络异步编码就到此完结了，假如看到本文章有不少纳闷，欢送留言发问，假如是 yield 语法没有太记患上，能够先读一读这个系列前几篇文章温习一下。

假如行，请三连。CoWorkerman 谢谢！

以上就是理解PHP yield的初级用法的具体内容，更多请存眷资源魔其它相干文章！