棘轮Websocket推动集成

function onMessage(ConnectionInterface $from, $msg){ ... }

问题是,如果我的表中发生了变化,我希望通过后台工作线程将消息从后端数据库推送到正确的客户端。这可以使用PHP吗?

我不希望客户端每隔5分钟要求websocket服务器刷新其状态,如下所示。

{"action":"giveMeUpdates"}

但是Web服务器应该能够执行以下操作:

{"status":"newMessages", "messagelist":[...]}

class Chat extends ChatActionHandler implements MessageComponentInterface { ... }

这是我的类,其中ChatActionHandler包含与客户端请求交互的函数。使用MessageComponentInterface,我只能回复套接字事件,如 function onOpen(ConnectionInterface $conn)

$server = IoServer::factory(
   new Chat(),
   8080);
$server->run();