Как реализовать ratchet websocket push?

Question

[Silverviql]

Пытался переделать и запустить вебсокет пуш на yii2 по примеру из этого видео https://www.youtube.com/watch?v=wXCORk5xXPs&t=139s..
Пример кода можно посмотреть тут:
https://github.com/3u3ik/cp.lucky-wifi.ru/blob/fa4...
https://github.com/3u3ik/cp.lucky-wifi.ru/blob/fa4...
https://github.com/3u3ik/cp.lucky-wifi.ru/blob/fa4...

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

Argument 2 passed to React\Socket\Server::__construct() must implement interface React\EventLoop\LoopInterface, none given.

Если функцию конструктора изменить на:

public function __construct()
    {
        parent::__construct($this->id, $this->module);
    }

То выходит следующая ошибка:

PHP Fatal Error 'yii\base\ErrorException' with message 'Call to a member function getUniqueId() on null'

Рад любой помощи или совету.

Comments

[Максим Тимофеев]

Вы уже 69 раз этот вопрос задаете.

[Silverviql]

Максим Тимофеев, Ну тот был вопрос про запуск скрипта для запуска вебсокета на примере чата. А тут немного другое. И тот вопрос я в итоге сам решил... Вроде нашел решение https://gostash.it/ru/stashes/1533-podklucenie-k-s...

[Максим Тимофеев]

Silverviql, вот только ошибка таже самая и я точно уже объяснял Вам ее причину

[Silverviql]

Максим Тимофеев, Вы сказали что нету объекта. У меня есть 2 класса . 1 BasePusher с основными методами , и 2 класс Pusher с методом который отправляет данными в виде массива и методом где сервер отправляет сообщения тем кто подписан на события.
public function __construct()
{
$pusher = new Pusher; // Создаем объект класса Pusher
parent::__construct($this->id,$this->pusher);
}
Вы это имели ввиду ?

[Максим Тимофеев]

Silverviql, есть ошибка, есть ее текст (вы его привели и он мне однозначно понятен, я Вам его расшифровал), кроме этого в ошибке содержится весь лог вызовов, который к ней привел с указанием на классы и методы, а так же строки конкретные (их Вы не привели). Так что знать где именно она возникает я не могу в принципе. Это Вы посмотрите у Вас четкие данные перед глазами.

[Silverviql]

Максим Тимофеев, переделал код по данному примеру https://gostash.it/ru/stashes/1533-podklucenie-k-s...
Сервер запускается, данные

public function get () {
    $eventModel = [
        'subscribeKey' => 'eventMonitoring',
        'data'  => 'eventData' . rand(1,100)
    ];
    Book::pushEventToSocket($eventModel);
    var_dump($eventModel);
    }

отправляю, в pushEventToSocket данные приходят, а вот как проверить что они до сервера дошли ?

static function pushEventToSocket(array $eventModel)
    {
        $context = new \ZMQContext();
        $socket = $context->getSocket(\ZMQ::SOCKET_PUSH, 'desktop');
        if($socket instanceof \ZMQSocket)
        {
            // Здесь тоже передаём идентификатор, чтобы в push классе мы смогли получить объект topic
            $eventModel['subscribeKey'] = 'eventMonitoring';
            $eventData = json_encode($eventModel);
            $socket->connect("tcp://127.0.0.1:5555");
            $socket->send($eventData);
            file_put_contents('mekas1.txt', $eventData, FILE_APPEND);
        }
    }

Сервер

public function actionPushServer($port=5555)
    {
        $loop = Factory::create();
        // Класс, который реализуем ниже.
        $pusher = new EventPusher;

        // Listen for the web server to make a ZeroMQ push after an ajax request
        $context = new Context($loop);
        $pull = $context->getSocket(\ZMQ::SOCKET_PULL);
        // Binding to 127.0.0.1 means the only client that can connect is itself
        $pull->bind('tcp://127.0.0.1:'.$port);
        $pull->on('message', array($pusher, 'onPushEventData'));
        // Set up our WebSocket server for clients wanting real-time updates
        $webSock = new Server($loop);
        // Binding to 0.0.0.0 means remotes can connect
        $webSock->listen(8080, '0.0.0.0');
        $webServer = new IoServer(
            new HttpServer(
                new WsServer(
                    new WampServer(
                        $pusher
                    )
                )
            ),
            $webSock
        );

        $loop->run();
    }

[Максим Тимофеев]

Silverviql, У Вас js обращается к серверу и получает ответ, там исчерпывающая информация.

[Silverviql]

Максим Тимофеев,

$pull->bind('tcp://127.0.0.1:'.$port);
        $pull->on('message', array($pusher, 'onPushEventData'));

Подключается к каналу 'tcp://127.0.0.1:'.$port и ждет сообщения. Если есть запускает объект $pusher = new EventPusher; с методом onPushEventData

$eventData = json_encode($eventModel);
            $socket->connect('tcp://127.0.0.1:'.$port);
            $socket->send($eventData);

Массив полученный в json запихиваю подключаюсь к каналу , и отправляю данные . который сервер ждет. Но как узнать что подключились они вообще, пришло ли сообщение, словил его сервер ? Ошибок нету.

[Максим Тимофеев]

Silverviql, цитирую Ваш гайд (который Вы привели)

conn.subscribe('eventMonitoring', function(topic, data) {
        	// Сюда будут прилетать данные от вашего веб приложения.
            console.log(data);
        });

[Silverviql]

Метод который должен эти данные обработать и отдать клиентам которые на данное событие подписаны.

public function onPushEventData($event)
    {

        $eventData = json_decode($event, true);
        file_put_contents('mekas3.txt', $eventData, FILE_APPEND);
        //Здесь в массиве $eventData мы тоже передаём идентификатор и проверяем есть ли подписанные клиенты.
        if (!array_key_exists($eventData['subscribeKey'], $this->subscribedTopics))
        {
            return;
        }
        // Через этот идентификатор получаем нужный нам объект instanceof Topic.
        $topic = $this->subscribedTopics[$eventData['subscribeKey']];
        if($topic instanceof Topic)
        {
            foreach($eventData as $eventField => &$fieldValue)
                $fieldValue = Html::encode($fieldValue);

            // Посылаем данные клиенту
            $topic->broadcast($eventData);
        }
        else
        {
            return;
        }
    }

Но $eventData пустой. Поэтому я и спрашиваю, как узнать данные до сервера вообще дошли или нет. Данных нет поэтому клиент ничего не получает.

Вот даже цитирую того кто писал этот пост. Но данных нет)

$eventModel['subscribeKey'] = 'eventMonitoring';
$eventData = json_encode($eventModel);
$socket->connect("tcp://127.0.0.1:5555");
$socket->send($eventData);

Вот это и есть передача данных. $eventData
Здесь хочу заметить, что там куда они "прилетят", в моём примере это метод onPushEventData
для отладки xdebug и подобные отладки не сработают. Я много времени убил, пытаясь понять где же данные. А оказалось xdebug просто не делал останов в нужном месте ;)
В этом методе, после строчки $eventData = json_decode($event, true); можно поставить отладку, запись в файл, например. и там увидеть данные в массиве $eventData.

[Silverviql]

Максим Тимофеев, Есть ощущение что , что то не так с настройками сервера. т.к
bind сервера и connect отправки работают .
При включение сервера он создает прослушку данного канала

Коннект тоже происходит.

Но вот работает ли send или работает $pull->on('message', function ($msg) {
file_put_contents('mekas25.txt', $msg, FILE_APPEND);
});
Непонятно, т.к файл не создается .

[Максим Тимофеев]

Silverviql, странный путь к файлу. Возможно просто нет прав на запись.

[Silverviql]

Максим Тимофеев, Если прописать вот так file_put_contents('mekas25.txt', $pull, FILE_APPEND);
При запуске сервера он создает файл т.к $pull = $context->getSocket(\ZMQ::SOCKET_PULL); но внутри пусто)

метод on

public function on($event, callable $listener)
    {
        if (!isset($this->listeners[$event])) {
            $this->listeners[$event] = [];
        }

        $this->listeners[$event][] = $listener;

        return $this;
    }

Я вообще правильные параметры ему задаю ?)
Метод send

public function send($message, $mode = 0)
    {
    }

[Максим Тимофеев]

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

[Silverviql]

Максим Тимофеев, Вы неправильно поняли ,я проверил что доступ на запись есть, а так я

file_put_contents('mekas25.txt', $msg, FILE_APPEND);

только для $pull->on('message', function ($msg) { прописал чтобы проверить приходит ли сообщение. Как выяснилось не приходит. А почему непонятно.

[Silverviql]

Максим Тимофеев, Короче так и не заработало даже элементарный пример через консоль, я думаю у меня на локальной машине или какое то приложение блочит или не установлено какое то обновление и т.д т.к на гитхабе уже сталкивались с этим, на убунту работает. Вы не знаете как можно еще реализовать подписки ? Можно закостылить конечно и конектить сервер как клиент и каждое событие отправлять на какой нибудь обработчик ,который от севера напишет сообщение "Я добавил данные в бд" и делать клиентов которые будут подключатся к чатам как отдельные диалоги. Но это прям костыльное решение. Ну и дальше я не вижу смысла zmq ковырять т.к хостинг на котором развернут сайт не поддерживает данный модуль.

[Silverviql]

Максим Тимофеев, Я нашел решение , просто никогда не разрабатывать на windows, поставил ubuntu 16.04 настроил и все работает просто превосходно .