Come gestire i dati di streaming in PHP?

Question

C'è una famiglia di metodi (birddog, shadow, and follow) nell'API di Twitter che apre una connessione (prevalentemente) permanente e consente di seguire molti utenti. Ho eseguito il codice di connessione di esempio con cURL in bash, e funziona bene: quando un utente che specifichi scrive un tweet, ottengo un flusso di XML nella mia console.

La mia domanda è: come posso accedere ai dati con PHP che non viene restituito come una chiamata di funzione diretta, ma è in streaming? Questi dati arrivano sporadicamente e imprevedibilmente, e non è qualcosa che abbia mai affrontato né so da dove cominciare a cercare risposte. Sarebbe gradito qualsiasi consiglio e descrizione di biblioteche o insidie.

Answer 1

fopen e fgets

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

Questo non è affatto grande (o anche buona) Codice ma dovrebbe forniscono le funzionalità necessarie. Sarà necessario aggiungere la gestione degli errori e l'analisi dei dati tra le altre cose.

Answer 2

Vorrei suggerire di utilizzare AJAX. Non sono uno sviluppatore PHP, ma penso che potresti collegare una chiamata AJAX all'API e aggiornare la tua pagina web.

Answer 3

Sono quasi sicuro che lo script scadrà dopo circa 30 secondi di ascolto dei dati sullo streaming. Anche se così non fosse, una volta ottenuto un carico significativo sul server, il semplice numero di connessioni aperte e in ascolto porterà il server alle sue ginocchia.

Suggerirei di dare un'occhiata a una soluzione AJAX che effettua una chiamata a uno script che memorizza solo una coda di messaggi. Non sono sicuro di come funzioni esattamente l'API di Twitter, quindi non sono sicuro che tu possa eseguire uno script quando richiesto per ottenere tutti i tweet, o se devi avere una sorta di demone per aggiungere i tweet a una coda che PHP può leggere e passare tramite la chiamata AJAX.

Answer 4

Non ci sono librerie per questo in questi giorni che fanno cose molto più facile (e gestiscono i bit difficili come reconnections, movimentazione presa, TCP backoff, ecc), vale a dire:

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

Answer 5

Phirehose è sicuramente il modo andare: il supporto flusso

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