如何在ratchetphp上自动重新连接客户端？

Question

我正在使用rachetphp为api服务器创建一个客户端。 但我有一个问题，当我的连接关闭，无论原因，我无法自动重新连接。

这里的lib我使用：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(); 

我想尝试重新连接的连接结束后每隔几秒钟。 任何想法？

Answer 1

这个想法很简单，但它需要一些重构。我们必须将重新连接代码放入连接关闭时执行的处理程序中。为了做到这一点，我们通过$app函数。

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(); 

的想法是，当连接接收close事件，我们使用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); 
    }); 
});