HttpListenerResponse и бесконечное значение для его свойства ContentLength64 - PullRequest
1 голос
/ 14 ноября 2011

У меня возникла проблема с прокси-потоком http.

Первое: я создаю сервер потоковой передачи мультимедиа по протоколу http с помощью проигрывателя VLC.

Второе: я слушаю http-запросы на одном порту с помощью HttpListener и пытаюсь переслать ответ от порта vlc-сервера в качестве ответа от первого.

Прокси-сервер:

Client            Server(:1234)                         VLC(:2345)
       -request-> HttpListener
                  HttpWebRequest           -request->
                  HttpWebResponse         <-response-
                 Stream <=Copy= Stream
      <-response- HttpListenerResponse

Все отлично работает. Но все же есть одна проблема. Я пытаюсь скопировать прямой эфир в HttpListenerResponse. Но я не могу добавить отрицательное значение к его свойству ContentLength64. Свойство HttpWebResponse ContentLength имеет значение -1. Это должно быть значение для бесконечной длины контента.

Это необходимо, потому что я пересылаю прямой эфир.

void ProxyRequest(HttpListenerResponse httpResponse)
{
    HttpWebRequest HttpWReq = (HttpWebRequest)WebRequest.Create("http://localhost:2345");
    HttpWebResponse HttpWResp = (HttpWebResponse)HttpWReq.GetResponse();

    // this must be >=0. Throws ArgumentOutOfRangeException "The value specified for a set operation is less than zero."
    httpResponse.ContentLength64 = HttpWResp.ContentLength;

    byte[] buffer = new byte[32768];
    int bytesWritten = 0;
    while (true)
    {
        int read = HttpWResp.GetResponseStream().Read(buffer, 0, buffer.Length);
        if (read <= 0)
            break;
        httpResponse.OutputStream.Write(buffer, 0, read);
        bytesWritten += read;
    }
}

У кого-нибудь есть решение этой проблемы?

1 Ответ

2 голосов
/ 14 ноября 2011

Установка свойства SendChunked в значение true и удаление присвоения значения ContentLength64 должны быть решением. Как описано в предоставленной вами ссылке.

void ProxyRequest(HttpListenerResponse httpResponse)
{
    HttpWebRequest HttpWReq = (HttpWebRequest)WebRequest.Create("http://localhost:2345");
    HttpWebResponse HttpWResp = (HttpWebResponse)HttpWReq.GetResponse();

    // Solution!!!
    httpResponse.SendChunked = true;

    byte[] buffer = new byte[32768];
    int bytesWritten = 0;
    while (true)
    {
        int read = HttpWResp.GetResponseStream().Read(buffer, 0, buffer.Length);
        if (read <= 0)
            break;
        httpResponse.OutputStream.Write(buffer, 0, read);
        bytesWritten += read;
    }
}
...