通过 Ratchet\ReactPHP 发送动作的状态更新

问题描述

我设置了一个安全的 websocket，并结合使用了 Ratchet 和 ReactPHP。我想要完成的部分工作是允许用户执行一些将发送到服务器的操作，并获得每个部分完成的通知 - 大致如下：

public function process()
{
    $this->currentconnection->send("Doing 1 of 3");
    // action first part of process
    $this->currentconnection->send("Doing 2 of 3");
    // uses output of first part to perform second
    $this->currentconnection->send("Doing 3 of 3");
    // uses output of second to perform third
    $this->currentconnection->send("Complete!");
}

然而，这有效地创建了一个阻塞函数，因为当它运行时，消息不会发送到连接，直到函数完成处理。

以前我通过在浏览器和 PHP 后端之间来回的 ajax 请求来完成此操作，但我认为我可以在没有来回的情况下完成此操作并使用 websocket（我正在使用其他功能）来实现这一点。

我一直在查看示例并尝试不同的方法来尝试实现这一目标，但我真的很挣扎，找不到任何其他地方可以实现的示例。现在感觉我需要将它作为子进程运行，然后（以某种方式）轮询它，但我发现这也很棘手。

因此，如果有人有建议、示例逻辑或我应该在哪里创建可以报告其过程的异步函数/类的指针，那就太棒了。谢谢。

解决方法

我已通过使用 $loop->futureTick 功能设法解决了我的问题。我创建了一个类，其中的动作被拆分为多个方法，如果方法结束，它会使用 futureTick 方法来排队下一个动作。我的意思的一个例子如下：

class Actions
{
    public function __construct(ConnectionInterface $conn,$loop)
    {
        $this->connection = $conn;
        $this->loop = $loop;
    }

    public function action1()
    {
        // ... do action ...
        if ($fail) {
            $this->connection->send('Action 1 failed');
        } else {
            $this->connection->send('Action 1 success');
            $this->loop->futureTick(function() {
                $this->action2();
            });
        }
    }

    public function action2()
    {
        ...
        $this->loop->futureTick(function() {
            $this->action3();
        });
    }
}

这允许通过循环完成每个操作，并且每次函数完成时都会通知客户端。

这可能不是实现这一目标的理想方式，因此我仍然愿意就是否（例如）将操作创建为单独的流程并在进行过程中告知连接方面的建议持开放态度。我只是不确定目前如何实现。