C++/CLI HTTP 代理问题

Question

我正在尝试（非常努力）制作一个小型 HTTP 代理服务器，我可以用它来将所有通信保存到文件中。由于我在该领域没有任何经验，因此我使用了 codeproject.com 中的一个类和一些相关代码来开始（它是用旧的 CLI 语法制作的，所以我对其进行了转换）。我无法让它工作，所以我添加了更多代码来使其工作（线程等），现在它可以工作了。基本上，它从客户端接收一些内容（我刚刚将 Mozilla Firefox 配置为通过此代理路由其连接），然后将其路由到 google.com。将 Firefox 的数据发送给 google 后，收到响应并将其发送给 Firefox。这工作正常，但代理无法从 Firefox 接收任何数据。它只是在 Sleep(50) 部分循环。不管怎样，代码如下：

ProxyTest.cpp:

#include "stdafx.h"
#include "windows.h"
#include "CHTTPProxy.h"

public ref class ClientThread {
public:
    System::Net::Sockets::TcpClient ^ pClient;
    CHttpProxy ^ pProxy;
    System::Int32 ^ pRecieveBufferSize;
    System::Threading::Thread ^ Thread;
    ClientThread(System::Net::Sockets::TcpClient ^ sClient,
                 CHttpProxy ^ sProxy,
                 System::Int32 ^ sRecieveBufferSize) {
        pClient = sClient;
        pProxy = sProxy;
        pRecieveBufferSize = sRecieveBufferSize;
    };
    void StartReading() {
        Thread = gcnew System::Threading::Thread(gcnew System::Threading::ThreadStart(this,&ClientThread::ThreadEntryPoint));
        Thread->Start();
    };
    void ThreadEntryPoint() {
        char * bytess;
        bytess = new char[(int)pRecieveBufferSize];
        memset(bytess, 0, (int)pRecieveBufferSize);
        array<unsigned char> ^ bytes = gcnew array<unsigned char>((int)pRecieveBufferSize);
        array<unsigned char> ^ sendbytes;
        do {
            if (pClient->GetStream()->DataAvailable) {
                try {
                    do {
                        Sleep(100); //Lets wait for whole packet to get cached (If it even does...)
                        unsigned int k = pClient->GetStream()->Read(bytes, 0, (int)pRecieveBufferSize); //Read it
                        for (unsigned int i=0; i<(int)pRecieveBufferSize; i++) bytess[i] = bytes[i];
                        Console::WriteLine("Packet Received:\n"+gcnew System::String(bytess));
                        pProxy->SendToServer(bytes,pClient->GetStream()); //Now send it to google!

                    } while (pClient->GetStream()->DataAvailable);
                } catch (Exception ^ e) {
                    break;
                }
            } else {
                Sleep(50);
                if (!(pClient->Connected)) break;
            };
        } while (pClient->GetStream()->CanRead);
        delete [] bytess;
        pClient->Close();
    };
};
int main(array<System::String ^> ^args)
{
    System::Collections::Generic::Stack<ClientThread ^> ^ Clients =
        gcnew System::Collections::Generic::Stack<ClientThread ^>();

    System::Net::Sockets::TcpListener ^ pTcpListener = gcnew System::Net::Sockets::TcpListener(8080);

    pTcpListener->Start();
    System::Net::Sockets::TcpClient ^ pTcpClient;
    while (1) {
        pTcpClient = pTcpListener->AcceptTcpClient(); //Wait for client

        ClientThread ^ Client = gcnew ClientThread(pTcpClient,
                                gcnew CHttpProxy("www.google.com.au", 80),
                                pTcpClient->ReceiveBufferSize); //Make a new object for this client

        Client->StartReading(); //Start the thread
        Clients->Push(Client); //Add it to the list
    };
    pTcpListener->Stop();
    return 0;
}

CHTTPProxy.h，来自http://www.codeproject.com/KB/IP/howtoproxy.aspx 进行了大量修改：

#using <mscorlib.dll>
#using <SYSTEM.DLL>
using namespace System;
using System::Net::Sockets::TcpClient;
using System::String;
using System::Exception;
using System::Net::Sockets::NetworkStream;
#include <stdio.h>

ref class CHttpProxy 
{ 
public: 
    CHttpProxy(System::String ^ szHost, int port); 
    System::String ^ m_host; 
    int m_port; 
    void SendToServer(array<unsigned char> ^ Packet, System::Net::Sockets::NetworkStream ^ sendstr); 
};

CHttpProxy::CHttpProxy(System::String ^ szHost, int port)
{
    m_host = gcnew System::String(szHost);
    m_port = port;
}

void CHttpProxy::SendToServer(array<unsigned char> ^ Packet, System::Net::Sockets::NetworkStream ^ sendstr)
{
    TcpClient ^ tcpclnt = gcnew TcpClient();

    try
    {
        tcpclnt->Connect(m_host,m_port); 
    }
    catch (Exception ^ e )
    {
        Console::WriteLine(e->ToString());
        return;
    }

    // Send it
    if ( tcpclnt )
    {
        NetworkStream ^ networkStream;

        networkStream = tcpclnt->GetStream();

        int size = Packet->Length;        
        networkStream->Write(Packet, 0, size);
        array<unsigned char> ^ bytes = gcnew array<unsigned char>(tcpclnt->ReceiveBufferSize);
        char * bytess = new char[tcpclnt->ReceiveBufferSize];
        Sleep(500); //Wait for responce 
        do {
            unsigned int k = networkStream->Read(bytes, 0, (int)tcpclnt->ReceiveBufferSize); //Read from google

            for(unsigned int i=0; i<k; i++) {
                bytess[i] = bytes[i];
                if (bytess[i] == 0) bytess[i] = ' '; //Dont terminate the string
                if (bytess[i] < 8) bytess[i] = ' '; //Somethings making the computer beep, and its not 7?!?!
            };
            Console::WriteLine("\n\nAbove packet sent to google. Google Packet Received:\n"+gcnew System::String(bytess)); 

            sendstr->Write(bytes,0,k); //Send it to mozilla

            Console::WriteLine("\n\nAbove packet sent to client..."); 
            //Sleep(1000);

        } while(networkStream->DataAvailable);

        delete [] bytess;
    }
    return;
}

任何帮助将不胜感激，我已经尝试了几个小时。 （对缩进 nobugz 感到抱歉，现已修复）