Nejde mi poslat zprávu do WebSocket topicu přes ZeroMQ (ipublikuj/websockets-zmq)

WSS není tak super easy rozchodit, resp. když jsem to zkoušel během vývoje tak byl problém se SSL handshake na straně reactu :/ řeší se to pomocí proxy (popisoval sem v mailul, nevím zda dorazil)

V apache např takto:

ProxyPass „/sockets/“ „ws://yourdomain.com:9787“

Tedy volá se spojení z klienta na wss://yourdomain.com/sockets a apache to přeroutuje na ws://yourdomain.com:9787

Ad zmq pokud to nic neconsumuje tak možná že nesedly porty :/ každopádně na consumerovi jsou eventy https://github.com/…/en/index.md#… tak je zkus logovat jestli tam něco přijde

zmq je supereasy fronta. Jedině co ještě může dělat problém je obsazenost portu. Ve zkratce to jede tak že se otevře TCP kanál na vybraný port kde poslouchá consumer a pusher/producer se připojí jen pro komunikaci, pošle data a pak se odpojí.

a malé OT, vidím tam DATE_ISO8601 což je imo špatně: https://www.php.net/…nterface.php#…

akadlec napsal(a):

WSS není tak super easy rozchodit, resp. když jsem to zkoušel během vývoje tak byl problém se SSL handshake na straně reactu :/ řeší se to pomocí proxy (popisoval sem v mailul, nevím zda dorazil)

V apache např takto:

ProxyPass „/sockets/“ „ws://yourdomain.com:9787“

Tedy volá se spojení z klienta na wss://yourdomain.com/sockets a apache to přeroutuje na ws://yourdomain.com:9787

Ad zmq pokud to nic neconsumuje tak možná že nesedly porty :/ každopádně na consumerovi jsou eventy https://github.com/…/en/index.md#… tak je zkus logovat jestli tam něco přijde

zmq je supereasy fronta. Jedině co ještě může dělat problém je obsazenost portu. Ve zkratce to jede tak že se otevře TCP kanál na vybraný port kde poslouchá consumer a pusher/producer se připojí jen pro komunikaci, pošle data a pak se odpojí.

Povolil jsem v Apache moduly:

mod_proxy.so
mod_proxy_wstunnel.so

A do httpd-vhosts.conf jsem pridal:

ProxyPass        /sockets/ ws://127.0.0.1:8080

Na klientovi pak volam:

IPub.WebSockets.WAMP.initialize('wss://127.0.0.1:8080/sockets/');

A bohuzel handshake nekonci 101, ale request je porad pending a pak vytimeoutuje :(

Editoval crassus (31. 5. 2019 21:27)

nemůžeš volat stejný port IPub.WebSockets.WAMP.initialize('wss://127.0.0.1:8080/sockets/');
Pokud děláš proxy tak voláš jiný port a proxypass ti to přeroutuje takže IPub.WebSockets.WAMP.initialize('wss://127.0.0.1/sockets/');

akadlec napsal(a):

Ad zmq, pokud to neodpaluje eventy tak ten consumer vubec nic nedostane. Buď poslouchá na jiném portu než posílá consumer a nebo je ten port obsazeny. Jaký port si tam nakonfil?

    webSocketsZMQ:
        host: '127.0.0.1'
        port: 5555
        persistent: true
        protocol: 'tcp'

Zkousel jsem 5555, 5554 i treba 9787 a porad nic. Vam ta ZeroMQ fronta funguje? Vsiml jsem si totiz ze ta abstraktni metoda doPush() uvnitr IPub\WebSocketsWAMP\PushMessages\Pusher nikde neni implementovana.

akadlec napsal(a):

nemůžeš volat stejný port IPub.WebSockets.WAMP.initialize('wss://127.0.0.1:8080/sockets/');
Pokud děláš proxy tak voláš jiný port a proxypass ti to přeroutuje takže IPub.WebSockets.WAMP.initialize('wss://127.0.0.1/sockets/');

Ted jsem jeste zkusil navstivit https://127.0.0.1/sockets/, potvrdil jsem ze chci prejit na stranku, a pak jsem znovu spustil klienta, ktery mi ted pise:

autobahn.js:1293: WebSocket connection to ‚wss://127.0.0.1/sockets/‘ failed: Error during WebSocket handshake: Unexpected response code: 500

@crassus v configu WS serveru vůbec nenastavuj SSL tohle:

        secured:
            enable: true
            sslSettings:
                local_cert : 'C:\Apache24\conf\server.crt'
                local_pk : 'C:\Apache24\conf\server.key'
                allow_self_signed : true
                verify_peer : false

dej pryč. WS server ti poběží bez SSL, o SSL se ti postará právě ta proxy a certifikáty to bude mít takové co máš pro ten vhost

@crassus hele tak jsem tu zmq zkusil a normálně mě to běhá. V „presenteru“ mám:

		$this->socketsPusher->push($this->getClientsMessage($thing, $channel), 'IOServerExchange:Thing:', [
			'thing' => $thing->getPlainId(),
		]);

a controleru pr WS pak

	public function actionPush(
		array $data,
		IOServerModuleEntities\Things\IThing $thing,
		WebSocketsWAMP\Entities\Topics\ITopic $topic
	) : void {
		if (!$this->entityManagerHelpers->checkEntityManager()) {
			throw new WebSockets\Exceptions\TerminateException('EntityManager is closed.');
		}

		try {
			$topic->broadcast(Utils\Json::encode($data));

		} catch (Utils\JsonException $ex) {
			$this->logger->logException($ex, [
				'type'       => 'controller',
				'controller' => 'thing',
				'action'     => 'encode_payload',
				'thing'      => [
					'id' => $thing->getPlainId(),
				],
			]);
		}
	}

akadlec napsal(a):

@crassus v configu WS serveru vůbec nenastavuj SSL tohle:

        secured:
            enable: true
            sslSettings:
                local_cert : 'C:\Apache24\conf\server.crt'
                local_pk : 'C:\Apache24\conf\server.key'
                allow_self_signed : true
                verify_peer : false

dej pryč. WS server ti poběží bez SSL, o SSL se ti postará právě ta proxy a certifikáty to bude mít takové co máš pro ten vhost

Dal jsem celou konfiguraci pryc, ale pise to porad: WebSocket connection to ‚wss://127.0.0.1/sockets/‘ failed: Error during WebSocket handshake: Unexpected response code: 500

Asi budu mit tim padem spatne napsany ten ProxyPass.

Tady jeste posilam cely ten kontroler:

<?php

namespace App\Controllers;

use IPub\WebSockets\Application\Controller\Controller;
use IPub\WebSockets\Entities\Clients\IClient;
use IPub\WebSocketsWAMP\Entities\Topics\ITopic;
use Nette\Utils\Json;

class RaspberryPiController extends Controller
{
    public function actionSubscribe(IClient $client, ITopic $topic, int $id)
    {
        $topic->broadcast($client->getId() .' joined: ' . ' id: ' . $id);
    }

    public function actionUnsubscribe(IClient $client, ITopic $topic, int $id)
    {
        $topic->broadcast($client->getId() .' left: ' . ' id:' . $id);
    }

    public function actionPublish($event, IClient $client, ITopic $topic, int $id)
    {
        $topic->broadcast($client->getId() .' is saying: '. $event . ' , topic: ' . $topic->getId() . ' id: ' . $id);
    }

    public function actionPush(array $data, ITopic $topic)
    {
        \Tracy\Debugger::log("nezavola se");
        //$now = new \DateTime();
        $message = new \stdClass();
        $message->type = $data['type'];
        //$message->time = $now->format(DATE_ISO8601);
        $message->content = $data['content'];
        $topic->broadcast(Json::encode($message));
    }
}

Vsechny actions krome actionPush funguji.

Zkus update knihoven, vydal jsem nové verze a aktuálně mě fungujou. Ale zaměřil bych se primárně na to odstranění SSL, a promazání cache.

ano je to secured, resp spojení klient server je, server pak „interně“ už jede nezabezpečeně

Deploynul jsem projekt s těmi WebSockety na produkci, kde mám linux a tam ta fronta běží v pohodě.

zřejmě nemáš nainstalovanou zeroMq

akadlec napsal(a):

zřejmě nemáš nainstalovanou zeroMq

Je prosim vyše uvedená knihovna ta spravna?

akadlec napsal(a):

Bohužel ti nedokáži odpovědět. zmq nepoužívám už pár let

A muze byt prosim ta chyba (ZMQ socket failed to ack message) jeste zpusobena necim jinym?

akadlec napsal(a):

tak můžeš kouknout do kódu, hodit si tam dumpy/logy a uvidíš co je špatně

Jasne, na chybu jsem jiz prisel, posunul se dal, ale zde si nevim rady… v logu vypada vse OK, ale v prohlizeci se nic nestane

INFO: ZMQ transport listening on 127.0.0.1:5555
DEBUG: Starting IPub\WebSockets
DEBUG: Launching WebSockets WS Server on: 0.0.0.0:8080
DEBUG: INSERT CLIENT 188
DEBUG: GET CLIENT 188
INFO: New connection! (188)
DEBUG: GET CLIENT 188
DEBUG: INSERT TOPIC phone/1
DEBUG: GET TOPIC phone/1
DEBUG: GET TOPIC phone/1
DEBUG: INSERT TOPIC phone/1
INFO: Connection 188 has subscribed to phone/1
DEBUG: INSERT TOPIC /phone/1
DEBUG: GET TOPIC /phone/1
INFO: Message was pushed to /phone/1 topic

Udelal jsem si dump zde

public function actionPush(array $data, IPub\WebSocketsWAMP\Entities\Topics\ITopic $topic)
{
    Debugger::log($topic->getIterator(), 'WS2');

    $topic->broadcast(json_encode($data));
}

a $topic je pouze prazdny SplObjectStorage

	public function broadcast($message, array $exclude = [], array $eligible = []): void
	{
		if (!is_string($message) && !$message instanceof WebSocketsApplication\Responses\IResponse) {
			throw new Exceptions\InvalidArgumentException(sprintf('Provided message for broadcasting have to be string or instance of "%s"', WebSocketsApplication\Responses\IResponse::class));
		}

		$useEligible = (bool) count($eligible);

		Debugger::log($this->subscribers, 'X');
		/** @var WebSocketsEntities\Clients\IClient $client */
		foreach ($this->subscribers as $client) {
			Debugger::log($client, 'X');
			if (in_array($client->getId(), $exclude, true)) {
				continue;
			}

			if ($useEligible && !in_array($client->getParameter('subscribedTopics'), $eligible, true)) {
				continue;
			}

			$client->send(Utils\Json::encode([Application\Application::MSG_EVENT, $this->id, (string) $message]));
		}
	}

a funkce broadcast ma prazdnou promennou $this->subscribers

Vubec nechapu, kde je problem, ze tam neni prihlaseny uzivatel k topicu, kdyz v prvnim logu vidim, ze prihlaseni probehlo uspesne? :(

Zkus si ten kód prokrokovat, pak uvidíš, co se ve které chvíli děje. Je to poměrně jistý způsob odhalení problému, když člověk už fakt neví.