Способ построения простого http прокси - PullRequest
Новая
       7

Способ построения простого http прокси

0 голосов
/ 28 марта 2019

Я пытаюсь создать простой http прокси , который выполняет четыре очень простых вещи:

  • Принимает соединение из веб-браузера (используя TcpClient / TcpListener).
  • Читает запрос из его потока.
  • Считывает имя хоста и инициирует соединение с хостом.
  • Загружает контент с веб-страницы и пересылает его обратно клиенту.

Проблемы , с которыми я встречался:

  • Иногда страница вообще не загружается.
  • Иногда браузер выдает мне сообщение «Контент имеет неправильное шифрование» (в Firefox).
  • Редко я вижу повреждение содержимого (простой текст вместо HTML).

Что я сделал:

  • Класс HttpListener, который содержит методы для прослушивания входящих запросов и вызова события OnNewRequestReceived: 
        public void Listen()
        {
            Listener.Start();

            while (true)
            {
                var client = Listener.AcceptTcpClient();

                Task.Run(() => StartReceivingData(client));      
            }

        }

        public void StartReceivingData(TcpClient client)
        {
            NetworkStream clientStream = client.GetStream();

            var buffer = new byte[16000];

            while (true)
            {
                try
                {
                    if (!clientStream.CanRead)
                        return;

                    //connection is closed
                    if (clientStream.Read(buffer).Equals(0))
                        return;

                    OnNewRequestReceived?.Invoke(this, new RequestReceivedEventArgs() { User = client, Request = buffer });
                } // when clientStream is disposed, exception is thrown.
                catch { return; }
            }
        }
  • Класс HttpClient, который в основном содержит метод, который подписывается на событие, описанное выше: 
 private void Listener_OnNewConnectionReceived(object sender, RequestReceivedEventArgs e)
        {
            string hostname = HttpQueryParser.GetHostName(e.Request);
            NetworkStream proxyClientStream = e.User.GetStream();

            try
            {
                if (firewall.CheckIfBlocked(hostname))
                {
                    //send error page
                    e.User.GetStream().Write(Encoding.ASCII.GetBytes("<html><body style=\"padding:0; margin:0;\"><img style=\"padding:0; margin:0; width:100%; height:100%;\" src=\"https://www.hostinger.co.id/tutorial/wp-content/uploads/sites/11/2017/08/what-is-403-forbidden-error-and-how-to-fix-it.jpg\"</body></html>"));
                    return;
                }

                var targetServer = new TcpClient(hostname, 80);

                NetworkStream targetServerStream = targetServer.GetStream();

                targetServerStream.Write(e.Request);

                var responseBuffer = new byte[32];

                for (int offsetCounter = 0; true; ++offsetCounter)
                {
                    var bytesRead = targetServerStream.Read(responseBuffer, 0, responseBuffer.Length);

                  //  Console.WriteLine($"Read {bytesRead} from {hostname}.");

                    if (bytesRead.Equals(0))
                        return;


                    proxyClientStream.Write(responseBuffer, 0, responseBuffer.Length);

                    if (offsetCounter.Equals(0))
                    {
                        var headers = Encoding.UTF8.GetString(responseBuffer).Split("\r\n");

                        logger.Log(new HttpRequestEntry()
                        {
                            ResponseCode = headers[0].Substring(headers[0].IndexOf(" ") + 1),
                            Hostname = hostname
                        });
                    }
                }

            }
            catch { return; }
            finally { proxyClientStream.Dispose(); }


        }

Итак, я предполагаю, что есть проблема с моим размером буфера, но изменение его на более высокие значения фактически ничего не меняет.

1 Ответ

0 голосов
/ 28 марта 2019

Хорошо, поэтому я не знаю, в чем проблема с моими байтовыми массивами, , но я заставил это работать, используя Stream.CopyTo, который меня очень удивил - он работает на двух NetworkStreams. Вот метод работы, если вам интересно: 

 private void Listener_OnNewConnectionReceived(object sender, RequestReceivedEventArgs e)
 {
            string hostname = HttpQueryParser.GetHostName(e.Request);
            NetworkStream proxyClientStream = e.User.GetStream();

            try
            {
                if (firewall.CheckIfBlocked(hostname))
                {
                    //send error page
                    e.User.GetStream().Write(Encoding.ASCII.GetBytes("<html><body style=\"padding:0; margin:0;\"><img style=\"padding:0; margin:0; width:100%; height:100%;\" src=\"https://www.hostinger.co.id/tutorial/wp-content/uploads/sites/11/2017/08/what-is-403-forbidden-error-and-how-to-fix-it.jpg\"</body></html>"));
                    return;
                }

                var targetServer = new TcpClient(hostname, 80);

                NetworkStream targetServerStream = targetServer.GetStream();

                targetServerStream.Write(e.Request);

                var responseBuffer = new byte[32];

                //this is to capture status of http request and log it.

                targetServerStream.Read(responseBuffer, 0, responseBuffer.Length);

                proxyClientStream.Write(responseBuffer, 0, responseBuffer.Length);

                var headers = Encoding.UTF8.GetString(responseBuffer).Split("\r\n");

                logger.Log(new HttpRequestEntry()
                {
                    ResponseCode = headers[0].Substring(headers[0].IndexOf(" ") + 1),
                    Hostname = hostname
                });

                targetServerStream.CopyTo(proxyClientStream);

            }
            catch { return; }
            finally { proxyClientStream.Dispose(); }


}
...