C＃中的套接字：如何获取响应流？
我想替换这个：
void ProcessRequest(object listenerContext) { var context = (HttpListenerContext)listenerContext; Uri URL = new Uri(context.Request.RawUrl); HttpWebRequest.DefaultWebProxy = null; HttpWebRequest httpWebRequest = (HttpWebRequest)WebRequest.Create(URL); httpWebRequest.Method = context.Request.HttpMethod; httpWebRequest.Headers.Clear(); if (context.Request.UserAgent != null) httpWebRequest.UserAgent = context.Request.UserAgent; foreach (string headerKey in context.Request.Headers.AllKeys) { try { httpWebRequest.Headers.Set(headerKey, context.Request.Headers[headerKey]); } catch (Exception) { } } using (HttpWebResponse httpWebResponse = (HttpWebResponse)httpWebRequest.GetResponse()) { Stream responseStream = httpWebResponse.GetResponseStream(); if (httpWebResponse.ContentEncoding.ToLower().Contains("gzip")) responseStream = new GZipStream(responseStream, CompressionMode.Decompress); else if (httpWebResponse.ContentEncoding.ToLower().Contains("deflate")) responseStream = new DeflateStream(responseStream, CompressionMode.Decompress); MemoryStream memStream = new MemoryStream(); byte[] respBuffer = new byte[4096]; try { int bytesRead = responseStream.Read(respBuffer, 0, respBuffer.Length); while (bytesRead > 0) { memStream.Write(respBuffer, 0, bytesRead); bytesRead = responseStream.Read(respBuffer, 0, respBuffer.Length); } } finally { responseStream.Close(); } byte[] msg = memStream.ToArray(); context.Response.ContentLength64 = msg.Length; using (Stream strOut = context.Response.OutputStream) { strOut.Write(msg, 0, msg.Length); } } catch (Exception ex) { // Some error handling } } 带sockets。 这是我到目前为止：
void ProcessRequest(object listenerContext) { HttpListenerContext context = (HttpListenerContext)listenerContext; Uri URL = new Uri(context.Request.RawUrl); string getString = string.Format("GET {0} HTTP/1.1\r\nHost: {1}\r\nAccept-Encoding: gzip\r\n\r\n", context.Request.Url.PathAndQuery, context.Request.UserHostName); Socket socket = null; string[] hostAndPort; if (context.Request.UserHostName.Contains(":")) { hostAndPort = context.Request.UserHostName.Split(':'); } else { hostAndPort = new string[] { context.Request.UserHostName, "80" }; } IPHostEntry ipAddress = Dns.GetHostEntry(hostAndPort[0]); IPEndPoint ip = new IPEndPoint(IPAddress.Parse(ipAddress.AddressList[0].ToString()), int.Parse(hostAndPort[1])); socket = new Socket(ip.AddressFamily, SocketType.Stream, ProtocolType.Tcp); socket.Connect(ip);
开始新的代码
Encoding ASCII = Encoding.ASCII; Byte[] byteGetString = ASCII.GetBytes(getString); Byte[] receiveByte = new Byte[256]; string response = string.Empty; socket.Send(byteGetString, byteGetString.Length, 0); Int32 bytes = socket.Receive(receiveByte, receiveByte.Length, 0); response += ASCII.GetString(receiveByte, 0, bytes); while (bytes > 0) { bytes = socket.Receive(receiveByte, receiveByte.Length, 0); strPage = strPage + ASCII.GetString(receiveByte, 0, bytes); } socket.Close(); string separator = "\r\n\r\n"; string header = strPage.Substring(0,strPage.IndexOf(separator)); string content = strPage.Remove(0, strPage.IndexOf(separator) + 4); byte[] byteResponse = ASCII.GetBytes(content); context.Response.ContentLength64 = byteResponse .Length; context.Response.OutputStream.Write(byteResponse , 0, byteResponse .Length); context.Response.OutputStream.Close();
结束新代码
连接到套接字后我不知道如何让Stream响应解压缩，并发送回context.Response.OutputStream
任何帮助将不胜感激。 谢谢。 干杯。
编辑2：使用此编辑现在似乎工作正常（至少与HttpWebRequest相同）。 你在这里发现任何错误吗？
编辑3：误报……仍然无法正常工作
编辑4：我需要在Scott的代码中添加以下行…因为并非总是reponseStream的第一个字节是gzip幻数。 序列似乎是：0x0a（10），0x1f（31），0x8b（139）。 最后两个是gzip幻数。 第一个数字总是在我的测试之前。
if (contentEncoding.Equals("gzip")) { int magicNumber = 0; while (magicNumber != 10) magicNumber = responseStream.ReadByte(); responseStream = new GZipStream(responseStream, CompressionMode.Decompress); }
这里有一些适合我的代码。
using System; using System.Collections.Generic; using System.IO; using System.Net; using System.Net.Sockets; using System.Text; using System.IO.Compression; namespace HttpUsingSockets { public class Program { private static readonly Encoding DefaultEncoding = Encoding.ASCII; private static readonly byte[] LineTerminator = new byte[] { 13, 10 }; public static void Main(string[] args) { var host = "stackoverflow.com"; var url = "/questions/523930/sockets-in-c-how-to-get-the-response-stream"; IPHostEntry ipAddress = Dns.GetHostEntry(host); var ip = new IPEndPoint(ipAddress.AddressList[0], 80); using (var socket = new Socket(ip.AddressFamily, SocketType.Stream, ProtocolType.Tcp)) { socket.Connect(ip); using (var n = new NetworkStream(socket)) { SendRequest(n, new[] {"GET " + url + " HTTP/1.1", "Host: " + host, "Connection: Close", "Accept-Encoding: gzip"}); var headers = new Dictionary(); while (true) { var line = ReadLine(n); if (line.Length == 0) { break; } int index = line.IndexOf(':'); headers.Add(line.Substring(0, index), line.Substring(index + 2)); } string contentEncoding; if (headers.TryGetValue("Content-Encoding", out contentEncoding)) { Stream responseStream = n; if (contentEncoding.Equals("gzip")) { responseStream = new GZipStream(responseStream, CompressionMode.Decompress); } else if (contentEncoding.Equals("deflate")) { responseStream = new DeflateStream(responseStream, CompressionMode.Decompress); } var memStream = new MemoryStream(); var respBuffer = new byte[4096]; try { int bytesRead = responseStream.Read(respBuffer, 0, respBuffer.Length); while (bytesRead > 0) { memStream.Write(respBuffer, 0, bytesRead); bytesRead = responseStream.Read(respBuffer, 0, respBuffer.Length); } } finally { responseStream.Close(); } var body = DefaultEncoding.GetString(memStream.ToArray()); Console.WriteLine(body); } else { while (true) { var line = ReadLine(n); if (line == null) { break; } Console.WriteLine(line); } } } } } static void SendRequest(Stream stream, IEnumerable request) { foreach (var r in request) { var data = DefaultEncoding.GetBytes(r); stream.Write(data, 0, data.Length); stream.Write(LineTerminator, 0, 2); } stream.Write(LineTerminator, 0, 2); // Eat response var response = ReadLine(stream); } static string ReadLine(Stream stream) { var lineBuffer = new List(); while (true) { int b = stream.ReadByte(); if (b == -1) { return null; } if (b == 10) { break; } if (b != 13) { lineBuffer.Add((byte)b); } } return DefaultEncoding.GetString(lineBuffer.ToArray()); } } }
您可以将其替换为Socket / NetworkStream并节省一些工作。
using (var client = new TcpClient(host, 80)) { using (var n = client.GetStream()) { } }
根据定义，套接字是访问网络的低级别。 您甚至可以将数据报协议与套接字一起使用。 在这种情况下，流根本没有意义。
虽然我不确定你为什么要做HttpWebRequest轻松完成的任务，但是要读取/写入数据到套接字，你可以使用发送/接收方法。 如果您希望有一个像访问TCP套接字的流，您应该使用TcpClient / TcpListener类来封装套接字并为其提供网络流。
还有一个NetworkStream类，它将Socket作为参数。 ;）