Asp.Net WebAPI核心对象解析（三）

   对于.NET的分布式应用开发，可以供我们选择的技术和框架比较多，例如webservice，.net remoting，MSMQ，WCF等等技术。对于这些技术很多人都不会陌生，即时没有深入的了解，但是肯定听说过，每种技术都各有优势和适用范围，没有绝对的好坏，只有相对的合适程度。不过可惜了，今天我们讲解的主题不是这几种技术，今天主要讲解的是ASP.NET WebAPI。

   对于ASP.NET WebAPI的优势和特点，在这里就不讲了，需要用到的自然就会选择，也不需要我浪费篇幅去讲解这些，这篇博文主要讲解ASP.NET WebAPI中的HTTP消息的结构和处理消息的核心对象。

一.WebAPI的HTTP概述：

   有关HTTP协议的相关内容在这里就不做介绍，在笔者前面的博文中已经做过介绍，现在提供一下地址，因为过多的赘述就是浪费时间，我就姑且看这篇博文的读者已经对HTTP协议和WebAPI都有所了解。博文地址：

http://www.cnblogs.com/pengze0902/p/5976388.html

http://www.cnblogs.com/pengze0902/p/6224792.html

http://www.cnblogs.com/pengze0902/p/6230105.html

   1.在.NET4.5之前的版本中，处理HTTP的核心对象：

      (1).在客户端：System.Net.HttpWebRequest用于初始化HTTP请求，处理相关的响应； System.Net.HttpWebResponse处理HTTP响应头和数据读取的检索。

      (2).在服务器端：System.Web.HttpContext，System.Web.HttpRequest，System.Web.HttpResponse类用在ASP.NET上下文中，代表单个请求和响应。System.Net.HttpListenerContext类，提供对HTTP请求和响应对象的访问。

   2.在.NET4.5版本中，处理HTTP的核心对象：

      (1).在客户端和服务器端使用同样的类。（HttpRequestMessage和HttpResponseMessage对象中不包含上下文消息，所以可以在服务器和客户端共用。）

      (2).由于在.NET4.5中引入了TAP（异步任务模型），所以在新的HTTP模型中，处理HTTP请求的方法可以使用async和awit实现异步编程。（可以简单高效的实现异步编程）

    我们对于新旧的HTTP编程模型时，会很容易的发现在新版本的HTTP模型中，无论是编程的难度和代码编写的精简度，已经执行的效率都是很高的。在对于Web项目的开发中，我们对HTTP知识的了解是必要的，对于ASP.NET的HTTP处理的原理在这里就不做具体的介绍，网上也有比较多的文章可供阅读和了解。

    对于ASP.NET的HTTP处理方式的了解，是我在开发微信公众平台时进一步学习的，微信公众平台提供了对外访问的接口，我们的程序和服务器对微信服务器的接口进行请求访问，微信服务器获取HTTP请求后，返回处理结果，本地服务器获取返回结果。这样一个请求-响应模式，组成一个会话。对于微信公众平台的开发对于很多刚学习.NET的人来说有些高大（当然这是相对而言），即时开发过很多次这个类别的程序的人（调用第三方接口的开发）也不一定可以很清晰的知道这个其中的原理，笔者觉得对于这样的第三方平台的开发，其主要的核心部分就是对于HTTP协议的处理，建立请求、获取响应消息和解析消息这三大步骤，返回的消息内容一般为json或者xml，获取响应消息后，主要是对消息内容的反序列化，获得消息的实体信息，进而在程序中进一步处理。

    在WeAPI中消息的产生和解析，以及消息的格式都是可以动态的创建和协商，下面我们进一步的了解实现这一过程的核心对象。

二.WebAPI的HTTP消息解析：

      HTTP协议的工作方式是在客户端和服务器之间交换请求和响应消息，那么这也就可以说明HTTP的核心就是消息，对于“消息”的了解，我们只要知道消息分为“消息头部”和“消息内容”，我们接下来的对新HTTP编程模型的介绍的主体就是“消息头部”和“消息内容”。

      在命名空间System.Net.Http中，具有两个核心对象：HttpRequestMessage和HttpResponseMessage。两个对象的结构如下图：

      以上主要讲解了HttpRequestMessage对象和HttpResponseMessage对象包含的主要内容，请求和响应消息都可以包含一个可选的消息正文，两中消息类型以及消息内容，都可以使用响应的标头。接下来具体了解一些消息的结构。

    1.HttpRequestMessage对象解析：

         (1).HttpRequestMessage主要属性和方法概述：

名称	说明
Version	获取或设置 HTTP 消息版本
Content	获取或设置 HTTP 消息的内容
Method	获取或设置 HTTP 请求信息使用的 HTTP 方法
RequestUri	获取或设置 HTTP 请求的 Uri
Headers	获取 HTTP 请求标头的集合
Properties	获取 HTTP 请求的属性集
ToString	返回表示当前对象的字符串

        该对象主要用于表示 HTTP 请求消息。对于该对象的这些属性和方法，大部分应该都不会陌生，因为一个HTTP消息中主要包含头部、消息内容等等，在这里主要介绍一个属性Properties，该属性并不属于任何标准的HTTP消息，当消息传输时，不会保留该属性。

         (2).Properties属性解析：

[__DynamicallyInvokable]
public IDictionary<string, object> Properties
{
    [__DynamicallyInvokable]
    get
    {
        if (this.properties == null)
        {
            this.properties = new Dictionary<string, object>();
        }
        return this.properties;
    }
}

    有以上的代码可以很明显的看出该属性只有一个只读属性，并返回一个IDictionary<string, object>。当消息在服务器或者客户端本地进行处理时，该属性用于保存附加的消息信息。该属性只是一个通用的容器，保存本地消息属性。（与接受消息的连接相关的客户端认证；将消息与配置路由进行匹配，得到的路由数据）

   2.HttpResponseMessage对象解析：

        (1).HttpRequestMessage主要属性和方法概述：

名称	说明
EnsureSuccessStatusCode	如果 HTTP 响应的 IsSuccessStatusCode 属性为  false， 将引发异常
StatusCode	获取或设置 HTTP 响应的状态代码
ReasonPhrase	获取或设置服务器与状态代码通常一起发送的原因短语
RequestMessage	获取或设置导致此响应消息的请求消息
IsSuccessStatusCode	获取一个值，该值指示 HTTP 响应是否成功

      对于该对象的一些属性没有列举，因为在HttpRequestMessage对象已经介绍，如：Version、Content、Headers等，该对象主要用于表示 HTTP 响应消息。在这里主要介绍StatusCode属性。

       (2).StatusCode属性：

[__DynamicallyInvokable]
public HttpStatusCode StatusCode
{
    [__DynamicallyInvokable, TargetedPatchingOptOut("Performance critical to inline this type of method across NGen image boundaries")]
    get
    {
        return this.statusCode;
    }
    [__DynamicallyInvokable]
    set
    {
        if ((value < ((HttpStatusCode) 0)) || (value > ((HttpStatusCode) 0x3e7)))
        {
            throw new ArgumentOutOfRangeException("value");
        }
        this.CheckDisposed();
        this.statusCode = value;
    }
}

     StatusCode属性为枚举属性，该属性可读可写，对于状态码这个概念，很多人都是比较了解的，在HTTP协议中，状态码主要是表示在消息的请求在服务器中处理的结果，状态有2XX，3XX，4XX，5XX等等，具体表示的意义就不再描述。

     3.HTTP模型消息标头解析：

          在HTTP中，请求和响应消息，以及消息内容自身，都可以使用称为标头的额外字段，包含更多的信息。

       (1).标头分类：

标头名称	描述	HTTP模型标头容器类
User-Agent	为请求提供扩展信息，描述产生这个请求的应用程序	HttpRequestHeaders
Server	为响应提供关于源服务器软件的扩展信息	HttpResponseHeaders
Content-Type	定义请求或响应有效载荷正文中，资源表示使用的媒体类型	HttpContentHeaders

       (2).HttpHeaders抽象类分析：

名称	描述
Add	添加指定的标头及其值到 HttpHeaders 集合中。
TryAddWithoutValidation	返回一个值，该值指示指定标头及其值是否已添加到HttpHeaders 集合，而未验证所提供的信息。
Clear	从 HttpHeaders 集合中移除所有标头。
Remove	从HttpHeaders集合中移除指定的标头。
GetValues	返回存储在HttpHeaders 集合中所有指定标头的标头值。
Contains	如果指定标头存在于 HttpHeaders 集合则返回。
ToString	返回表示当前 HttpHeaders对象的字符串。

       HttpHeaders是一个抽象类，HttpRequestHeaders、HttpResponseHeaders、HttpContentHeaders三个类继承了该类。接下来我们来了解一下Add()方法：

[__DynamicallyInvokable]
public void Add(string name, string value)
{
    HeaderStoreItemInfo info;
    bool flag;
    this.CheckHeaderName(name);
    this.PrepareHeaderInfoForAdd(name, out info, out flag);
    this.ParseAndAddValue(name, info, value);
    if (flag && (info.ParsedValue != null))
    {
        this.AddHeaderToStore(name, info);
    }
}

       Add()方法具有两个重载版本，该方法可以向容器添加标头，如果要添加的标头有标准名，在添加之前标头值会进行验证。Add方法还会验证标头是否可以有多个值。

   4.HTTP消息内容解析：

      在.NET4.5版本的HTTP模型中，HTTP消息的正文由抽象基类HttpContent表示，HttpResponseMessage和HttpRequestMessage对象都包含一个HttpContent类型的Content属性。

     (1).HttpContent主要属性和方法：

名称	描述
ReadAsByteArrayAsync	以异步操作将 HTTP 内容写入字节数组。
SerializeToStreamAsync	以异步操作将 HTTP 内容序列化到流。
CopyToAsync	以异步操作将 HTTP 内容写入流。
LoadIntoBufferAsync	以异步操作将 HTTP 内容序列化到内存缓冲区。
CreateContentReadStreamAsync	以异步操作将 HTTP 内容写入内存流。
TryComputeLength	确定 HTTP 内容是否具备有效的字节长度。
Headers	根据 RFC 2616 中的定义，获取内容标头。

     (2).CopyToAsync()方法解析：

[__DynamicallyInvokable]
public Task CopyToAsync(Stream stream, TransportContext context)
{
    Action<Task> continuation = null;
    this.CheckDisposed();
    if (stream == null)
    {
        throw new ArgumentNullException("stream");
    }
    TaskCompletionSource<object> tcs = new TaskCompletionSource<object>();
    try
    {
        Task task = null;
        if (this.IsBuffered)
        {
            task = Task.Factory.FromAsync<byte[], int, int>(new Func<byte[], int, int, 
            AsyncCallback, object, IAsyncResult>(stream.BeginWrite), new Action<IAsyncResult>(stream.EndWrite), 
　　　　　　　this.bufferedContent.GetBuffer(), 0, (int) this.bufferedContent.Length, null);
        }
        else
        {
            task = this.SerializeToStreamAsync(stream, context);
            this.CheckTaskNotNull(task);
        }
        if (continuation == null)
        {
            continuation = delegate (Task copyTask) {
                if (copyTask.IsFaulted)
                {
                    tcs.TrySetException(GetStreamCopyException(copyTask.Exception.GetBaseException()));
                }
                else if (copyTask.IsCanceled)
                {
                    tcs.TrySetCanceled();
                }
                else
                {
                    tcs.TrySetResult(null);
                }
            };
        }
        task.ContinueWithStandard(continuation);
    }
    catch (IOException exception)
    {
        tcs.TrySetException(GetStreamCopyException(exception));
    }
    catch (ObjectDisposedException exception2)
    {
        tcs.TrySetException(GetStreamCopyException(exception2));
    }
    return tcs.Task;
}

    在使用消息内容时，需要使用HtppContent的方法或者扩展方法。在HttpContent中利用CopyToAsync()方法以推送方式访问原始的消息内容，由方法代码可以看出，该方法接受两个参数，一个是流对象，一个是有关传输的信息（例如，通道绑定），此参数可以为 null。该方法可以把消息内容写入到这个流中。

    在该方法的实现代码中 创建了一个TaskCompletionSource<object>的泛型对象，该对象表示未绑定到委托的 Task<TResult> 的制造者方，并通过 Task 属性提供对使用者方的访问。SerializeToStreamAsync方法将传入的流对象序列化，该方法为异步方法。

    我们需要注意的几点，主要为委托的创建和使用，在C#中，尽量使用有.NET提供的委托类，不要自己去创建。还有一点就是在程序中对异常的处理方式，异常的捕获具有层次性，并且调用了自定义的一个异常处理方法TrySetException。

    (2).ReadAsStreamAsync()方法解析：

      在获取原始消息内容时，除了调用上面介绍的方法外，还可以调用ReadAsStreamAsync()方法以拉取的方式访问原始的消息内容。

      在HttpContent中包含有另外两个类似的方法，ReadAsStringAsync()和ReadAsByteArrayAsync()异步的提供消息内容的缓冲副本，ReadAsByteArrayAsync()返回原始的字节内容，ReadAsStringAsync()将内容解码为字符串返回。

三.DotNet中新旧HTTP模型分析：

   1..NET4.5之前版本创建HTTP POST请求实例：

        public static string HttpPost(string postUrl, string postData)
        {
            if (string.IsNullOrEmpty(postUrl))
                throw new ArgumentNullException(postUrl);
            if (string.IsNullOrEmpty(postData))
                throw new ArgumentNullException(postData);
            var request = WebRequest.Create(postUrl) as HttpWebRequest;
            if (request == null)
                throw new ArgumentNullException("postUrl");
            try
            {
                var cookieContainer = new CookieContainer();
                request.CookieContainer = cookieContainer;
                request.AllowAutoRedirect = true;
                request.Method = "POST";
                request.ContentType = "application/x-www-form-urlencoded";
                var data = Encoding.UTF8.GetBytes(postData);
                request.ContentLength = data.Length;
                var outstream = request.GetRequestStream();
                outstream.Write(data, 0, data.Length);
                outstream.Close();
                //发送请求并获取相应回应数据，获取对应HTTP请求的响应
                var response = request.GetResponse() as HttpWebResponse;
                if (response != null)
                {
                    var instream = response.GetResponseStream();
                    var content = string.Empty;
                    if (instream == null)
                    {
                        return content;
                    }
                    using (var sr = new StreamReader(instream, Encoding.UTF8))
                    {
                        content = sr.ReadToEnd();
                    }
                    return content;
                }
            }
            catch (ArgumentException arex)
            {
                throw arex;
            }
            catch (IOException ioex)
            {
                throw ioex;
            }
            return null;
        }

   2..NET4.5版本创建HTTP POST请求实例：

async static void getResponse(string url)
        {
            using (HttpClient client = new HttpClient())
            {
                using (HttpResponseMessage response = await client.GetAsync(url))
                {
                    using (HttpContent content = response.Content)
                    {
                        string myContent = await content.ReadAsStringAsync();
                    }
                }
            }
        }
        async static void postResponse(string url)
        {
            while (true)
            {
                IEnumerable<KeyValuePair<string, string>> queries = new List<KeyValuePair<string, string>>()
            {
                new KeyValuePair<string, string> ("test","test")
            };
                HttpContent q = new FormUrlEncodedContent(queries);
                using (HttpClient client = new HttpClient())
                {
                    using (HttpResponseMessage response = await client.PostAsync(url, q))
                    {
                        using (HttpContent content = response.Content)
                        {
                            string myContent = await content.ReadAsStringAsync();

                            Console.WriteLine(myContent);
                        }
                    }
                }
            }
        }

四.总结：

   以上主要讲解了.NET4.5之前和之后版本对HTTP编程模式的一些内容， 两者的主要区别在于.NET4.5版本之前的HTTP编程模型会区分客户端和服务器，两者使用的对象存在不同，实现的原理上虽然存在一定的相似性，但是使用的类却不同。.NET4.5之后的版本中，对象的使用没有客户端和服务器之分，两者可以共用。