C# HttpClient 有没有可以设置IP和端口的？只能用Socket 么？

Question

我自己用Socket写了一个HttpClient ，感觉性能不太好，在网上找了一些
发现都无法设置IP

下面是我自己实现的HttpClient

using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;

namespace PageCache.Common
{
    public class HttpDataInfo
    {
        public HttpDataInfo()
        {
            headers = new NameValueCollection();
        }

        public int StatusCode { get; set; }
        public string StatusDescription { get; set; }
        public string Scheme { get; set; }


        NameValueCollection headers;
        public NameValueCollection Headers
        {
            get { return headers; }
            set { headers = value; }
        }

        public string HeadersStrings { get; set; }

        public int ContentLength { get; set; }
    }

    public class HttpData : HttpDataInfo
    {
        public byte[] BodyData { get; set; }
    }

    public class HttpClient
    {

        const string Sign_Content_Length = "Content-Length";
        const string Sign_Header_End = "\r\n";

        const string Sign_Chunked_End = "\r\n";
        const string Sign_Chunked = "chunked";

        const int None_Data = -1;
        const int Buffer_Size = 256;

        byte[] ParseChunkedData(List<byte> data)
        {
            int endPosition = data.Count;

            List<byte> list = new List<byte>();

            StringBuilder sb = new StringBuilder();

            for (int i = 0; i < data.Count; i++)
            {
                byte b = data[i];

                char c = (char)b;

                sb.Append(c);

                string line = sb.ToString();

                int inx = line.IndexOf(Sign_Chunked_End);

                if (inx > 0)
                {
                    string hex = line.Substring(0, inx);

                    int count = Convert.ToInt32(hex, 16);

                    if (count > 0)
                    {
                        var range = data.GetRange(i + 1, count);

                        list.AddRange(range);

                        i = i + count + 2;
                    }
                    else if (count == 0)
                    {
                        break;
                    }

                    sb.Clear();
                }
            }

            return list.ToArray();
        }

        bool IsSame(char[] chars, List<byte> bytes)
        {
            if (chars.Length != bytes.Count)
            {
                return false;
            }

            bool same = true;

            for (int i = 0; i < chars.Length; i++)
            {
                same = same && chars[i] == bytes[i];
            }

            return same;

        }

        char[] Sign_End = { '\r', '\n', '\r', '\n' };

        int receiveTimeout = 5000;

        /// <summary>
        /// 接收超时默认2秒
        /// </summary>
        public int ReceiveTimeout
        {
            get { return receiveTimeout; }
            set { receiveTimeout = value; }
        }

        int sendTimeout = 5000;

        /// <summary>
        /// 发送超时默认1秒
        /// </summary>
        public int SendTimeout
        {
            get { return sendTimeout; }
            set { sendTimeout = value; }
        }



        public Log ErrorLog { get; set; }

        List<byte> ReceiveAllData(Socket socket, byte[] headersData)
        {
            int zero_times = 0;
            int zero_max = 3;

            List<byte> list = new List<byte>(1024 * 64);

            int nowContentLength = 0;

            byte[] buffer = new byte[Buffer_Size];

            try
            {
                while (true)
                {
                    int receiveCount = socket.Receive(buffer, Buffer_Size, SocketFlags.None);

                    if (receiveCount > 0)
                    {
                        zero_times = 0;


                        for (int i = 0; i < receiveCount; i++)
                        {
                            list.Add(buffer[i]);
                        }
                        nowContentLength += receiveCount;
                    }

                    if (receiveCount == 0 || receiveCount < Buffer_Size)
                    {
                        zero_times++;
                        if (zero_times >= zero_max)
                        {
                            break;
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                if (ErrorLog != null)
                {
                    ErrorLog.Write(ex.ToString());
                    ErrorLog.Write(Encoding.UTF8.GetString(headersData));
                }
            }

            return list;
        }

        public HttpData GetData(Socket socket, byte[] headersData)
        {
            List<byte> list_data = ReceiveAllData(socket, headersData);

            byte[] header_data = null;
            List<byte> body_data_list = null;

            int sign_len = Sign_End.Length;

            //拆分出 HTTP Header Body
            if (list_data.Count > sign_len)
            {

                for (int i = 0; i <= list_data.Count - sign_len; i++)
                {
                    var range = list_data.GetRange(i, sign_len);

                    if (IsSame(Sign_End, range))
                    {
                        header_data = list_data.GetRange(0, i + sign_len).ToArray();

                        if (header_data.Length < list_data.Count)
                        {
                            body_data_list = list_data.GetRange(i + sign_len, list_data.Count - header_data.Length);
                        }

                        break;
                    }
                }
            }


            if (header_data == null)
            {
                return null;
            }

            string headerString = Encoding.ASCII.GetString(header_data);

            HttpDataInfo info = ParseHeaderString(headerString);

            HttpData data = null;

            if (info != null)
            {
                data = new HttpData
                {

                    HeadersStrings = info.HeadersStrings
                    ,
                    Scheme = info.Scheme
                    ,
                    StatusCode = info.StatusCode
                    ,
                    StatusDescription = info.StatusDescription
                    ,
                    Headers = info.Headers
                };

                data.BodyData = new byte[0];

                if (body_data_list != null)
                {
                    if (info.ContentLength > 0)
                    {
                        if (body_data_list == null)
                        {
                            throw new Exception("ContentLength>0 and ReceiveBodyData is null");
                        }
                        else
                        {
                            data.BodyData = body_data_list.ToArray();
                        }
                    }
                    else if (info.ContentLength == None_Data)
                    {
                        string tran = info.Headers["Transfer-Encoding"] ?? string.Empty;

                        if (tran.Equals(Sign_Chunked, StringComparison.OrdinalIgnoreCase))
                        {

                            if (body_data_list == null)
                            {

                                throw new Exception("Transfer-Encoding is " + Sign_Chunked + " and ReceiveBodyData is null");
                            }
                            else
                            {
                                data.BodyData = ParseChunkedData(body_data_list);
                            }
                        }
                        else
                        {
                            data.BodyData = body_data_list.ToArray();
                        }
                    }
                }

                if (data.BodyData != null)
                {
                    data.ContentLength = data.BodyData.Length;
                }
                else
                {
                    data.ContentLength = 0;
                }
            }

            return data;
        }


        public HttpData GetData(string host, byte[] headersData)
        {
            return GetData(host, 80, headersData);
        }

        public HttpData GetData(string host, string headersString)
        {
            return GetData(host, Encoding.ASCII.GetBytes(headersString));
        }

        public HttpData GetData(string host, int port, string headersString)
        {
            return GetData(host, port, Encoding.ASCII.GetBytes(headersString));
        }

        public HttpData GetData(string host, int port, byte[] headersData)
        {
            HttpData data = null;

            using (Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
            {
                socket.ReceiveTimeout = receiveTimeout;
                socket.SendTimeout = sendTimeout;


                int loopTimes = 0;
                int loopTimesMax = 2;

                loop:

                if (!socket.Connected)
                {
                    socket.Connect(host, port);
                }

                if (!socket.Connected)
                {
                    loopTimes++;

                    if (loopTimes < loopTimesMax)
                    {
                        goto loop;
                    }
                }

                if (socket.Connected)
                {
                    socket.Send(headersData);
                    data = GetData(socket, headersData);
                    socket.Shutdown(SocketShutdown.Both);
                }
            }

            return data;
        }

        public HttpData GetData(IPEndPoint address, string headersString)
        {
            return GetData(address, Encoding.ASCII.GetBytes(headersString));
        }

        public HttpData GetData(IPEndPoint address, byte[] headersData)
        {
            HttpData data = null;

            using (Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
            {
                socket.ReceiveTimeout = receiveTimeout;
                socket.SendTimeout = sendTimeout;
                int loopTimes = 0;
                int loopTimesMax = 2;

                loop:

                if (!socket.Connected)
                {
                    socket.Connect(address);
                }

                if (!socket.Connected)
                {
                    loopTimes++;

                    if (loopTimes < loopTimesMax)
                    {
                        goto loop;
                    }
                }

                if (socket.Connected)
                {
                    socket.Send(headersData);
                    data = GetData(socket, headersData);
                    socket.Shutdown(SocketShutdown.Both);
                }
            }

            return data;
        }

        public static HttpDataInfo ParseHeaderString(string headersStringText)
        {

            string[] headersStrings = headersStringText.Split(new string[] { Sign_Header_End }, StringSplitOptions.None);

            if (headersStrings.Length > 0)
            {
                HttpDataInfo info = new HttpDataInfo();
                info.ContentLength = None_Data;

                info.HeadersStrings = headersStringText;

                string firstLine = headersStrings[0].Trim();

                if (!string.IsNullOrEmpty(firstLine))
                {
                    int inx_space1 = firstLine.IndexOf(' ');

                    int inx_space2 = firstLine.IndexOf(' ', inx_space1 + 1);

                    if (inx_space2 > inx_space1 && inx_space1 > 0)
                    {
                        string codeString = firstLine.Substring(inx_space1 + 1, inx_space2 - inx_space1);

                        int code = 0;

                        if (int.TryParse(codeString, out code))
                        {
                            info.StatusCode = code;
                        }

                        info.Scheme = firstLine.Substring(0, inx_space1);

                        info.StatusDescription = firstLine.Substring(inx_space2 + 1);
                    }
                }

                string headerSplitSign = ": ";

                if (headersStrings.Length > 1)
                {
                    for (int i = 1; i < headersStrings.Length; i++)
                    {
                        string header = headersStrings[i].Trim();

                        int signIndex = header.IndexOf(headerSplitSign);

                        int valueIndex = signIndex + headerSplitSign.Length;

                        if (signIndex > 0 && valueIndex < header.Length)
                        {
                            string key = header.Substring(0, signIndex);

                            string value = header.Substring(valueIndex);

                            if (key.Equals(Sign_Content_Length, StringComparison.OrdinalIgnoreCase))
                            {
                                int contentLength = 0;
                                if (int.TryParse(value, out contentLength))
                                {
                                    info.ContentLength = contentLength;
                                }
                                else
                                {
                                    info.ContentLength = None_Data;
                                }
                            }

                            info.Headers[key] = value;
                        }
                    }
                }

                return info;
            }

            return null;
        }

    }
}

Answer 1

https://msdn.microsoft.com/en-us/library/system.net.http.httpclient(v=vs.118).aspx

看下这个 是你想要的吗