<分区>
我正在尝试了解套接字在 C# 中的工作原理。我的想法是编写一个简单的 http 代理: 这是我的代码:
using System;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading;
class Program
{
static void Main(string[] args)
{
ThreadPool.SetMaxThreads(1000, 500);
ThreadPool.SetMinThreads(500, 250);
TcpListener listener = new TcpListener(IPAddress.Any, 8282);
listener.Start();
while (true)
{
Socket client = listener.AcceptSocket();
ThreadPool.QueueUserWorkItem(ProcessSocket, client);
}
}
private static readonly string patternHostPort = @"(Host:\s)(\S+)(:)(\d+)";
private static readonly string patternHost = @"(Host:\s)(\S+)";
private static Regex regexHostPort = new Regex(patternHostPort);
private static Regex regexHost = new Regex(patternHost);
static void ProcessSocket(object request)
{
string requestString = string.Empty;
MemoryStream mStream = new MemoryStream();
int bytesReceived;
int bytesSended;
byte[] buffer;
byte[] byteOriginalRequest;
Socket socketClient = (Socket)request;
Console.WriteLine("Incoming connection: " + socketClient.RemoteEndPoint.ToString());
buffer = new byte[4096];
bytesReceived = socketClient.Receive(buffer, 0, buffer.Length, SocketFlags.None);
mStream.Write(buffer, 0, bytesReceived);
while (socketClient.Available > 0)
{
bytesReceived = socketClient.Receive(buffer, 0, buffer.Length, SocketFlags.None);
mStream.Write(buffer, 0, bytesReceived);
}
mStream.Close();
byteOriginalRequest = mStream.ToArray();
requestString = Encoding.ASCII.GetString(byteOriginalRequest);
//Console.WriteLine(requestString);
#region Get requested Host and Port
string srvHost = string.Empty;
string srvPort = string.Empty;
Match matchHostPort = regexHostPort.Match(requestString);
if (matchHostPort.Success)
{
srvHost = matchHostPort.Groups[2].Value;
srvPort = matchHostPort.Groups[4].Value;
}
else
{
Match matchHost = regexHost.Match(requestString);
if (matchHost.Success)
{
srvHost = matchHost.Groups[2].Value;
srvPort = "80";
}
else
{
Console.WriteLine("Invalid request?");
}
}
#endregion
Console.WriteLine(string.Format("Request to {0} on port {1}", srvHost, srvPort));
IPAddress[] ipAddress = Dns.GetHostAddresses(srvHost);
IPEndPoint endPoint = new IPEndPoint(ipAddress[0], int.Parse(srvPort));
using (Socket socketProxy = new Socket(endPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp))
{
socketProxy.Connect(endPoint);
bytesSended = socketProxy.Send(byteOriginalRequest, byteOriginalRequest.Length, SocketFlags.None);
MemoryStream m2Stream = new MemoryStream();
bytesReceived = 1;
while (bytesReceived > 0)
{
bytesReceived = socketProxy.Receive(buffer, 0, buffer.Length, SocketFlags.None);
m2Stream.Write(buffer, 0, bytesReceived);
}
m2Stream.Close();
byte[] finalResponse = m2Stream.ToArray();
string stringFinalResponse = Encoding.ASCII.GetString(finalResponse);
bytesSended = socketClient.Send(finalResponse, finalResponse.Length, SocketFlags.None);
socketProxy.Close();
}
socketClient.Close();
}
}
这里有一些问题:
1) 为什么我要替换这个
bytesReceived = 1;
while (bytesReceived > 0)
{
bytesReceived = socketProxy.Receive(buffer, 0, buffer.Length, SocketFlags.None);
m2Stream.Write(buffer, 0, bytesReceived);
}
有了这个
while (socketProxy.Available > 0)
{
bytesReceived = socketProxy.Receive(buffer, 0, buffer.Length, SocketFlags.None);
m2Stream.Write(buffer, 0, bytesReceived);
}
我只得到一个空白页面(在浏览器中)？
2) 可能与 1) 有关，但是......使用当前代码加载任何简单页面(如谷歌)需要一段时间，调试我发现问题可能是在 socketProxy.Receive ... 但我不知道为什么。
3)有什么区别
socketProxy.Send(byteOriginalRequest, byteOriginalRequest.Length, SocketFlags.None);
或
socketProxy.Send(byteOriginalRequest);
? (更多参数不是有效答案:)
4) 有推荐读物吗？书籍、教程、...？
5) 还有其他学习套接字的建议吗？
感谢您的宝贵时间。 最好的问候。