PHP, websocket, как обрабатывать данные?

Question

[Flex78]

Здравствуйте! У меня мало практики и знаний в программировании на PHP, но для своих целей хватало. Интернет есть, добрые люди помогают. И вот я снова прошу помощи, в интернете не смог найти то что нужно. Речь идет про работу с websocket на PHP. Никогда с ними ранее не сталкивался, нашел кое какие описания, подключил библиотеки и вроде все нормально, но... всегда есть но! Кстати с классами я тоже не работал, а как я понимаю в составе библиотек приходится с ними работать. Вот код на одной площадке, который мне дали для работы с websocket

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

\Ratchet\Client\connect('wss://ws.binaryws.com/websockets/v3?app_id=1089')->then(
		function($conn) {
			$conn->on('message', function($msg) use ($conn) {
				$msg_php = json_decode($msg, 1); 
				$conn->close();
			});
			
			$conn->send('{"authorize" : "'.$token.'"}');
		});

То с чем у меня сложности:
1. вот сюда "$conn->send('{"authorize" : "'.$token.'"}');" мне нужно передать токен. Я не знаю как это сделать кроме как объявить переменную глобальной. Подскажите еще вариант пожалуйста.
2. Вот отсюда "$msg_php = json_decode($msg, 1); " нужно вытащить все данные за пределы функций/класса для дальнейшей обработки, и тут я совсем не знаю как это сделать. Если при работе с функциями используется return, то как его использовать тут?
3. Можно ли переписать код что бы он воспринимался проще? Может глупый вопрос, но я не работал с классами, в основном использовал процедурный стиль программирования.

Заранее спасибо за помощь всем кто откликнется!

Answer 1

[Николай Кокоулин]

1. не надо работать с сокетами на php (то что вам предложили это костыль, который убивает весь смысл сокетов)
PHP синхронный язык, веб сокеты Асинхронные, работать крайне не наглядно. Держать открытое соединение на PHP, крайне дурная затея.

PS. Если вас приковали к батарее и заставляют, то вот примерное решение которое лишено смысла, но должно работать. После того как произойдет коннект и вы вернете данные вебсокет закроется.

Это лямбда функция, вам в нее просто нужно просто передать переменные в которых ждете результат
Возможно библеотека использует промисы, без классов тут не обойтись

<?php
class ClassName {
    private $status = false;
    private $result;

    function connect($token)
    {
        \Ratchet\Client\connect('wss://ws.binaryws.com/websockets/v3?app_id=1089')->then(
            function($conn) use ($token) {
                $conn->on('message', function($msg) use ($conn) {
                    $msg_php = json_decode($msg, 1);
                    $this->result = $msg_php;
                    $conn->close();
                });
                $conn->send('{"authorize" : "'.$token.'"}');
                $this->status = true;
            });
    }
    
    function getResult() 
    {
        if ($this->status) {
            return null;
        }
        return $this->result;
    }
}

$token = 'qwerty';

$obj = new ClassName();
$obj->connect($token);

$result = null;
for ($i = 0; $i < 3; $i++) {
    $result = $obj->getResult();
    if ($result != null) {
        break;
    }
    sleep(1);
}

var_dump($result);

Так как вам нужен клиент, то скорее всего вы пишете какого-то бота, сделайте это лучше на Golang куда проще будет

Comments

[Flex78]

Спасибо огромное! Я действительно пишу БОТа, и меня приковали к батарее)) Точнее я сам себя приковал. PHP единственный язык который я знаю хоть как-то. Держать соединение открытым мне необходимости нет потому надеюсь что этого мне будет достаточно.

Ваш код я попробовал, но не сработало, я получаю NULL. Токен передается, запрос обрабатывается, ответ получаю, но возврата результата за пределы класса/функции нет.

[Николай Кокоулин]

Flex78, там вся хитрость в том, что вы ответ получаете после того, как обрабатывается код который его получает.

Скорее всего в библиотеке есть какой-то метод, использовав который можно заставить ждать ответа.

вобще можете пробовать вот это, тут попроще, но скорее всего работает похуже
https://github.com/paragi/PHP-websocket-client/blo...

[Flex78]

Николай Кокоулин, Спасибо, я обязательно попробую!