咱们好，我便是那个前两天招待打得太骚、现如今已不知怎样开场的老李。
在第八章和第九章的事例中，哥用socket和fork等根底为为咱们扮演了如下一波儿：
-
一个逐步演进的可支撑必定并发的TCP服务器
-
TCP服务器数据的承受和发送
细心感受一下，这个服务器的并发才能全赖fork()。
假如说均匀完结一次恳求会话事务处理均匀耗时一秒钟，那么理论上十个进程在一秒钟时刻粒度内一起最多支撑十个客户端的恳求会话处理。
也便是说，我要在一秒钟时刻粒度内均匀服侍一万个客户端，就要开TA个一万个进程（线程）左右... ...
到这里是时分又得回到我这个大众号姓名的flag上了，这个[ 高功能API社区 ]无疑便是个巨大的flag，为了能均匀一秒钟能服侍一万个客户端就得开一万个进程，这叫[ 高功能API ]？
...与高功能半毛钱联系都没有，好么？
-
低功能API社区
-
API最差实践
-
忽悠人的API社区
2020年让咱们一起重立这个高功能flag
总算写到select体系调用了，咱老李腰板也总算xue微xue微能直起来一点点了，不论咋说，多多少少算是和高功能挨上点儿边儿了，至少是和高IO能挨上点儿边儿了。
今日要说的这个东西叫做IO multiplexing，中文翻译叫做IO多路复用。
按我个人了解[ 多路 ]是指一大坨多个衔接恳求，[ 复用 ]是指这么多的一坨恳求一起占用一个或少量几个进程（线程），我这么一[ 歪解 ]咱们是不是忽然觉得还行...
前面咱们说过了运用进程（线程）完成TCP服务器，有一个定论便是只能用一个进程（线程）去支撑一个客户端链接，老李那会儿逃课去的网吧大约均匀数量能维持在400台左右，光服侍一个网吧就要搞400个进程（线程）？
可是后来工作呈现了转机，那便是2003年左右标志性的Linux Kernel 2.6，这个版别的Linux Kernel搭载了一种叫做epoll的核武器（之前其实也有搭载不过都是处于dev状况中的epoll）。
epoll总算完美处理了*NIX平台下的c10k问题，所以腾讯也敏捷跟进了。
依据是什么？
-
UDP服务器
-
TCP服务器
而其时一些刚兴起来的电脑知识论坛（什么电脑爱好者论坛、网友世界什么的）开端流传起“ 挑选TCP服务器 ”能够让谈天更快更安稳的小道传说，尽管大部分的初代网民们压根就不知道究竟啥叫TCP。
老李那会儿逃课去网吧通宵的时分，晚上打一圈CS、魔兽争霸III后没啥事儿了就喜爱跟网管扯淡，从运用//192.168.1.xxx/share/con/con让对方的Windows 9X设备死机、到怎样用X-Scan之类的扫描公网上开着3389弱口令的Windows 2000系主机、到怎样流通痛快地运用闻名软件[ PP点点通 ]、[ 哇嘎画年代 ]...啥都能聊，快乐地时分都会帮网管用GHOST给出了问题的机器做盗版XP体系用来交换下一次通宵时分的五折扣头优惠券。
记住后来有一天，我跟老肉、红旗一行五六个人又一起跑路去网吧通宵打CS，一边加两个robot开5V5，地图便是那张经典的沙漠2。
我跟红旗还有志超坐一排，老肉他们几个坐在咱们对面一排，半拉网吧都沉浸在咱们几个一边儿热情地吼叫声中。
大约打到清晨四点多的时分，忽然门口闯进来几个人，然后也不知道怎样着就和老肉后边那一排的几个人干起来了，两边打得贼剧烈拿键盘扛着凳子互相攻击，其时我和红旗都看呆了，志超跟老肉一看我俩在他人打架就吼了一声“ 你们俩TM快点儿啊！
我TM炸弹都装好了！
”，然后咱们几个持续静心打CS，那几个人也持续拿着键盘举着凳子打架。
大约到早上五点多的时分，网吧老板火急火燎地来了，咱们几个往后一看地上还躺着一个家伙，一脸都是血。
老肉说“ 咱们赶忙回去吧，一瞬间就赶不上早自习了 ”，所以咱们就跑了。
逐步忘掉标题... ... ......
其实也不必对IO多路复用产生恐惧感，这种东西严厉含义上说也不算是什么黑科技，要知道复用这种概念其实在通讯职业十分常见，即便在咱们日常日子里也是常见的很，这是一种思维，下面我测验用一个不太契合日子知识的比方来阐明论述下[ select多路复用 ]究竟大约是怎样个意思。
翻译一下：有一百个客户端会话衔接了上来，可是服务器中只要一个进程（线程）来服务这一百个客户端，这本是不或许的，可是进程（线程）能够经过运用IO复用来完成这个本来不或许的使命。IO复用能够回来给调用进程（线程）这一百个客户端会话中哪个能够读取音讯了、哪个能够写音讯了（在这里我要弥补的是，众所周知*NIX中一切皆为文件。所以在UNP或许APUE中，一个客户端衔接到服务器上实际上就会构成一个叫做文件描述符fd的东西，后边服务器从客户端读音讯或写音讯实际上便是读写这个文件描述符）。
现在常见的IO多路复用计划有select、poll、epoll、kqueue，这几个计划的联系大约是这样的：
-
select是*NIX呈现较早的IO复用计划，有较大缺点（缺点后边章节会弥补）
-
poll是select的升级版，但仍然归于新瓶旧酒
-
epoll是*NIX下终极处理计划，而kqueue则是Mac、BSD下同等级的计划
select体系调用，这个玩意是咱们今日的主角。在PHP里，操作select的函数叫做socket_select()或许stream_select()，我把socket_select()原型复制粘贴过来你们先感受一下：
// 这种参数我前面提到过，在apue里这种用法叫做
// 值-成果 参数
socket_select ( array $read ,
array $write ,
array $except ,
int $tv_sec [, int $tv_usec = 0 ]
)
// 将想要重视可读socket保存到read中，可是函数自身又会修正read参数内容
// 比方你将 四个socket 保存到了read中，表明select要监听这 四个 socket
// 上的可读事情。可是假如只要两个socket上呈现了可读，那么select就会
// 将这两个socket保存到read中，也便是read会被从有四个socket修正变成
// 只要两个socket，所以此处必定要留意！
// 实际上在PHP里不算是fd，而是一种叫做resource的概念
// 本质上仍然是fd
read
The sockets listed in the read array will be watched to see if characters become available for reading (more precisely, to see if a read will not block - in particular, a socket resource is also ready on end-of-file, in which case a socket_read() will return a zero length string).
// 将想要重视可读socket保存到read中
// 实际上在PHP里不算是fd，而是一种叫做resource的概念
// 本质上仍然是fd
write
The sockets listed in the write array will be watched to see if a write will not block.
// 反常的fd
except
The sockets listed in the except array will be watched for exceptions.
// 超时时刻
tv_sec
The tv_sec and tv_usec together form the timeout parameter. The timeout is an upper bound on the amount of time elapsed before socket_select() return. tv_sec may be zero , causing socket_select() to return immediately. This is useful for polling. If tv_sec is NULL (no timeout), socket_select() can block indefinitely.
tv_usec
你们还记住上篇结束那个留传的问题吗？便是假如将listen-socket设置为非堵塞，CPU简直就会跑满。这便对错堵塞的特色，我再次啰嗦一遍：当listen-socket被设置为非堵塞IO后，咱们运用socket_accept( listen-socket )从检测客户端衔接时就会从本来的[ 假如没有客户端衔接就会堵塞在这里一向比及有客户端衔接 ]变为[ 假如没有新客户端衔接就会立马回来然后持续进行一下测验 ]，这个进程有点儿类似于不断不断不断while。所以说，假如你想要运用非堵塞，就要调配上IO复用这种“ 异步 ”（为什么加上双引号是由于IO复用其实并不是满意POSIX界说的异步，但尔后咱们仍然先依照异步来称号）计划，到此为止，咱们总算逐步凑完全了网络上常见的[ 异步非堵塞 ]。
那么为什么说[ 非堵塞IO ]要调配这种根据事情的[ 异步 ]IO多路复用呢？还回到listen-socket上来，由于当时TA现已被设置成了非堵塞IO，所以CPU会不断不断不断while accept。可是此刻假如此刻将listen-socket加入到IO多路复用事情中，由于只要当可读（也便是有新客户端衔接时）IO复用才会奉告调用方，那么此刻再去accept就必定能够获取到新客户端，这样就完美地避免了打空炮行为。
小试牛刀一把，先用select完成一个根据TCP长衔接的异步非堵塞谈天室你们感受一下：
?php
$host = '0.0.0.0';
$port = 6666;
$listen_socket = socket_create( AF_INET, SOCK_STREAM, SOL_TCP );
// 假如你对之前的文章中的内容真的着手实践了的话，你就有必定概率
// 会遇到这个过错提示：address already in use
// 将SO_REUSEADDR设置为1，这样这个地址就能够被重复运用了
socket_set_option( $listen_socket, SOL_SOCKET, SO_REUSEADDR, 1 );
// 将SO_REUSEPORT设置为1，能够重复运用某个端口
socket_set_option( $listen_socket, SOL_SOCKET, SO_REUSEPORT, 1 );
socket_bind( $listen_socket, $host, $port );
socket_listen( $listen_socket );
// 将listen-socket设置为非堵塞
socket_set_nonblock( $listen_socket );
//socket_getsockname( $listen_socket, $addr, $port );
echo 'Chatroom - '.$addr.':'.$port.PHP_EOL;
// 将listen-socket加入到client数组中
$client = array( $listen_socket );
while ( true ) {
// 将client赋值给read
// 由于client中包括listen-socket
// 所以read中也会包括listen-socket
// 为什么还需求一个client数组呢？
// 由于select会修正read中，所以client适当所以
// 一种备份。client中保存的便是你一切想要监听
// 的socket，可是并不是每个socket都会有可读产生
// 可是select会修正read数组，将可读的socket
// 保存到read中，下次循环重新开端的时分，read需求
// 从client中再次将一切需求监听可读的socket悉数
// 拿过来
// 假如你没看理解，看看我上面函数原型里的注释
$read = $client;
$write = array();
$exception = array();
// ⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️
// 留意，体系会被堵塞在socket_select()上
// 一向到有 可读、可写等事情产生的时分
// 调用才会回来，并一起将可读、可写等数据主动保存
// 到read、write等数组中，ret回来成果是可读可写等
// 数量。
// 关于listen-socket而言，select会调用方监控
// 产生在listen-socket上的可读事情，即有新客户端衔接
// 衔接上来了
$ret = socket_select( $read, $write, $exception, NULL );
//print_r( $read );
//echo "select-loop : {$ret}".PHP_EOL.PHP_EOL.PHP_EOL;
if ( $ret = 0 ) {
continue;
}
// 便是说，假如 listen-socket 中有事情，listen-socket能有啥事情：便是用新的客户端来了
if ( in_array( $listen_socket, $read ) ) {
$connection_socket = socket_accept( $listen_socket );
if ( !$connection_socket ) {
continue;
}
socket_getpeername( $connection_socket, $client_ip, $client_port );
echo "Client {$client_ip}:{$client_port}".PHP_EOL;
// 将新衔接上来的客户端的socket保存到client中
$client[] = $connection_socket;
// 将listen-socket从read中手艺移除去，由于后边
// 要开端从connection-socket中读取数据了
// listen-socket上只能做accept操作不能做read操作
$key = array_search( $listen_socket, $read );
unset( $read[ $key ] );
}
// 关于其他的connection-socket
foreach( $read as $read_key = $read_fd ) {
// 读取数据吧～～～
socket_recv( $read_fd, $recv_content, 1024, 0 );
if ( !$recv_content ) {
echo "客户端 {$read_fd} 丢掉".PHP_EOL;
unset( $client[ $read_key ] );
socket_close( $read_fd );
continue;
}
$recv_content = "{$read_fd}说：".$recv_content;
// 将收到的音讯播送给除了自己以外的其他一切在线客户端，其实也便是除了自己fd之外的其他一切fd
foreach( $client as $fd_item ) {
if ( $fd_item == $listen_socket ) {
continue;
}
if ( $fd_item != $read_fd ) {
echo "发送给{$read_fd}".PHP_EOL;
socket_write( $fd_item, $recv_content, strlen( $recv_content ) );
}
}
// 下面三行注释是啥意思？
// 假如开着的话，客户端就会被断开衔接了
// 谈天室是需求长衔接的，不能断开
//unset( $client[ $read_key ] );
//socket_shutdown( $read_fd );
//socket_close( $read_fd );
}
}
跑一下成果如下，你们感受一下（友爱提示Windows用户 - Windows下应该是不可用、WSL或许也不好使）：
你们先渐渐感受一下，下篇咱们将根据这份代码完成一个HTTP服务器。
