socket_read在使用socket_accept进入多个客户端时解除阻塞?

内容来源于 Stack Overflow,并遵循CC BY-SA 3.0许可协议进行翻译与使用

  • 回答 (1)
  • 关注 (0)
  • 查看 (238)

我有服务器套接字,客户端可以连接到我,读取和写入这样的套接字

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_bind($socket, $address, $port))
socket_listen($socket);
socket_set_nonblock($socket);

我在socket_accept中将socket_set_nonblock设置为非阻塞我的套接字这项工作正常但是对于连接到我的服务器的客户端我不能阻止客户端

while(true){
    if (($newc = @socket_accept($socket)) !== false) {
        //socket_set_nonblock($newc);
        //socket_set_option($socket,SOL_SOCKET, SO_RCVTIMEO, array("sec"=>5, "usec"=>0));
        $clients[] = $newc;
        $data = socket_read($newc, 1024, PHP_NORMAL_READ);
    }
    echo "do sometings ...";
}

我测试了socket_set_nonblock($ newc)和选项SO_RCVTIMEO以防止在socket_read中阻塞$ newc但是我没有成功阻止

我测试socket_select如下,但这不起作用

 $write = array();
 $expect = NULL;
 socket_select($clients, $write, $except, 0);

当第二个客户端连接到程序回显“做某事......”不工作,直到第二个客户端输入任何非阻塞socket_read我必须做什么?这是不可能的,或者我使用socket_select不正确?

提问于
用户回答回答于

我花了几个小时才终于有所作为。socket_set_nonblock($ newsock); Linux(CentOS)PHP7需要每个收入客户端,但它应该适用于Windows PHP5。

<?php
ini_set('error_reporting', E_ALL ^ E_NOTICE);
ini_set('display_errors', 1);
// Set time limit to indefinite execution
set_time_limit(0);
// Set the ip and port we will listen on
$address = '127.0.0.1';
$port = 6901;
ob_implicit_flush();
// Create a TCP Stream socket
$sock = socket_create(AF_INET, SOCK_STREAM, 0);
// Bind the socket to an address/port
socket_bind($sock, $address, $port) or die('Could not bind to address');
// Start listening for connections
socket_listen($sock);
// Non block socket type
socket_set_nonblock($sock);
// Clients
$clients = [];
// Loop continuously
while (true) {
    // Accept new connections
    if ($newsock = socket_accept($sock)) {
        if (is_resource($newsock)) {
            // Write something back to the user
            socket_write($newsock, ">", 1).chr(0);
            // Non bloco for the new connection
            socket_set_nonblock($newsock);
            // Do something on the server side
            echo "New client connected\n";
            // Append the new connection to the clients array
            $clients[] = $newsock;
        }
    }
    // Polling for new messages
    if (count($clients)) {
        foreach ($clients AS $k => $v) {
            // Check for new messages
            $string = '';
            if ($char = socket_read($v, 1024)) {
                $string .= $char;
            }
            // New string for a connection
            if ($string) {
                echo "$k:$string\n";
            } else {
                if ($seconds > 60) {
                    // Ping every 5 seconds for live connections
                    if (false === socket_write($v, 'PING')) {
                        // Close non-responsive connection
                        session_close($clients[$k]);
                        // Remove from active connections array
                        unset($clients[$k]);
                    }
                    // Reset counter
                    $seconds = 0;
                }
            }
        }
    }
    sleep(1);
    $seconds++;
}
// Close the master sockets
socket_close($sock);

扫码关注云+社区

领取腾讯云代金券