参考文献
5种IO模型：https://blog.mailjob.net/posts/3565199751.html
github代码下载：https://github.com/mailjobblog/dev_php_io/tree/master/test/noblocking
函数（stream_set_blocking）：https://php.golaravel.com/function.stream-set-blocking.html
函数（feof）：https://php.golaravel.com/function.feof.html
函数（stream_select）：https://php.golaravel.com/function.stream-select.html
IO非阻塞模型原理
非阻塞IO发出read请求后发现数据没准备好，会继续往下执行，此时应用程序会不断轮询polling内核询问数据是否准备好，当数据没有准备好时，内核立即返回EWOULDBLOCK错误。直到数据被拷贝到应用程序缓冲区，read请求才获取到结果。并且你要注意！这里最后一次 read 调用获取数据的过程，是一个同步的过程，是需要等待的过程。这里的同步指的是内核态的数据拷贝到用户程序的缓存区这个过程。
原生php代码演示
代码
server.php
<?php
require __DIR__."/../../vendor/autoload.php";
use DevPhpIO\Blocking\Worker;
$server = new Worker('0.0.0.0',9500);
{
mathJaxContainer[0]}server,$client){
dd($client,'连接成功');
});
{
mathJaxContainer[1]}server,{
mathJaxContainer[2]}data){
dd($data,'处理client的数据');
sleep(5); // 进行阻塞，方便演示
{
mathJaxContainer[3]}client, "hello i’m is server");
{
mathJaxContainer[4]}client);
});
{
mathJaxContainer[5]}server,$client){
dd($client,'连接断开');
});
$server->start();
client.php
<?php
require __DIR__."/../../vendor/autoload.php";
$fp = stream_socket_client("tcp://127.0.0.1:9500");
//设置套接字为非阻塞模型
stream_set_blocking($fp, 0);
fwrite($fp,'hello NO-blocking');
$time = time();
echo fread($fp,65535);
echo "\n此处执行其他业务代码\r\n";
{
mathJaxContainer[6]}time;
echo "执行时间" . $m . "秒钟\n";
// # 1
// 用 feof 判断是否到达结尾的位置，如果到达，则跳出输出服务端返回的结果
// while(!feof($fp)){
// sleep(1);
// var_dump(fread($fp,65535));
// }
// # 2
// 用 stream_select 去循环遍历server的读写状态
// while(!feof($fp)){
// sleep(1);
// $read[] = $fp;
// stream_select($read, $write, $error, 1);
// var_dump($read);
// var_dump(fread($fp,65535));
// }
fclose($fp);
Tips:
和 php阻塞模型 相比，该模型代码中，在 client.php 中增加了 stream_set_blocking($fp, 0); 进而达到了，不等待服务端返回结果，而直接进行下一步处理的过程。
测试
测试后发现，虽然服务端阻塞了 5s ，但是该模型，并不需要等待阻塞，而直接返回结果。
上面的测试，虽然解决了，阻塞问题，但是又带来了一个新的问题，就是对于 server 返回的结果，无法拿到，所以根据上面的代码，打开 #1 的代码注释快，然后进行了如下的测试：
用 feof 判断是否到了指针的结束位置，如果到达了指针的结束位置，则输出 server 反馈的值。
