php - 运行后如何使用 Ratchet\Server\IoServer 对象？

Question

我想运行一个遍历生成器类的函数。只要 Ratchet 连接处于事件状态，生成器函数就会运行。我需要做的就是在执行 run 方法后实现这一点:

use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use MyApp\Chat;

require dirname(__DIR__) . '/xxx/vendor/autoload.php';

 $server = IoServer::factory(

    new HttpServer(
        new WsServer(
            new Chat()
        )
    ),

    8180,
    '0.0.0.0'

);

$server->run();

这是我需要在服务器启动后运行的方法:

function generatorFunction()
{

$products = r\table("tableOne")->changes()->run($conn);
 foreach ($products as $product) {
   yield $product['new_val'];
 }

}

以前我在 $server->run() 之前调用这个函数是这样的:

for ( $gen = generatorFunction(); $gen->valid(); $gen->next()) {
 var_dump($gen->current());
}
$server->run();

但这不允许客户端与 Ratchet 服务器建立连接。我怀疑它永远不会出现在 $server->run() 中，因为正在迭代生成器类。

所以现在，我想先启动服务器，然后调用这个生成器方法，让它可以一直监听rethinkdb中的变化。

我该怎么做？

Answer 1

让我们从例子开始:

<?php

require 'vendor/autoload.php';

class Chat implements \Ratchet\MessageComponentInterface {
    function onOpen(\Ratchet\ConnectionInterface $conn) { echo "connected.\n"; }
    function onClose(\Ratchet\ConnectionInterface $conn) {}
    function onError(\Ratchet\ConnectionInterface $conn, \Exception $e) {}
    function onMessage(\Ratchet\ConnectionInterface $from, $msg) {}
}

$loop = \React\EventLoop\Factory::create(); // create EventLoop best for given environment
$socket = new \React\Socket\Server('0.0.0.0:8180', $loop); // make a new socket to listen to (don't forget to change 'address:port' string)
$server = new \Ratchet\Server\IoServer(
    /* same things that go into IoServer::factory */
    new \Ratchet\Http\HttpServer(
        new \Ratchet\WebSocket\WsServer(
            new Chat() // dummy chat to test things out
        )
    ), 
    /* our socket and loop objects */
    $socket, 
    $loop
);

$loop->addPeriodicTimer(1, function (\React\EventLoop\Timer\Timer $timer) {
    echo "echo from timer!\n";
});

$server->run();

要实现您需要的功能，您不必在$server->run() 之前 或之后 运行循环，但是它需要同时运行。

为此，您需要比 Ratchet 更深入 - ReactPHP 及其 EventLoop .如果您有权访问 loop interface然后添加一个计时器(执行一次)或一个周期性计时器(每第 n 秒)是小菜一碟。