通过套接字发回守护进程的输出

Question

我正在创建一个 Twitter 客户端，我需要在后台处理来自每个 streaming processes (started with Symfony's Process component). I have a websocket server 运行的推文，这非常有效。

我的问题是我不知道如何从这些进程中获取数据流并通过套接字传回客户端。为了继续检查读取输出，我需要为其创建一个 while 循环，但这会阻止其他用户启动他们的流，因为套接字服务器将卡在该循环中。

如果可能，我想避免使用数据库队列。

服务器，从终端启动：

class StreamServer extends \WebSocketServer
{
    /**
     *
     * Called immediately when the data is recieved.
     *
     * @param $user
     * @param $message
     */
    protected function process($user, $message)
    {
        var_dump($user);
    }

    /**
     * Called after the handshake response is sent to the client.
     *
     * @param $user
     */
    protected function connected($user)
    {
        $streamer = new Process('php Streamer.php');
        $streamer->setTimeout(null);
        $streamer->start();

        $this->send($user, 'tweets');
    }

    /**
     * Called after the connection is closed.
     *
     * @param $user
     */
    protected function closed($user)
    {
        $this->disconnect($user->socket);
    }
}

$echo = new StreamServer("127.0.0.1", "9000");

try {
    $echo->run();
} catch (Exception $e) {
    $echo->stdout($e->getMessage());
}

主播：

class Streamer
{
    public function run()
    {
//        $this->user = $user;
        echo 'hello';


        $config = [
            'oauth' => [
                'consumer_key'    => '**',
                'consumer_secret' => '**',
                'token'           => '**',
                'token_secret'    => '**',
            ],
        ];

        $floodgate = Floodgate::create($config);

        $handler = function ($message)
        {
            var_export($message);
        };

        $generator = function ()
        {
            return [];
        };

        $floodgate->user($handler, $generator);
    }
}

$stream = new Streamer();
$stream->run();

Answer 1

我找到了一个解决方案，叫做 ReactPHP & Ratchet。

通过套接字发回守护进程的输出

Sending back the output of a daemon through a socket

php

twitter

streaming

daemon

symfony-process