php stream_select兑现可控并发

php stream_select实现可控并发

<?php$time = 100;$parallel = 10;$sockets = array();$results = array();$failed = array();$id = 0;$url = 'localhost:8080';$http_msg = "GET /stream_select_req.php?delay=%s";$http_msg .= "HTTP/1.0\r\n";$http_msg .= "Host:localhost:8080\r\n\r\n";$timeout = 300;for($i = 0 ; $i < $parallel ; $i++){        $s = stream_socket_client($url,$errno,$errstr,$timeout,STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT);        if($s){                $sockets[$id++] = $s;                fwrite($s,sprintf($http_msg,$i));        }else{                echo "Stream $id falied to open correctly.";                $failed[] = sprintf($http_msg,$i);        }}while(count($sockets)){        $read = $sockets;        stream_select($read,$w=null,$e=null,$timeout);        if(count($read)){                foreach($read as $r){                        $index = array_search($r,$sockets);                        $data = fread($r,1024);            本#文来源gaodai$ma#com搞$$代**码网$搞代gaodaima码            if(strlen($data) == 0 ){                                echo "Stream $index closes at ".date('h:i:s')."
";                                fclose($r);                                unset($sockets[$index]);                                //add new task                                $next = $id++;                                if($next 

---

搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]‍，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：php stream_select兑现可控并发

喜欢 (0)赏

[搞代码]

分享 (0)