ラチェットWebsocket push integration

Question

私はWebsocket（Ratchet）を使ってチャットシステムを開発しようとしています。これまで、私はすでに以下のメソッドを使用して定義済みのJSONエンコードされたメッセージに答えることのできるPHPベースのWebsocketサーバーを作成しました。

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

問題は何かが私のテーブルに変更された場合、私は、右のクライアントにバックグラウンドワーカー/スレッドを経由してバックエンドのデータベースからメッセージをプッシュしたいということです。これはPHPを使って可能ですか？

私はクライアントが以下のように状態を更新するために5分ごとにwebsocketサーバに尋ねることは望ましくありません。

{"action":"giveMeUpdates"} 

が、ウェブサーバは、このような何か行うことができる必要があります。また

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

：

class Chat extends ChatActionHandler implements MessageComponentInterface { ... } 

これは、クライアントの要求と対話するためのChatActionHandlerは、機能を保持している私のクラスです。 MessageComponentInterfaceでは、function onOpen(ConnectionInterface $conn)のようなSocketイベントでしか返信できません。これは、RatchetIO Serverによってrunnedさ：

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

Answer 1

あなたはMessageComponentInterfaceは、このような機能を保持していない

$this->loop->addPeriodicTimer($timeout, function($timer) {});