用 PHP 实现聊天室出现问题，请教下问题所在。

问题描述：

     1.用 telnet  127.0.0.1  9999 首次访问，则显示第一个用户访问
     2.依次打开另外界面进行，则不显示内容
     3.但是如果我在第一个 telnet 输入内容 这时候才会出现第二个用户访问
     4.发送消息，也是如此
     举例：比如 A 发消息，B、C、D 可以收到。但是实际上呢，A 发消息后，B、C、D 必须也发一条消息后，才能收到其他人的消息。

        $host = "0.0.0.0";
        $port = "9999";
        $fd = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        socket_bind($fd, $host, $port);
        socket_listen($fd);
        $conn = [];
        $writeFds = [];
        $e = null;
        echo PHP_EOL . PHP_EOL . "欢迎来到 select 聊天室" . PHP_EOL . PHP_EOL;
        echo "           tcp://{$host}:{$port}" . PHP_EOL;
        echo $fd;
        while (true) {
            $readFds = array_merge($conn, [$fd]);
            if (socket_select($readFds, $writeFds, $e, null) > 0) {
                if (in_array($fd, $readFds)) {
                    $newConn = socket_accept($fd);
                    $i = intval($newConn);
                    $conn[$i] = $newConn;
                    $readFds[$i] = $newConn;
                    $writeFds[$i] = $newConn;
                    $key = array_search($fd, $readFds);
                    unset($readFds[$key]);
                    echo "第" . $i . "个用户来到聊天室" . PHP_EOL;
                }
                if (count($readFds) > 0) {
                    foreach ($readFds as $rfd) {
                        $line = socket_read($rfd, 2048);
                        foreach ($conn as $value) {
                            if ($rfd == $value) {
                                continue;
                            }
                            socket_write($value, $line, strlen($line));
                        }
                    }

                }

            } else {
                continue;
            }
        }

haiyang416

2019-10-11 18:01:09 +08:00

注释掉这行：$readFds[$i] = $newConn;
你刚 accept 就把它加入到 $readFds 数组，这时它还没有数据读取，接着马上在来一个阻塞的 socket_read，
你的程序会一直阻塞到这个连接有数据发送才会执行后面的代码。
并且每个新连接过来都会出现这个情况。

haiyang416

2019-10-11 18:50:58 +08:00

@awanganddong 跟情况无关，你的理解有问题。在 socket_select 之后 $readFds 里都是可以用于读取的“句柄”，它已经被 socket_select 函数修改了，这时你不应该自己往这个数组里加入新的数据，除非你可以确定它是有数据可读的。你只需要把新的连接加入到 $conn 数组，等待 while 循环再次调用 socket_select 即可。

awanganddong

2019-10-11 21:19:12 +08:00

@haiyang416 你能帮我解释下下边这个情况吗。

就是 telnet 初次连接的时候，打印 socket_select 下$readFds 里边为服务器的 fd 与客户端 fd，
然后 telnet 发送消息，就只剩下客服端的 fd。

socket_select 处理第一次连接和发送消息有什么不同呢。不理解

haiyang416

2019-10-11 23:21:03 +08:00

@awanganddong
$readFds 里面装的就是所有需要监听的描述符，可能有服务器的 fd，也可能有客户端连接的 fd，在经过 socket_select 之后，该函数会删除 $readFds 里暂时不可读的 fd。

$readFds = [$fd];
当前有新连接
socket_accept 之后增加了 $conn1，再次进入 while 循环。
--------------------------------------------------------
$readFds = [$fd, $conn1];
当前又有新连接
socket_accept 之后增加了 $conn2，再次进入 while 循环。
--------------------------------------------------------
$readFds = [$fd, $conn1, $conn2];
比如当前没有新连接，$conn1 收到了消息，$conn2 没有收到消息，
那么 socket_select 函数就会把 $fd 和 $conn2 从数组中删除，即 $readFds = [$conn1]；
处理完 $conn1 后会再次进入 while 循环。
--------------------------------------------------------
$readFds = [$fd, $conn1, $conn2];
当前又有新连接，$conn1 和 $conn2 没有收到消息
那么 socket_select 函数就会把 $conn1 和 $conn2 从数组中删除，即 $readFds = [$fd]；
socket_accept 之后增加了 $conn3，再次进入 while 循环。
--------------------------------------------------------
$readFds = [$fd, $conn1, $conn2, $conn3];

simonlu9

2019-10-12 00:32:30 +08:00

@haiyang416 不好意思，你说的是对的， $readFds[$i] = $newConn; 这句代码有问题，如果新连接 A 到刚 accept 马上 read 会导致堵塞代码的，所以当之后的连接都感应不了，只有等 A 发消息后，其他的连接才能 accept,然后才能收到消息
，处理这种错误最好每次读完消息都把它剔除，然后再加入 select

这是一个专为移动设备优化的页面（即为了让你能够在 Google 搜索结果里秒开这个页面），如果你希望参与 V2EX 社区的讨论，你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/608313