socket_recv не получает полные данные

Вы настроили наш сокет как неблокирующий, указав MSG_DONTWAIT, поэтому он вернет EAGAIN после того, как прочитает первый блок данных, вместо того, чтобы ждать дополнительных данных. Удалите флаг MSG_DONTWAIT и вместо него используйте MSG_WAITALL, чтобы он ожидал получения всех данных.

Есть несколько способов узнать, получили ли вы все ожидаемые данные:

1. Отправьте длину данных. Это полезно, если вы хотите отправить несколько блоков содержимого переменной длины. Например, если я хочу отправить три строки, я мог бы сначала отправить «3», чтобы сообщить получателю, сколько строк ожидать, затем для каждой я бы отправил длину строки, а затем данные строки.
2. Используйте сообщения фиксированной длины. Если вы ожидаете несколько сообщений, но каждое из них имеет одинаковый размер, вы можете просто читать из сокета, пока у вас не будет хотя бы столько байтов, а затем обработать сообщение. Обратите внимание, что вы можете получить более одного сообщения (включая частичные сообщения) в одном вызове recv().
3. Закройте соединение. Если вы отправляете только одно сообщение, то вы можете наполовину закрыть соединение. Это работает, потому что TCP-соединения поддерживают отдельные состояния для отправки и получения, поэтому сервер и закрывает отправляющее соединение, но оставляет принимающее открытым для ответа клиента. В этом случае сервер отправляет все свои данные клиенту, а затем вызывает socket_shutdown(1 )

1394 примерно соответствует размеру MTU, особенно если вы туннелируете через VPN (а вы?).

Вы не можете рассчитывать на чтение всех байтов за один вызов, пакеты могут быть фрагментированы в соответствии с сетевым MTU.

Просто мои 2 цента на этом. socket_recv может возвращать false в случае ошибки. Где он также может получать ноль (0) байтов в неблокирующем вводе-выводе.

Ваша проверка в вашем цикле должна быть:

while(($bytes = socket_recv($resource, $r_data, 4000, MSG_DONTWAIT)) !== false) {}

Хотя я бы также проверил сокет на наличие ошибок и добавил вызов usleep, чтобы предотвратить «сжигание процессора».

$data = '';
$done = false;
while(!$done) {
    socket_clear_error($resource);
    $bytes = @socket_recv($resource, $r_data, 4000, MSG_DONTWAIT);

    $lastError = socket_last_error($resource);

    if ($lastError != 11 && $lastError > 0) {
        // something went wrong! do something
        $done = true;
    }
    else if ($bytes === false) {
        // something went wrong also! do something else
        $done = true;
    }
    else if (intval($bytes) > 0) {
        $data .= $r_data;
    }
    else {
        usleep(2000); // prevent "CPU burn"
    }
}

Мне интересно, есть ли у вас проблемы с подключением к веб-сокетам. Цикл while, который вы цитируете выше, мне кажется, находится в той части кода, где рукопожатие клиента не удалось, это в else из if($client->getHandshake()) { ... } else { ... }.

Насколько я могу судить, $client — это отдельный класс, поэтому я не вижу, как выглядит этот класс или что делает Client::getHandshake(), но я предполагаю, что это геттер логического значения, который содержит успех или неудача рукопожатия обновления веб-сокета.

Если я прав, рукопожатие завершается неудачей, и соединение закрывается клиентом. Из кода я вижу, что для используемого вами серверного кода требуется версия 13 спецификации. Вы не указываете, какую клиентскую библиотеку вы используете, но другие серверы будут принимать версии, отличные от этого сервера.

Убедитесь, что ваша клиентская библиотека поддерживает последнюю версию.

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

НО, разве та часть кода, которую вы вставили, не содержится в блоке else? Блок else, который мне кажется, что рукопожатие не прошло?

Не могли бы вы распечатать полученные байты в виде строки?

Я не думаю, что ваш вопрос корректен. Согласно исходному коду, если рукопожатие прошло успешно, выполняется этот участок кода:

$data = '';

while (true) {
    $ret = socket_recv($socket, $r_data, 4000, MSG_DONTWAIT);
    if ($ret === false) {
        $this->console("$myidentity socket_recv error");
        exit(0);
    }
    $data .= $r_data;
    if (strlen($data) > 4000) {
        print "breaking as data len is more than 4000\n";
        break;
    } else {
        print "curr datalen=" . strlen($data) . "\n";
    }
}

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

Класс сервера имеет третий параметр verboseMode, который, если установлено значение true, предоставит вам подробные журналы отладки о том, что именно происходит.

Мы будем просто рассуждать без журнала отладки, но если журнал отладки будет предоставлен, мы сможем предложить лучшее предложение.