Чтение повторяющегося источника потоковых данных в C#

Question

Предположим, у меня есть URL-адрес источника потоковых данных (например, поток обновленных данных о погоде), и я знаю, что этот URL-адрес работает с GET (я проверял, что он возвращает данные о пропаривании) , Поток сжат с помощью GZIP, каждое «сообщение» начинается с 1 байтового идентификатора, 2 байтовой части, содержащей длину сообщения, а затем еще 2 байта с некоторой запатентованной информацией. После этого появляется само сообщение, а затем этот формат повторяется до тех пор, пока поток остается открытым.

Мне нужно выполнить блок кода каждый раз, когда получено полное сообщение, которое будет анализировать необработанные байты в .net-типы (я могу выяснить часть разбора. Я уверен, что если у меня есть массив байтов для работы с). Я пробовал бесконечные способы, которые я нашел в сети для подобных ситуаций, но по какой-то причине не может заставить это работать. Если бы кто-то мог также объяснить, как сделать тот же процесс, используя POST вместо GET, который также будет оценен. Спасибо заранее всем!

P.S. По моим собственным попыткам это кажется, что только асинхронное чтение будет работать. Вот где я думаю, что падаю в своих попытках.

Bob

Answer 1

Я нашел несколько лучшие условия поиска и нашел этот вопрос, где ответ содержал информацию, которую я пропал без вести. Я работал с IAsyncResult и объектом состояния запроса некорректно.

C#: Downloading a URL with timeout

Answer 2

Что не работает, точно? Вы пытались получить ответный поток с GetResponseStream(), выполнив Stream.Read() в буфер byte[], а затем используя BitConverter?

Answer 3

Что-то вроде:

public IEnumerator<Message> GetEnumerator() 
{ 
    HttpWebRequest req = (HttpWebRequest) WebRequest.Create(uri); 
    req.AutomaticDecompression = DecompressionMethods.GZip; 
    Stream s = req.GetResponse().GetResponseStream(); 
    BinaryReader read = new BinaryReader(s); 
    while(true) 
    { 
     byte id = read.ReadByte(); 
     short len = (short)((read.ReadByte() << 8) | read.ReadByte()); 
     short proprietary = (short)((read.ReadByte() << 8) | read.ReadByte()); 
     byte[] msgBytes = read.ReadBytes(len); 
     yield return new Message(msgBytes); 
    } 
}