参考文献

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
<?php
require __DIR__."/../../vendor/autoload.php";

use DevPhpIO\Blocking\Worker;

$server = new Worker('0.0.0.0',9500);

$server->on('connect',function($server,$client){
    dd($client,'连接成功');
});

$server->on('receive',function($server,$client,$data){
    dd($data,'处理client的数据');
    sleep(5); // 进行阻塞，方便演示
    $server->send($client, "hello i’m is server");

    $server->close($client);
});

$server->on('close',function($server,$client){
    dd($client,'连接断开');
});

$server->start();

client.php

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
<?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";

$m = time() - $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 ，但是该模型，并不需要等待阻塞，而直接返回结果。

image-20210425230806578

上面的测试，虽然解决了，阻塞问题，但是又带来了一个新的问题，就是对于 server 返回的结果，无法拿到，所以根据上面的代码，打开 #1 的代码注释快，然后进行了如下的测试：

用 feof 判断是否到了指针的结束位置，如果到达了指针的结束位置，则输出 server 反馈的值。

image-20210425232603592