Estoy usando rachetphp para crear un cliente para un servidor API. Pero tengo un problema, cuando mi conexión se cierra, sea cual sea el motivo, no puedo volver a conectarme automáticamente.
aquí la biblioteca que uso: https://github.com/ratchetphp/Pawl
<?php require __DIR__ . '/vendor/autoload.php'; $loop = React\EventLoop\Factory::create(); $connector = new Ratchet\Client\Connector($loop); $connector('ws://127.0.0.1:9000', ['protocol1', 'subprotocol2'], ['Origin' => 'http://localhost']) ->then(function(Ratchet\Client\WebSocket $conn) { $conn->on('message', function(\Ratchet\RFC6455\Messaging\MessageInterface $msg) use ($conn) { echo "Received: {$msg}\n"; $conn->close(); }); $conn->on('close', function($code = null, $reason = null) { echo "Connection closed ({$code} - {$reason})\n"; }); $conn->send('Hello World!'); }, function(\Exception $e) use ($loop) { echo "Could not connect: {$e->getMessage()}\n"; $loop->stop(); }); $loop->run();Me gustaría intentar una reconexión cada segundo después de que se cierre una conexión. ¿Algunas ideas?
La idea es simple pero necesita un poco de refactorización. Debemos poner el código de reconexión en el controlador que se ejecuta cuando se cierra la conexión. Para hacer eso, pasamos la función $app dentro de sí mismo.
require __DIR__ . '/vendor/autoload.php'; $loop = React\EventLoop\Factory::create(); $connector = new Ratchet\Client\Connector($loop); $app = function (Ratchet\Client\WebSocket $conn) use ($connector, $loop, &$app) { $conn->on('message', function (\Ratchet\RFC6455\Messaging\MessageInterface $msg) use ($conn) { echo "Received: {$msg}\n"; $conn->close(); }); $conn->on('close', function ($code = null, $reason = null) use ($connector, $loop, $app) { echo "Connection closed ({$code} - {$reason})\n"; //in 3 seconds the app will reconnect $loop->addTimer(3, function () use ($connector, $loop, $app) { connectToServer($connector, $loop, $app); }); }); $conn->send('Hello World!'); }; function connectToServer($connector, $loop, $app) { $connector('ws://127.0.0.1:9000', ['protocol1', 'subprotocol2'], ['Origin' => 'http://localhost']) ->then($app, function (\Exception $e) use ($loop) { echo "Could not connect: {$e->getMessage()}\n"; $loop->stop(); }); } connectToServer($connector, $loop, $app); $loop->run(); La idea es que cuando la conexión reciba el evento de close hagamos una reconexión usando la función connectToServer :
$conn->on('close', function ($code = null, $reason = null) use ($connector, $loop, $app) { echo "Connection closed ({$code} - {$reason})\n"; //in 3 seconds the app will reconnect $loop->addTimer(3, function () use ($connector, $loop, $app) { connectToServer($connector, $loop, $app); }); });Si tiene pnctl ( http://php.net/manual/en/book.pcntl.php ) instalado, puede cambiar el controlador 'cerrar' a esto:
$conn->on('close', function($code = null, $reason = null) { echo "Connection closed ({$code} - {$reason})\n"; // restart myself global $argv; pcntl_exec($_SERVER['_'], $argv); exit(); });Para mí, esto fue más simple porque aún no tenía el $loop y el $conector extraídos, solo estoy usando
\Ratchet\Client\connect($ws_url, [], $headers) ->then(function ($conn) { echo "connected\n"; ...Para manejarlo en varios lugares, creé una pequeña función de ayuda que invoco en esos eventos (según el caso, agrego un retraso).
function restartMyself() { global $argv; pcntl_exec($_SERVER['_'], $argv); exit(); }