私聊（PHP 实现）

摘要：服务端设置阻塞模式在现有资源列表中找不到给定资源对应的索引在现有资源列表中找不到给定用户对应的客户端资源监听客户端连接监听客户端消息来自客户端的消息客户端接受客户端发来的消息下午时间到来自的消息客户端发送消息给客户端下午时间到来

$url = "tcp://0.0.0.0:9160";

$stream = stream_socket_server($url , $errno , $errstr);

// 设置阻塞模式
stream_set_blocking($stream , false);

$client_list = [];

$resource_list = [];

$resource_list[] = $stream;

$find= function($client) use(&$client_list){
   foreach ($client_list as $k => $v)
   {
       if ($v["resource"] === $client) {
           return $k;
       }
   }

   echo "在现有资源列表中找不到给定资源对应的索引" . PHP_EOL;

   return false;
};

$find_client = function($username) use(&$client_list) {
    foreach ($client_list as $v)
    {
        if ($v["username"] === $username) {
            return $v["resource"];
        }
    }

    echo "在现有资源列表中找不到给定用户对应的客户端资源" . PHP_EOL;

    return false;
};

while (true)
{
    $read = $resource_list;
    $write = $resource_list;
    $except = [];
    $wait_s = 0;
    $wait_us = 0;

    stream_select($read , $write , $except , $wait_s , $wati_us);

    foreach ($read as $v)
    {
        if ($v === $stream) {
            // 监听客户端连接
            $client = stream_socket_accept($v);

            if (is_resource($client)) {
                $resource_list[] = $client;

                $client_list[] = [
                    "username" => null ,
                    "resource" => $client
                ];
            }
        } else {
            $index = $find($v);
            $user  = $client_list[$index];

            // 监听客户端消息
            $msg = fread($v , 65535);

            if (!empty($msg)) {
                if (!is_null($user) && is_null($user["username"]) && preg_match("/username:(w+)/" , $msg , $matches) === 1) {
                    $client_list[$index]["username"] = $matches[1];
                } else {
                    $msg = unserialize($msg);

                    $client = $find_client($msg["to"]);

                    if ($client !== false) {
                        fwrite($client , serialize($msg));
                    } else {
                        echo "来自客户端的消息：from:{$msg["from"]};to:{$msg["to"]};msg:{$msg["msg"]}
";
                    }
                }
            }
        }
    }

    usleep(100 * 1000);
}

 $username ,
    "to" => "yueshu" ,
    "msg" => "hello girl"
];

$is_flag = false;

while (true)
{
    $e_time = time();

    if ($e_time - $s_time > $duration) {
        echo "20s 时间到" . PHP_EOL;
        break;
    }

    if (!$is_flag) {
        fwrite($client , "username:" . $username);

        $is_flag = true;
    } else {
        // $sends = serialize($send);

        // fwrite($client , $sends);
    }

    $msg = fread($client , 65535);

    if (!empty($msg)) {
        $msg = unserialize($msg);

        echo "来自{$msg["from"]}的消息：{$msg["msg"]}
";
    }

    usleep(10 * 1000);
}

 $username ,
    "to" => "chenxuelong" ,
    "msg" => "hello boy"
];

$is_flag = false;

while (true)
{
    $e_time = time();

    if ($e_time - $s_time > $duration) {
        echo "20s 时间到" . PHP_EOL;
        break;
    }

    if (!$is_flag) {
        fwrite($client , "username:" . $username);

        $is_flag = true;
    } else {
        $send = serialize($msg);

        fwrite($client , $send);
    }

    /*
    $msg = fread($client , 65535);

    if (!empty($msg)) {
        $msg = unserialize($msg);

        echo "来自{$msg["from"]}的消息：{$msg["msg"]}
";
    }
    */

    sleep(1);
}