我使用boost asio处理客户端/服务器应用程序,特别是boost :: asio :: ip :: tcp :: socket来连接和传输数据.现在我使用boost :: asio :: async_read来重放一定数量的字节.到目前为止,在所有情况下,我都知道在调用处理程序之前我想要接收多少字节.因此我没有看到使用套接字meber函数read_some的原因.但我想知道为什么没有boost :: asio :: ip :: tcp :: socket的“async_read”成员函数,只有免费的.

所以我的问题是：是否存在概念或技术原因,为什么有一个read_some成员函数但没有readmember函数,或者“Boost只是忘了实现它”？

Asio中的所有流接口都提供read_some和async_read_some moethods.这适用于TCP套接字,SSL流和串行端口. read,read_until及其异步兄弟的实现都基于使用read_some方法具有相同的实现. read函数被写为通用模板,可以在其第一个参数上使用read_some方法来执行您请求的调用.

有些C支持者建议尽可能使用非朋友非成员函数,以便在类实现发生更改时最小化更改. read_some是接口,read只是一个包装器,在各种不同源的部分读取的情况下添加阻塞.

使用套接字,我不知道如何设置超时？

谢谢

int sock,connected,bytes_recieved;char send_data [128],recv_data[128];       SOCKADDR_IN server_addr,client_addr;    int sin_size;int j = 0;::socket(AF_INET,SOCK_STREAM,0);server_addr.sin_family = AF_INET;         server_addr.sin_port = htons(4000);     server_addr.sin_addr.s_addr = INADDR_ANY; ::bind(sock,(struct sockaddr *)&server_addr,sizeof(struct sockaddr));::listen(sock,5);::fflush(stdout);while(1){      sin_size = sizeof(struct sockaddr_in);    connected = ::accept(sock,(struct sockaddr *)&client_addr,&sin_size);    while (1)    {        j++;        ::send(connected,send_data,strlen(send_data),0);          //dealing with lost communication ?         //and reastablishing communication        //set timeout and reset on timeout error        }}::closesocket(sock);

套接字默认处于阻塞模式.如果使用ioctlsocket(FIONBIO)将其切换到非阻塞模式,则可以使用select()来管理超时：

SOCKET sock,connected;int bytes_recieved;  char send_data [128],recv_data[128];         SOCKADDR_IN server_addr,client_addr;      int sin_size;  int j = 0,ret;  fd_set fd;timeval tv;sock = ::socket(AF_INET,0);  server_addr.sin_family = AF_INET;           server_addr.sin_port = htons(4000);       server_addr.sin_addr.s_addr = INADDR_ANY;   ::bind(sock,sizeof(struct sockaddr));  ::listen(sock,1);  ::fflush(stdout);  u_long nbio = 1;::ioctlsocket(sock,FIONBIO,&nbio);while(1) {       FD_ZERO(&fd);    FD_SET(sock,&fd);    tv.tv_sec = 5;    tv.tv_usec = 0;    if (select(0,&fd,NULL,&tv) > 0)    {        sin_size = sizeof(struct sockaddr_in);         connected = ::accept(sock,&sin_size);         nbio = 1;        ::ioctlsocket(connected,&nbio);        while (1)         {             j++;             if (::send(connected,0) < 0)            {                //dealing with lost communication ?                  //and reastablishing communication                 //set timeout and reset on timeout error                     if (WSAGetLastError() == WSAEWOULDBLOCK)                {                    FD_ZERO(&fd);                    FD_SET(connected,&fd);                    tv.tv_sec = 5;                    tv.tv_usec = 0;                    if (select(0,&tv) > 0)                        continue;                }                break;            }        }         closesocket(connected);    } }

我试图取代这个：

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,respBuffer.Length);
            while (bytesRead > 0)
            {
                memStream.Write(respBuffer,bytesRead);
                bytesRead = responseStream.Read(respBuffer,respBuffer.Length);
            }
        }
        finally
        {
            responseStream.Close();
        }

        byte[] msg = memStream.ToArray();

        context.Response.ContentLength64 = msg.Length;
        using (Stream strOut = context.Response.OutputStream)
        {
            strOut.Write(msg,msg.Length);
        }
    }
    catch (Exception ex)
    {
        // Some error handling
    }
}

带插座.这是我到目前为止

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,bytes);
while (bytes > 0)
{
bytes = socket.Receive(receiveByte,0);
strPage = strPage + ASCII.GetString(receiveByte,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,byteResponse .Length);
context.Response.OutputStream.Close();

结束新的代码

连接到套接字后,我不知道如何获取Stream的解压缩响应,并发回到context.Response.OutputStream

任何帮助将不胜感激.
谢谢.
干杯.

编辑2：
这个编辑现在似乎工作正常(至少与HttpWebRequest相同).你在这里找到任何错误吗？

编辑3：
虚假警报…仍然无法得到这个工作

编辑4：
我需要将以下行添加到Scott的代码中,因为并不总是第一个到响应流的字节是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,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<string,string>();
                    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,respBuffer.Length);
                            while (bytesRead > 0) {
                                memStream.Write(respBuffer,bytesRead);
                                bytesRead = responseStream.Read(respBuffer,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<string> request) {
            foreach (var r in request) {
                var data = DefaultEncoding.GetBytes(r);
                stream.Write(data,data.Length);
                stream.Write(LineTerminator,2);
            }
            stream.Write(LineTerminator,2);
            // Eat response
            var response = ReadLine(stream);
        }

        static string ReadLine(Stream stream) {
            var lineBuffer = new List<byte>();
            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()) {
     }
}