1.简介
多路是指多个客户端连接socket,复用就是指复用少数几个进程,多路复用本身依然隶属于同步通信方式,只是表现出的结果看起来像异步,这点值得注意.目前多路复用有三种常用的方案,依次是:
select,最早的解决方案
poll,算是select的升级版
epoll,目前的最终解决版,解决c10k问题的功臣随着互联网的普及,应用的用户群体几何倍增长,此时服务器性能问题就出现。最初的服务器是基于进程/线程模型。新到来一个TCP连接,就需要分配一个进程。假如有C10K,就需要创建1W个进程,可想而知单机是无法承受的。那么如何突破单机性能是高性能网络编程必须要面对的问题,进而这些局限和问题就统称为C10K问题
2.代码
<?php
// BEGIN 创建一个tcp socket服务器
$host = '0.0.0.0';
$port = 9999;
$listen_socket = socket_create( AF_INET, SOCK_STREAM, SOL_TCP );
socket_bind( $listen_socket, $host, $port );
socket_listen( $listen_socket );
// END 创建服务器完毕
echo '我启动了';
// 也将监听socket放入到read fd set中去,因为select也要监听listen_socket上发生事件
$client = [ $listen_socket ];
// 先暂时只引入读事件,避免有同学晕头
$write = [];
$exp = [];// 开始进入循环
while( true ){$read = $client;// 当select监听到了fd变化,注意第四个参数为null// 如果写成大于0的整数那么表示将在规定时间内超时// 如果写成等于0的整数那么表示不断调用select,执行后立马返回,然后继续// 如果写成null,那么表示select会阻塞一直到监听发生变化if( socket_select( $read, $write, $exp, null ) > 0 ){// 判断listen_socket有没有发生变化,如果有就是有客户端发生连接操作了if( in_array( $listen_socket, $read ) ){// 将客户端socket加入到client数组中$client_socket = socket_accept( $listen_socket );$client[] = $client_socket;// 然后将listen_socket从read中去除掉$key = array_search( $listen_socket, $read );unset( $read[ $key ] );}// 查看去除listen_socket中是否还有client_socketif( count( $read ) > 0 ){foreach( $read as $socket_item ){// 从可读取的fd中读取出来数据内容,然后发送给其他客户端$content = socket_read( $socket_item, 2048 );// 循环client数组,将内容发送给其余所有客户端foreach( $client as $client_socket ){// 因为client数组中包含了 listen_socket 以及当前发送者自己socket,所以需要排除二者if( $client_socket != $listen_socket && $client_socket != $socket_item ){sleep(1);socket_write( $client_socket, $content, strlen( $content ) );}}}}}// 当select没有监听到可操作fd的时候,直接continue进入下一次循环else {continue;}}
效果
3.学习地址
https://github.com/elarity/advanced-php/blob/master/11.%20PHP%20socket%E5%88%9D%E6%8E%A2---select%E7%B3%BB%E7%BB%9F%E8%B0%83%E7%94%A8.md