Odczytywanie danych z otwartego strumienia HTTP

Question

Próbuję użyć klas .NET WebRequest/WebResponse, aby uzyskać dostęp do interfejsu API przesyłania strumieniowego na Twitterze tutaj "http://stream.twitter.com/spritzer.json".

Muszę mieć możliwość otwierania połączenia i odczytu danych przyrostowo z otwartego połączenia.

Obecnie, gdy wywołuję metodę WebRequest.GetResponse, blokuje ona do momentu pobrania całej odpowiedzi. Wiem, że istnieje metoda BeginGetResponse, ale zrobi to samo na wątku tła. Muszę uzyskać dostęp do strumienia odpowiedzi, gdy pobieranie nadal trwa. Po prostu nie wydaje mi się to możliwe z tymi klasami.

Jest specyficzny komentarz na ten temat w dokumentacji Twitterze:

„Należy pamiętać, że niektóre biblioteki klienta HTTP tylko zwrócić treść odpowiedzi po połączenie zostało zamknięte przez serwer Tych klientów nie będzie działać dostępu. Interfejs API do przesyłania strumieniowego Należy użyć klienta HTTP, który będzie zwracał dane odpowiedzi stopniowo, na przykład większość odpornych bibliotek klienckich HTTP będzie zapewniać tę funkcjonalność, na przykład Apache HttpClient obsłuży ten przypadek użycia. "

Wskazują one na HttpClient Appache, ale to niewiele pomoże, ponieważ muszę używać .NET.

Wszelkie pomysły, czy jest to możliwe z WebRequest/WebResponse, czy też muszę przejść do niższych klas sieciowych? Może są inne biblioteki, które pozwolą mi to zrobić?

Thx Allen

Answer 1

Czy próbowałeś WebRequest.BeginGetRequestStream()?

Albo coś takiego:

HttpWebRequest request = (HttpWebRequest)WebRequest.Create (http://www.twitter.com); 
HttpWebResponse response = (HttpWebResponse)request.GetResponse(); 
StreamReader reader = new StreamReader(response.GetResponseStream()); 

string str = reader.ReadLine(); 
while(str != null) 
{ 
    Console.WriteLine(str); 
    str = reader.ReadLine(); 
} 

Answer 2

Wystarczy użyć WebClient. Jest przeznaczony do prostych przypadków, takich jak ten, w których nie potrzebujesz pełnej mocy WebRequest.

System.Net.WebClient wc = new System.Net.WebClient(); 
Console.WriteLine(wc.DownloadString("http://stream.twitter.com/spritzer.json")); 

Answer 3

skończyło się używając TcpClient, które działa prawidłowo. Nadal chciałbym wiedzieć, czy jest to możliwe dzięki WebRequest/WebResponse. Tu jest mój kodu w przypadku ktokolwiek jest zainteresowany:

using (TcpClient client = new TcpClient()) 
{ 

string requestString = "GET /spritzer.json HTTP/1.1\r\n"; 
requestString += "Authorization: " + token + "\r\n"; 
requestString += "Host: stream.twitter.com\r\n"; 
requestString += "Connection: keep-alive\r\n"; 
requestString += "\r\n"; 

client.Connect("stream.twitter.com", 80); 

using (NetworkStream stream = client.GetStream()) 
{ 
    // Send the request. 
    StreamWriter writer = new StreamWriter(stream); 
    writer.Write(requestString); 
    writer.Flush(); 

    // Process the response. 
    StreamReader rdr = new StreamReader(stream); 

    while (!rdr.EndOfStream) 
    { 
     Console.WriteLine(rdr.ReadLine()); 
    } 
} 
} 

Answer 4

BeginGetResponse jest metoda trzeba. To pozwala na odczyt strumienia odpowiedzi stopniowo:

class Program 
{ 
    static void Main(string[] args) 
    { 
     WebRequest request = WebRequest.Create("http://stream.twitter.com/spritzer.json"); 
     request.Credentials = new NetworkCredential("username", "password"); 
     request.BeginGetResponse(ar => 
     { 
      var req = (WebRequest)ar.AsyncState; 
      // TODO: Add exception handling: EndGetResponse could throw 
      using (var response = req.EndGetResponse(ar)) 
      using (var reader = new StreamReader(response.GetResponseStream())) 
      { 
       // This loop goes as long as twitter is streaming 
       while (!reader.EndOfStream) 
       { 
        Console.WriteLine(reader.ReadLine()); 
       } 
      } 
     }, request); 

     // Press Enter to stop program 
     Console.ReadLine(); 
    } 
} 

Albo jeśli czujesz się bardziej komfortowo z WebClient (I personnally wolą go WebRequest):

using (var client = new WebClient()) 
{ 
    client.Credentials = new NetworkCredential("username", "password"); 
    client.OpenReadCompleted += (sender, e) => 
    { 
     using (var reader = new StreamReader(e.Result)) 
     { 
      while (!reader.EndOfStream) 
      { 
       Console.WriteLine(reader.ReadLine()); 
      } 
     } 
    }; 
    client.OpenReadAsync(new Uri("http://stream.twitter.com/spritzer.json")); 
} 
Console.ReadLine();