Отправить сообщение из PHP-скрипта на сервер веб-сокета с храповым механизмом PHP без ZMQ или каких-либо пакетов PECL - PullRequest
Новая
       17

Отправить сообщение из PHP-скрипта на сервер веб-сокета с храповым механизмом PHP без ZMQ или каких-либо пакетов PECL

0 голосов
/ 04 октября 2019

КОНТЕКСТ

Я использую RatchetPHP, чтобы мои HTML-клиенты были синхронизированы с собой.

websocket-server.php

Я запускаю этот файл, используя php websocket-server.php, который бесконечно зацикливается для обработки соединений и сообщений веб-сокетов. 

<?php

require __DIR__ . "/../vendor/autoload.php";

use Me\Server;
use Ratchet\Http\HttpServer;
use Ratchet\Server\IoServer;
use Ratchet\WebSocket\WsServer;

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new Server()
        )
    ),
    8000
);

$server->run();

client.html 

<!DOCTYPE html>
<html lang="en">
    <head>
        <meta charset="UTF-8" />
        <meta name="viewport" content="width=device-width, initial-scale=1.0" />
        <meta http-equiv="X-UA-Compatible" content="ie=edge" />
        <title>Document</title>
    </head>
    <body>
        <script>
            var conn = new WebSocket("ws://127.0.0.1:8000");

            conn.onopen = function(e) {
                console.log("Connection established!");

                setTimeout(function() {
                    conn.send("coucou");
                }, 5000);
            };

            conn.onmessage = function(e) {
                console.log(e.data);
            };
        </script>
    </body>
</html>

Me \ Server.php

Это сервер, который обрабатывает события (сообщения, соединения). 

namespace Me;

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use SplObjectStorage;

class Server implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn) {
        // Store the new connection to send messages to later
        $this->clients->attach($conn);

        echo "New connection! ({$conn->resourceId})\n";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        $numRecv = count($this->clients) - 1;
        echo sprintf('Connection %d sending message "%s" to %d other connection%s' . "\n"
            , $from->resourceId, $msg, $numRecv, $numRecv == 1 ? '' : 's');

        foreach ($this->clients as $client) {
            if ($from !== $client) {
                // The sender is not the receiver, send to each client connected
                $client->send($msg);
            }
        }
    }

    public function onClose(ConnectionInterface $conn) {
        // The connection is closed, remove it, as we can no longer send it messages
        $this->clients->detach($conn);

        echo "Connection {$conn->resourceId} has disconnected\n";
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        echo "An error has occurred: {$e->getMessage()}\n";

        $conn->close();
    }
}

ATTEMPT

Мне также нужен мой бэкэнд для отправки сообщений на сервер сокетов, который сам отправит сообщение всем подключенным клиентам. Это серверная часть Laravel, которая, например, отправит клиентам сообщение о том, что доступна новая запись пользователя, и они должны перезагрузить свою веб-страницу. Вот моя попытка:

send.php 

$address="127.0.0.1";
$port="8000";
$msg="new user available";

$sock=socket_create(AF_INET,SOCK_STREAM,0) or die("Cannot create a socket");

socket_connect($sock,$address,$port) or die("Could not connect to the socket");
$result = socket_write($sock,$msg);

socket_close($sock);

Я заметил, что Ratchet анализирует HTTP-сообщения, поэтому, если я правильно понимаю, мне нужно отправитьHTTP-сообщение вместо простых сообщений (я подтвердил это, потому что, если я распечатаю необработанное сообщение до его анализа в файле vendor/cboden/ratchet/src/Ratchet/Http/HttpServer.php в начале метода onMessage, я вижу свое сообщение, но затем проверяется if (true !== $from->httpHeadersReceived) { не проходит, потому что я отправляю необработанный текст).

ВОПРОС

Как я могу отправить HTTP-сообщение на сервер веб-сокетов без каких-либо зависимостей, таких как ReactZMQа некоторые пакеты PECL?

...