Почему сокет не сохраняется в массиве?

Question

[Aspirant555]

Имеется сокет:

$socket = stream_socket_server($transport . '://' . $host . ':' . $port, $errno, $errstr, STREAM_SERVER_BIND|STREAM_SERVER_LISTEN, $ssl_context);

Он равен: Resource id #8

Присваиваем его массиву:
$connects = array($socket);

Получаем :
a:1:{i:0;i:0;}

Что не так?

Answer 1

[galaxy]

serialize() обрабатывает все типы, кроме resource и некоторых типов object

https://www.php.net/manual/ru/function.serialize.php

Если вам интересно почему, попробуйте вообразить, как бы вы сами написали сериализатор, способный обрабатывать сокеты или, например, файловые ресурсы fopen().

Comments

[Aspirant555]

Благодарю за ответ.

Что-то типа этого я предполагал

serialize() обрабатывает все типы, кроме resource и некоторых типов object

Но, при поиске этого ресурса почему-то выдаёт "1":
in_array($socket, $read)

А при использовании в функции:
if (in_array($socket, $read)) {}

Функция не работает, собственно из-за чего и начал искать содержимое переменных.

Ещё интересно, $socket тип resource, а $read[0] - NULL

[FanatPHP]

aspirantes, а зачем вообще все эти бредовые телодвижения?

[galaxy]

aspirantes, без полного кода непонятно, что и где не работает

[Aspirant555]

FanatPHP, Не могу разобраться, почему сравнение нормально не работает.

[Aspirant555]

galaxy,

$ssl_context = stream_context_create($ssl);
$socket = stream_socket_server($transport . '://' . $host . ':' . $port, $errno, $errstr, STREAM_SERVER_BIND|STREAM_SERVER_LISTEN, $ssl_context);

if (!$socket) {
    writeToLog("$errstr ($errno)\n", 'Ошибка соединения');
    die("$errstr ($errno)\n");
}

file_put_contents(__DIR__."/222", '------');
$connects = array($socket);
$write = $except = null;
$i = 0;
while (true) {
    //формируем массив прослушиваемых сокетов:
    $read = $connects;
    $i++;
//    unset($_SESSION['vd']);
//    writeToLog($read.'__'.$socket.'__'.in_array($socket, $read));


    if ($i > 5) {
        writeToLog(serialize($connects));
        fclose($socket);
        die;
    }

    if (stream_select($read, $write, $except, 0) < 1) //ожидаем сокеты доступные для чтения
    continue;

    writeToLog($read);

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

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

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

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

[FanatPHP]

сравнение ЧЕГО С ЧЕМ?
и почему нельзя было СРАЗУ задать вопрос про сравнение, а не лить этот бред про сериализацию?

[Aspirant555]

FanatPHP, В массиве ищу сокет, но в функции он не работает, хотя

writeToLog($read.'__'.$socket.'__'.in_array($socket, $read));

Показывает Array__Resource id #8__1

[FanatPHP]

ЗАЧЕМ заниматься таким идиотизмом, как поиск сокета в массиве?

при чем здесь вообще все эти сериализации и сокеты, если $read у вас - NULL? ЧТО вы собрались в нем искать?
ЛОГИКА ГДЕ?!

[Aspirant555]

FanatPHP, не пойму почему он NULL, я ему присваиваю:

$connects = array($socket);
$read = $connects;

А для $connects присваиваю сокет

$socket = stream_socket_server($transport . '://' . $host . ':' . $port, $errno, $errstr, STREAM_SERVER_BIND|STREAM_SERVER_LISTEN, $ssl_context);

А на выходе NULL, почему?

[FanatPHP]

Ну вот этот вопрос и надо было задавать
а не про поиск в массиве, который NULL
и не про сериализацию

нельзя заниматься программированием, если не умеешь мыслить логически.

[galaxy]

aspirantes,

В массиве ищу сокет, но в функции он не работает, хотя

в какой функции? Где в вашем коде функция?

не пойму почему он NULL, я ему присваиваю:

а потом удаляете из массива:

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

Итого: сериализация вообще тут никаким боком, in_array - работает. Ищите ошибку в вашей логике.

[Aspirant555]

galaxy, Не всё так просто. Здесь in_arrayне работает:

if (in_array($socket, $read)) {//есть новое соединение
        //принимаем новое соединение и производим рукопожатие:
        writeToLog('Рукопожопие...');

По сериализации, в вашем ответе уже понятно, что ресурсы не отображаются.

writeToLog(print_r($read.'__'.$socket.'__'.in_array($socket, $read)));

выдаёт Array__Resource id #8__1, то есть сам in_array со значением 1, но if () {} не выполняется. Поэтому и ищу, почему сокета нет в массиве на данном этапе?

Без сериализации, $read[0] тоже равен NULL

[galaxy]

aspirantes,

if (stream_select($read, $write, $except, 0) < 1) //ожидаем сокеты доступные для чтения
    continue;

Вообще-то, тут вы ничего не ожидаете:

Параметры seconds и microseconds вместе формируют параметр timeout, seconds указывает число секунд, а microseconds - число микросекунд. Параметр timeout - это верхняя граница времени, которое функция stream_select() будет ожидать до возвращения. Если параметры seconds и microseconds оба установлены в 0, то функция stream_select() не будет ожидать данных - вместо этого она вернётся немедленно, указывая текущий статус потоков.

https://www.php.net/manual/ru/function.stream-sele...

Скорее всего, ваш цикл пять раз моментально прокручивается и выходит по die.

Как вы определили, что if () {} не выполняется? Уверены, что до него дело доходит?
Где у вас в коде вообще обращение к $read[0]? Вы, получается, постоянно меняете код и хотите, чтобы мы рассказали, почему он не так работает?

В конце концов, вы сами можете свой код подебажить? А то, знаете, удаленно через комментарии это немного неудобно.

[Aspirant555]

galaxy, Этот момент тоже менял, было

if (!stream_select($read, $write, $except, 5)) {//ожидаем сокеты доступные для чтения (без таймаута)
        break;
    }

Доходит 5 раз до

if (in_array($socket, $read)) {//есть новое соединение
        //принимаем новое соединение и производим рукопожатие:

и всё...

[galaxy]

aspirantes, а, стоп, только заметил: функция stream_select перезаписывает свои параметры (в частности, $read). Если нет новых данных на сокетах, $read будет пустой

[Aspirant555]

galaxy, то есть, событие правильно работает? А соединение происходит с сервером, и сервер молчит?

[galaxy]

aspirantes, больше похоже, что пять раз stream_select срабатывает вхолостую.
У вас же лог есть, вот и смотрите, что в нем.

[Aspirant555]

galaxy, Так и есть скорее всего $read то пустой.

Замечание:

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

Вопрос просто, почему?

[galaxy]

aspirantes, если $read пустой, а stream_select вернул что-то >0, значит $write или $except непустой

[Aspirant555]

galaxy, сделал так

$select = stream_select($read, $write, $except, 0);
    if ($select < 1) //ожидаем сокеты доступные для чтения
    continue;

получилось так: $select = i:0;

[galaxy]

aspirantes, ну это 0, т.е. никаких событий на сокетах.
Уберите 0 из последнего параметра stream_select, я уже писал, почему

[Aspirant555]

galaxy,

Внимание
Использование значения времени ожидания 0 позволяет вам мгновенно опросить статус потоков, однако ПЛОХАЯ идея использовать значение времени ожидания 0 в цикле, так как это заставит ваш скрипт потреблять слишком много процессорного времени.

Но я плавно снижал с 200000 рекомендуемых, на ситуацию повлияло положительно, так как для пяти опросов нагрузки особо нет, а скорость выполнения мгновенная. Для отладки пока так держу, но на всякий случай секунду добавил.

[Aspirant555]

galaxy, Подредактируйте ответ. stream_select обнуляет массив. А ноль возвращает, потому что ответа от сервера нет.

Answer 2

[Антон Шаманов]

а что по твоему он должен сохранить? ты же не настройки соединения сериализуешь, а ресурс т.е. id соединения

Comments

[Aspirant555]

Убрал я уже сериализацию из вопроса, в предыдущем ответе уже вывели цитату, что ресурсы не сериализуются, так же пришли к выводу, что stream_selectпереписывает значения, вопрос, почему они нулевые.

[Антон Шаманов]

aspirantes, потому что php приводит значения к сериализуемым: unserialize(serialize(tmpfile())) === 0

[Антон Шаманов]

aspirantes, если ты хочешь добиться чего-то подобного, то оберни свой код в класс

[Aspirant555]

Антон Шаманов, ну сериализация дело второе. $socket то выводит нормально, а если его добавить в массив $read, а потом попробовать найти в этом массиве, то после stream_select его там нет. А сам stream_select равен нулю.

Не знаю с чем связано, но $read[0] начал выдавать такое же значение, что и $socket.

Теперь осталось разобраться почему не работает

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

В логе выдаёт, что in_array($socket, $read) равен единице.

[Антон Шаманов]

aspirantes, ты опять забыл что php приводит типы, in_array($socket, $read, true) === false

[Aspirant555]

Антон Шаманов, так я в $read тот же самый ресурс и записываю, не преобразую.

[Aspirant555]

Антон Шаманов, А нет, всё таки после stream_select массив обнуляется...