PHPでストリーミングデータを扱うには？

Question

（ほとんど）永続的な接続を開き、多くのユーザーに従うことができるTwitter APIには、一連のメソッド（birddog, shadow, and follow）があります。私は、bashのcURLを使ってサンプル接続コードを実行しました。うまく動作します。私が指定したユーザーがツイートを書き込むと、私のコンソールにXMLのストリームが得られます。

私の質問は直接関数呼び出しとして返されないが、ストリーミングされるPHPでデータにアクセスするにはどうすればよいですか？このデータは散発的かつ予測不可能に到着しています。これまで対処してきたことではなく、回答の検索を開始する場所もわかりません。図書館や落とし穴に関するアドバイスや説明は高く評価されます。

Answer 1

fopenとfgets

<?php 
$sock = fopen('http://domain.tld/path/to/file', 'r'); 
$data = null; 
while(($data = fgets($sock)) == TRUE) 
{ 
    echo $data; 
} 
fclose($sock); 

これは素晴らしい（あるいは良い）コードを意味しますが、それがないであるはあなたが必要とする機能を提供する必要があります。エラー処理とデータ解析を他にも​​追加する必要があります。

Answer 2

AJAXの使用を検討することをお勧めします。私はPHP開発者ではありませんが、AJAX呼び出しをAPIに接続してWebページを更新できると思います。

Answer 3

ストリーム上のデータを聞く〜30秒後にスクリプトがタイムアウトすることは間違いありません。そうでない場合でも、重要なサーバー負荷が発生すると、オープンおよびリスニング接続の数が膨大になり、サーバーが無意味になります。

メッセージキューを格納するスクリプトを呼び出すAJAXソリューションを見てみることをお勧めします。私はTwitter APIがどのように正確に動作するのかよくわからないので、すべてのつぶやきを取得するように要求されたときにスクリプトを実行できるかどうか、またはデーモンのある種の並べ替えをキューに追加する必要があるかどうかはわかりませんPHPはあなたのAJAX呼び出しを介して読みとり返すことができます。

Answer 4

物事がはるかに容易になります（と再接続、ソケット取り扱い、TCPバックオフなどのようなトリッキーなビットハンドル）、すなわち、このこれらの日のためのライブラリがあります。

http://code.google.com/p/phirehose/

Answer 5

Phirehoseは間違いな方法です行き：

http://code.google.com/p/phirehose/