php高级语法

👤拔丝英语网 🕔2024/01/07 19:17 📁国外生活

本文转载于SegmentFault社区

作者：小白要生发

开篇

刚开始接触PHP 的 yield 的时候，感觉，yield 是什么黑科技，百度一下：yield——协程，生成器。很多文章都在讲 Iterator ，Generater, 蛤～，这东西是 PHP 迭代器的一个补充。再翻几页，就是Go 协程。我出于好奇点开看了下Go 协程, 里面都是并发，线程，管道通讯这类字眼，wc,nb, 这tm才是黑科技啊，再回来看PHP，分分钟想转 Go。

四部曲

yield 语法探究
yield from 语法探究
yield 实战“多线程”编码
PHP yield 高级用法网络——终章

yield 语法加入 PHP

yield语法是在版本5.5加入PHP的，配合迭代器使用，功能上就是流程控制代码，和goto，return 类似。

以下就是官方提供的 yield 小例子，通过执行结果，我们可分析当代码执行到 yield $i 时,他会进行 return $i，待 echo "$valuen" 后， 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 "$valuen";}
// output12...67

我们遇到了什么问题

写代码就是解决问题。我们来看看他们遇到了什么问题：php官方呢，需要言简意赅地把yield介绍给大家。一部分网友呢，需要在有限的资源内完成大文件操作。而我们的鸟哥。面对的一群对当下yield的教程停留于初级而不满意的phper，就以一个任务调度器作为例子，给大家讲了一种yield高级用法。

php.net:生成器语法：

https://www.php.net/manual/zh/language.generators.syntax.php
PHP如何读取大文件：

https://www.luyuqiang.com/how-php-read-a-large-file
风雪之隅:在PHP中使用协程实现多任务调度：

https://www.laruence.com/2015/05/28/3038.html

提出问题，再用yield来解答，看到以上答案，我觉得呢，这PHP协程不过如此（和Go协程相比）。

有句话——一个好问题比答案更重要，目前广大网友还没有给yield提出更好，更困难的问题。

yield这个进进出出的语法，很多举例都是再让yield做迭代器啊，或者利用低内存读取超大文本的Excel，csv什么的，再高级就是用它实现一个简单的任务调度器，并且这个调度器，一看代码都差不多。

我来出道题

正如一个好的问题，比答案更有价值

用PHP实现一个 Socket Server，他能接收请求，并返回Server的时间。

好，这是第一个问题，铺垫。官方答案：

https://www.php.net/manual/zh/function.stream-socket-server.php

在原来的代码上，我们加个需求，该Socket Server 处理请求时，依赖其他 Socket Server，还需要有 Client 功能。也就是他能接收请求，向其它Server发起请求。

这是第二个问题，也是铺垫。

原来的Socket Server同一时间只能服务一个客户，希望能实现一个非阻塞I/O Socket Server，这个 Server 内有 Socket Client 功能，支持并发处理收到的请求，和主动发起的请求。要求不用多线程，多进程。

这个问题，还是铺垫，这几个问题很干，大家可以想一想，2，3题的答案，都放在一个脚本里了：nio_server.php

https://gitee.com/xupaul/php-nio-server/blob/master/cart-server-demo/nio_server.php

以上这段代码，我列举了一个具体的业务，就是用户请求购物车加购动作，而购物车服务呢，又需要和产品服务，库存服务，优惠服务交互，来验证加购动作可行性。有同步，异步方式请求，并做对比。

后续还有很多代码，我都放gitee链接了。使用方法，见readme.md

最后一个问题：在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

不等大家的答案了，先上我的结果代码吧，代码呢都放在这个目录下了。

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

运行测试代码

clone 代码到本地后，需要拉起4个 command 命令程序：

拉起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 并发教程（https://www.runoob.com/go/go-concurrent.html）

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：

https://github.com/PaulXu-cn/CoWorkerman/blob/master/examples/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

总结

自此 PHP 协程编码到网络异步编码就到此结束了，如果看到这边文章有很多疑惑，或者对 yield 语法不了解的，那么读一读这个系列前几篇文章打打基础是非常有必要。

https://github.com/PaulXu-cn/CoWorkerman

参考

https://ericfu.me/several-ways-to-aync/
https://segmentfault.com/a/1190000018106557

点击左下角阅读原文，到 SegmentFault 思否社区 和文章作者展开更多互动和交流。

- END -

php高级语法

开篇

四部曲

yield 语法加入 PHP

我们遇到了什么问题

我来出道题

用yield来解决问题

运行测试代码

拉起3个第三方服务

启动购物车服务

发起用户请求

运行结果

非阻塞模式

阻塞模式

工作原理

和Golang比一比

和NodeJS比划一下

PHP yield 使用注意事项

爆改 Workerman

启动测试程序

运行结果

CoWorker购物车服务

运行命令

总结

参考

发表评论

发表回复

开篇

四部曲

yield 语法加入 PHP

我们遇到了什么问题

我来出道题

用yield来解决问题

运行测试代码

拉起3个第三方服务

启动购物车服务

发起用户请求

运行结果

非阻塞模式

阻塞模式

工作原理

和Golang比一比

和NodeJS比划一下

PHP yield 使用注意事项

爆改 Workerman

启动测试程序

运行结果

CoWorker购物车服务

运行命令

总结

参考

相关文章

发表评论

发表回复