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