Aufruf einer (Ratchet) WampServer Methode über einen React Timer

Question

Ich richte einen WampServer mit Ratchet ein. Ist es möglich, der Schleife einen Timer hinzuzufügen, der alle 30 Sekunden eine WampServer-Methode aufruft?

Ich habe den folgenden Code versucht:

public function addMonitoringTimer(){ 

    $this->loop->addPeriodicTimer(30, function() { 
     ... 
     $this->wampServer->methodName(); 
     ... 
    }); 

} 

aber keine Timer scheint zu funktionieren.

Hinweis: Da dieser Code eine Klassenmethode ist, $ ist dies ein Verweis auf das Klassenobjekt, das Verweise auf den WampServer ($ this-> wampserver) und die vom WampServer verwendete Schleife hat ($ this-> loop) . Die Methode, die ich anrufe, ist nicht Teil des WampServerInterfaces.

Answer 1

Nehmen wir an, Pusher ist die Klasse, die das WampServerInterface implementiert. Wir definieren eine benutzerdefinierte Methode (nicht Teil der Schnittstelle) onMessageToPush() in Pusher.

class Pusher implements WampServerInterface { 
    ... 
    public function onMessageToPush(){ 
     ... 
    } 
    ... 
} 

Erstellen Sie jetzt eine Reaktion Schleife:

$loop = \React\EventLoop\Factory::create(); 

, richten wir ein websocket Serverobjekt:

$webSock = new \React\Socket\Server($loop); 
$webSock->listen($bindPort, $bindIp); 

schaffen wir die WampServer Objekt:

$pusher = new Pusher(); 
$wampServer = new \Ratchet\Wamp\WampServer(
    $pusher 
); 

Wir haben einen I/O Server mit th eingerichtet e oben wamp Server, Web-Buchse und Schleife:

$ioserver = new \Ratchet\Server\IoServer(
     new \Ratchet\Http\HttpServer(
     new \Ratchet\WebSocket\WsServer(
       $wampServer 
      ) 
    ), 
     $webSock, 
    $loop 
); 

und jetzt können wir einen Timer definieren, die unsere eigene Methode aufrufen wird:

$loop->addPeriodicTimer(30, function() use ($pusher) { 
     $message = "my message"; 
     $pusher->onMessageToPush($message); 
}); 

Für alle, die daran interessiert sein kann, habe ich gebaut ein Beispiel, das zeigt, wie einige Funktionen mit Knarre, einschließlich der oben genannten Funktionen implementieren können Sie hier finden:

Example of using Ratchet