Как связать js и php веб сокеты?

Question

[Даниил Сухих]

Решил написать свой сервер на php для обработки websocket, узнал что нужно в ответ отсылать заголовок "рукопожатия". Так вот, когда я не отслыю заголовок то клиент подключаеться и ждёт, а когда отсылаю обратно то сразу закрываеться соединение и я получаюи сообщение: Connect close!

let socket = new WebSocket("ws://chat:8000/server.php");
socket.onopen = function () {
    message("<div>Connect!</div>")
}

socket.onerror = function () {
    message("<div>Connect error!</div>")
}

socket.onclose = function () {
    message("<div>Connect close!</div>")
}

socket.onmessage = function (e) {
    let data = JSON.parse(e.data);
    message("<div>" + data.type + " - " + data.message + "</div>>")
}

setInterval(function () {
    // console.log(socket.readyState)
})

function message(str) {
    let block = document.querySelector('.chat-result');

    block.insertAdjacentHTML('beforeend', str);
}

<?php
error_reporting(E_ALL);

/* Позволяет скрипту ожидать соединения бесконечно. */
set_time_limit(0);

/* Включает скрытое очищение вывода так, что мы видим данные
 * как только они появляются. */
ob_implicit_flush();

$address = '127.0.0.1';
$port = 8000;

if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false) {
    echo "Не удалось выполнить socket_create(): причина: " . socket_strerror(socket_last_error()) . "\n";
}

if (socket_bind($sock, $address, $port) === false) {
    echo "Не удалось выполнить socket_bind(): причина: " . socket_strerror(socket_last_error($sock)) . "\n";
}

if (socket_listen($sock, 5) === false) {
    echo "Не удалось выполнить socket_listen(): причина: " . socket_strerror(socket_last_error($sock)) . "\n";
}

do {
    if (($newSock = socket_accept($sock)) === false) {
        echo "Не удалось выполнить socket_accept(): причина: " . socket_strerror(socket_last_error($sock)) . "\n";
        break;
    }
    handshake($newSock);

} while (true);

socket_close($sock);

function handshake($newSock) {

    $header = socket_read($newSock, 1024);

    if (preg_match('/Sec-WebSocket-Key: (.*)/', $header, $match)) {
//        echo 'ok';
        $SecWebSocketAccept = base64_encode(pack('H*', sha1($match[1] . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
        $in_header = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
            "Upgrade: websocket\r\n" .
            "Connection: Upgrade\r\n" .
            "Sec-WebSocket-Accept:".$SecWebSocketAccept."\r\n\r\n";
        var_dump($in_header);
// Когда эта функция не выполнеяеться соединение висит не не отключаеться, а после её выполнения закрываеться сразу.
        socket_write($newSock, $in_header);
    }
}

Answer 1

[Сергей Соколов]

Хотя и можно найти или написать реализацию WS handshake на чистом PHP. Но далее продолжатся неудобства: для работы в (почти) реальном времени придется писать бесконечный цикл, в итерации которого проверять, есть ли новости в сокете. Будет работать, но костыльно и неэффективно.

Удобнее, например, добавить PHP модуль Swoole, который реализует полноценный WebSocket сервер, и заняться уже обработкой сообщений на высоком уровне — логикой вашего приложения.

Comments

[Mors Clamor]

А что насчет таких библиотек как Workerman и иже с ними?

[Даниил Сухих]

Спасибо за ответ, но не могли бы подсказать что в моём примере не так? После socket_write, происходит отключение со стороны клиента, т.е. "рукопожатие" не совершено. Почему так?

[Сергей Соколов]

Даниил Сухих, так там происходит выход из цикла и socket_close() – всё.

[Даниил Сухих]

Сергей Соколов, Вот такой код тоже не работает.

<?php
error_reporting(E_ALL);

set_time_limit(0);
ob_implicit_flush();

$address = '127.0.0.1';
$port = 8000;

$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
echo "Socket create...";
socket_bind($sock, $address, $port);
socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
echo "Socket bind...";
socket_listen($sock);
echo "Socket listen...";
while ($newSock = socket_accept($sock)) {
    echo "Socket accept...";
    $header = socket_read($newSock, 1024);
    echo "Socket read...";
    if (preg_match('/Sec-WebSocket-Key: (.*)/', $header, $match)) {
        $SecWebSocketAccept = base64_encode(pack('H*', sha1($match[1] . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
        $upgrade = "101 Switching Protocols\r\n" .
            "Upgrade: websocket\r\n" .
            "Connection: Upgrade\r\n" .
            "Sec-WebSocket-Accept: $SecWebSocketAccept\r\n\r\n";
        var_dump($upgrade);
        socket_write($newSock, $upgrade, strlen($upgrade));
    }
}

[Даниил Сухих]

Даниил Сухих, я получаю в консоли

var_dump($upgrade);

, но после соединение разрываеться.

[Сергей Соколов]

Даниил Сухих, подумайте, когда срабатывает условие внутри while()

[Даниил Сухих]

Сергей Соколов, уже взял за основу Workerman, подскажите а какой хостинг нужен для всего этого, как запустить этот сервер на хостинге?

[Сергей Соколов]

Даниил Сухих, сервер должен работать постоянным процессом, поэтому нужен VPS с shell-доступом.
Сначала попробуйте поднять всё это локально.

[Даниил Сухих]

Сергей Соколов, локально уже работает)