我试图为我的业务建立一个简单的C# TCP代理人,以便我能够阻止我雇员的某些网站。 除了我难以看到用户试图访问哪一个网站外,所有网站都很好。 我可以看到,用户与我的代理服务器有关系,因此我知道我正在联系,但OnRecieve报警甚至连发射。 我读一下一下从一纸空文中看错了吗?

Here is my code:

internal class AsyncState
{
    public const int BufferSize = 4096;
    public byte[] Buffer = new byte[AsyncState.BufferSize];
    public Socket Socket;
    public StringBuilder Content = new StringBuilder();
}

private void OnLoad(object sender, EventArgs e)
{
    IPAddress[] addressCollection = Dns.GetHostAddresses(Dns.GetHostName());
    foreach (IPAddress ipAddress in addressCollection)
    {
        if (ipAddress.AddressFamily == AddressFamily.InterNetwork)
        {
            localEndPoint = new IPEndPoint(ipAddress, 8080);
            Console.WriteLine("Local IP address found... " + localEndPoint.ToString());
            break;
        }
    }

    isListening = true;

    thread = new Thread(new ThreadStart(
        delegate()
        {
            serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            serverSocket.Bind(localEndPoint);
            serverSocket.Listen(10);

            while (isListening)
            {
                resetEvent.Reset();

                Console.WriteLine("Waiting for clients...");
                serverSocket.BeginAccept(new AsyncCallback(OnAccept), serverSocket);

                resetEvent.WaitOne();
                }
            }));

        thread.Start();
    }
}

private void OnAccept(IAsyncResult result)
{
    resetEvent.Set();

    Socket clientSocket = (result.AsyncState as Socket).EndAccept(result);
    Console.WriteLine("Client has connected... " + clientSocket.RemoteEndPoint.ToString());

    AsyncState state = new AsyncState();
    state.Socket = clientSocket;
    state.Socket.BeginReceive(state.Buffer, 0, AsyncState.BufferSize, SocketFlags.None, new AsyncCallback(OnRecieve), state);
}

private void OnRecieve(IAsyncResult result)
{
    AsyncState state = result.AsyncState as AsyncState;

    int totalRead = state.Socket.EndReceive(result);
    if (totalRead > 0)
    {
        state.Content.Append(Encoding.ASCII.GetString(state.Buffer, 0, totalRead));
        state.Socket.BeginReceive(state.Buffer, 0, AsyncState.BufferSize, SocketFlags.None, new AsyncCallback(OnRecieve), state);
    }
    else
    {
        if (state.Content.Length > 1)
            Console.WriteLine("Message recieved from client... " + state.Content.ToString());

        state.Socket.Close();
    }
}