PHP Ratchet Web 套接字发送消息工作流

Question

我正在通过 PHP Ratchet 库开发聊天服务器，我对发送消息有疑问:

我有两种方法:onOpen(ConnectionInterface $conn)和 onError(ConnectionInterface $conn, \Exception $e) .

当客户端连接到聊天时调用 onOpen 方法并且我会发送响应消息，因此我这样做 $conn->send($data) .

如果有错误 onError被调用，但如果没有错误我怎么知道自从流程继续以来一切是否成功？ (我没有成功的方法)。

我问你以下问题，因为我必须管理以下情况:
当我将消息发送给客户端时，如果“发送”方法出错，我必须将无法发送的消息保存在数据库中，然后尝试推迟发送，而如果发送成功，则不必保存任何事物。我的问题是，如果“send”方法出错，则会调用“onError”方法，并且我只有关于“ConnectionInterface”的实例，但没有我无法发送的消息，那么此时我该怎么办？做恢复吗？

我希望我能清楚地解释问题

Answer 1

也许，有些像这样...

@例子:

// ...

/**
 * {@inheritDoc}
 */
public function onOpen(ConnectionInterface $connection)
{
    // ...

    $package = [
        'data'  => $data = [] // for example
    ];

    $json = json_encode($package, JSON_FORCE_OBJECT);

    $connection->currentMessage = $json;
    $connection->send($json);

    // $connection->send(null); // uncomment if you wanna simulate error (call onError())
}

// ...

/**
 * {@inheritDoc}
 */
public function onError(ConnectionInterface $connection, \Exception $e)
{
    $connection->currentMessage; <-- your current message

    // ... save message, etc, ...whatever you want :)

    $connection->close();
}

玩得开心!