我想使用 Ratchet (http://socketo.me) 在 iPhone 应用程序和服务器之间建立永久连接。我需要在应用程序和服务器之间交换数据。
从这个例子 (http://socketo.me/docs/hello-world) 我发现我有一个函数 onMessage 当应用程序向服务器发送消息并且服务器可以向服务器发送响应时将调用它应用程序。
但服务器还必须能够在不从应用程序获取数据的情况下向应用程序发送数据。例如，应用程序和服务器之间的连接已经建立。服务器上发生了一些事情，我们需要向应用程序发送新数据。我该怎么做？有可能吗？
主要问题是如何从服务器向应用程序发送数据？
感谢您的帮助。
【问题讨论】：
标签： php sockets websocket ratchet
这确实是可能的。您需要以某种方式与 WebSocket 服务器进程进行通信。您可以通过使用某种形式的消息传递来做到这一点，无论是 RPC 还是消息队列。
Ratchet 本身基于 React 事件循环。这意味着与 Ratchet 的任何形式的通信都必须与该事件循环集成。 On the React homepage你可以看到一些已经存在的集成：
在 Ratchet 文档中有 a tutorial on how to use React/ZMQ 以便将消息从任何地方推送到您的 WebSocket 服务器。
【讨论】：
Ratchet 还实现了 WAMP，其中包括 PubSub。因此，您的客户可以订阅某些主题，并且您可以让其他客户端（即在您的后端基础架构上运行）发布到这些主题。您可以让基于 AutobahnPython 的客户端通过 Ratchet 发布到基于 AutobahnAndroid 的移动应用程序或基于 AutobahnJS 的 HTML5 客户端。
【讨论】：
我有完全相同的问题，这就是我所做的。
基于hello world tutorial，我用数组替换了SplObjectStorage。在展示我的修改之前，我想评论一下，如果您遵循该教程并理解它，那么阻止您自己获得此解决方案的唯一可能就是不知道 SplObjectStorage 是什么。
class Chat implements MessageComponentInterface {
protected $clients;
public function __construct() {
$this->clients = array();
}
public function onOpen(ConnectionInterface $conn) {
// Store the new connection to send messages to later
$this->clients[$conn->resourceId] = $conn;
echo "New connection! ({$conn->resourceId})\n";
}
public function onMessage(ConnectionInterface $from, $msg) {
$numRecv = count($this->clients) - 1;
echo sprintf('Connection %d sending message "%s" to %d other connection%s' . "\n"
, $from->resourceId, $msg, $numRecv, $numRecv == 1 ? '' : 's');
foreach ($this->clients as $key => $client) {
if ($from !== $client) {
// The sender is not the receiver, send to each client connected
$client->send($msg);
}
}
// Send a message to a known resourceId (in this example the sender)
$client = $this->clients[$from->resourceId];
$client->send("Message successfully sent to $numRecv users.");
}
public function onClose(ConnectionInterface $conn) {
// The connection is closed, remove it, as we can no longer send it messages
unset($this->clients[$conn->resourceId]);
echo "Connection {$conn->resourceId} has disconnected\n";
}
public function onError(ConnectionInterface $conn, \Exception $e) {
echo "An error has occurred: {$e->getMessage()}\n";
$conn->close();
}
}
当然，为了让它真正有用，您可能还想添加一个数据库连接，并存储/检索这些资源 ID。
【讨论】：