Как идетифицировать сокет?

Question

[Андрей Корехов]

Пытаюсь реализовать следующую схему.
Поднят сервер на php, к нему цепляются разные клиенты, которые сразу после соединения один раз отсылают свои идентификаторы и далее ждут.
по факту соединения октрытые сокеты добавляются в общий массив.

Сам сервер 5 секунд слушает изменения
После чего опрашивает бд и вытаскивает оттуда новые сообщения которые кладутся туда другим сервисом

Далее идет обход записей и должен сверяться идентификатор который передал сокет и идентификатор из бд если они совпадают то отсылается сообщение. И вот здесь у меня две проблемы.
1. Я не могу идентифицировать сокет. Она частично решена через создание объекта где хранится сам ресурс + к нему добивается идентификатор при получении
2. Обход сокетов в цикле и попытка запушить в них сообщение - не работает, по непонятной мне причине на каждой итерации массив с сокетами становится пустым

код

while (time() < $time) {
    
    if (!empty($connects)) {
        foreach ($connects as $value) {
            $read[] = $value->SocketItem;
        }
    }else{
        $read = $connects;
    }

    $read[]= $socket; //$socket - это процесс сервера
    $write = $except = null;

    stream_select($read, $write, $except, 5);

    if (in_array($socket, $read)) {//есть новое соединение
        //принимаем новое соединение и производим рукопожатие:
        if (($connect = new SocketItem(stream_socket_accept($socket, -1))) && $info = handshake($connect->SocketItem)) {
            $connect->SetLog($log);
            $connects[] = $connect;//добавляем его в список необходимых для обработки
            onOpen($connect, $info, $log);//вызываем пользовательский сценарий
        }
        unset($read[ array_search($socket, $read) ]);
    }

    if (time() > $bd_time) {
        $bd_data = check_bd($db, $db_table);
        $bd_time = set_bd_time();
    }

    $log->AddToLog("Сокеты",$connects);

    foreach($connect as $key => $connect) {//обрабатываем все соединения
        $data = fread($connect->SocketItem, 100000);

        $connection_data = onMessage($connect, $data, $bd_data,$log);//вызываем пользовательский сценарий

        if (empty($bd_data)) {
            continue;
        }

        foreach ($bd_data as $rec_id => $record) {
            $log->AddToLog('Проверка базы',[$key,$record]);
            $msg = json_encode($record);
            if ($rec_id == $connect->SocketID) {
                $connect->send($msg);
            }  
        }

        if (!$data) { //соединение было закрыто
            fclose($connect);
            unset($connects[ array_search($connect->SocketItem, $connects) ]);
            onClose($connect,$log);//вызываем пользовательский сценарий
            continue;
        } 
    }
}
fclose($socket);

Comments

[Дмитрий]

$read[]= $socket;
не совсем понятно зачем вы в цикле нное количество раз загоняете это в массив?

и потом еще и проверяете его наличие
if (in_array($socket, $read)) {
Оно там точно есть - вы его туда только что положили. но зачем не понятно
потому что потом вы его сразу вычищаете

unset($read[ array_search($socket, $read) ]);

[Дмитрий]

foreach($connect as $key => $connect) {
ну а здесь вообще странное не что. у вас $connects вроде массив соединений. а вы пытаетесь иттерировать $connect причем перезаписывая его.

[Андрей Корехов]

Дмитрий, здесь опечатка в коде $connects и на нем же и тестировалось, извините не корректно перенес в вопрос код

[Андрей Корехов]

Дмитрий,

не совсем понятно зачем вы в цикле нное количество раз загоняете это в массив?

Вот тут в массив должно попадать текущее состояние сервера, которое далее обрабатывается и если есть изменения, то они переносятся в массив для обработки и далее уже идет работа с ним.

stream_select($read, $write, $except, 5)

Вот это при вычитке изменяет состояние $read если есть какие то изменения по официальной документации

Когда stream_select() возвращается, массивы read, write и except изменяются для того, чтобы указать, какие потоковые ресурсы на самом деле изменили статус. Исходные ключи массивов (array) сохраняются

Так что таким механизмом отслеживается новое подключение - честно я сам е до конца понимаю эту конструкцию но она работает так как описано и соединения четко подхватываются и обрабатываются - лишних точно не создается, да и на message сервер тоже редактирует адекватно - он его получает и тут же может овтетить. Проблемы начинаются когда стартует следующая итерация while и оказывается что в $connections нет соединений куда бы было можно запушить сообщение либо они все с исходными ключами а не присвоенными идентификаторами, хотя в конце цикла все ключи на месте