[WCF REST] 提高性能的一个有效的手段:条件资源获取(Conditional Retrieval)

条件获取(Conditional Retrieval)旨在解决这样的问题:客户端获取某个资源并对其进行缓存,当再次获取相同资源时,如果资源数据与之前获取的一致,则不再返回真正的资源数据,而是在回复中设置一个“标识”表明获取的资源并未发生改变。[源代码从这里下载]

一、 HTTP对条件获取的支持

HTTP对条件获取提供了原生的支持。具体的实现是这样的:服务端接收到客户端针对某个资源的第一次获取请求时,除了将资源数据作为HTTP回复主体返回之外,还会设置一个叫做ETag的回复报头。这个ETag与资源本身关联并且可以对资源进行对等性判断,比如我们可以将资源内容的哈希码作为这个ETag报头。

客户端接收到资源后对其进行缓存,并从回复中获取到这个ETag报头值。当再次对相同的资源进行请求时,它会为HTTP请求添加一个名为If-None-Match报头,而该报头的值就是这个缓存的ETag值。服务端接收到该请求之后会通过If-None-Match请求报头确认最新的资源数据是否与该报头值代表的数据一致,如果一致则回复一个状态为“304 (Not Modified)”的空消息,否则将新的资源置于回复消息的主体并附上基于新资源数据的ETag报头。

除此之外,条件获取还支持另一种基于“最近修改时间”的资源改变判断机制。这种机制也很简单:服务端记录下资源最近一次修改的时间,并被作为客户端第一次访问请求的ETag回复报头。客户端针对相同资源的后续请求会将此ETag表示的时间作为一个名为If-Modified-Since的报头,而服务端则将该报头的时间和资源最近一次修改的时间进行比较从而确定请求的资源是否被改变。如果资源尚未改变则同样回复以状态为“304 (Not Modified)”的空消息,否则将新的资源置于回复消息的主体并附上新的ETag报头。条件获取仅仅针对方法类型为GET和HEAD的HTTP请求。

二、 WebOperationContext与条件获取

对于Web HTTP编程模型来说,通过当前WebOperationContext可以很容易地进行条件获取的检测和相相关HTTP报头的设置和获取。具体来说,服务端通过表示入栈请求上下文的IncomingWebRequestContext对象的CheckConditionalRetrieve方法进行条件获取的检测。其中参数类型为DateTime的重载用采用“最近修改时间”的资源改变判断机制。如果确资源尚未改变,则直接抛出一个HTTP状态为NotModified的WebFaultException,并将lastModified参数表示的时间作为回复消息的ETag报头。

对于其他的4个CheckConditionalRetrieve方法,作为参数的entityTag(ETag)将与请求消息的If-None-Match进行比较,如果不一致也会抛出HTTP状态为NotModified的WebFaultException,并将该参数值作为回复消息的ETag报头。

   1: public class IncomingWebRequestContext
   2: {    
   3:     //其他成员
   4:     public void CheckConditionalRetrieve(DateTime lastModified);
   5:  
   6:     public void CheckConditionalRetrieve(Guid entityTag);
   7:     public void CheckConditionalRetrieve(int entityTag);
   8:     public void CheckConditionalRetrieve(long entityTag);
   9:     public void CheckConditionalRetrieve(string entityTag);
  10:  
  11:     public DateTime? IfModifiedSince { get; }
  12:     public IEnumerable<string> IfNoneMatch { get; }
  13: }

IncomingWebRequestContext还具有IfModifiedSince和IfNoneMatch这两个只读属性,它们分别返回请求消息的If-Modified-Since和If-None-Match报头。而服务端针对回复消息的ETag报头的设置可以通过OutgoingWebResponseContext的四个SetETag方法来完成。

   1: public class OutgoingWebResponseContext
   2: {
   3:     //其他成员
   4:     public void SetETag(Guid entityTag);
   5:     public void SetETag(int entityTag);
   6:     public void SetETag(long entityTag);
   7:     public void SetETag(string entityTag);
   8: }

对于客户端来说,它可以通过当前WebOperationContext的IncomingResponse属性得到表示入栈回复上下文的IncomingWebResponseContext对象,并通过其只读属性ETag获取当前HTTP回复的ETag报头。

   1: public class IncomingWebResponseContext
   2: {
   3:     //其他成员
   4:     public string ETag { get; }
   5: }

如果客户端需要为请求设置If-Modified-Since和If-None-Match报头,则可以通过当前WebOperationContext的OutgoingRequest属性得到表示出栈请求上下文的OutgoingWebRequestContext对象,然后分别设置IfModifiedSince和IfNoneMatch属性即可。

   1: public class OutgoingWebRequestContext
   2: {
   3:     //其他成员
   4:     public string IfModifiedSince { get; set; }
   5:     public string IfNoneMatch { get; set; }
   6: }

需要注意的是,如果采用WCF客户端进行服务调用,一旦接收到状态为“304(Not Modified)”的回复会抛出如下图所示的ProtocolException异常,并提示“远程服务器返回了意外响应: (304) Not Modified”。

三、实例演示:创建基于条件获取的REST服务

接下来我们按照条件获取的方式来改造之前演示的用于管理员工信息的EmployeesService。假设我们的员工数量比较多,用于获取所有员工列表的GetAll操作将会返回一个庞大的数据。如果客户端对第一次获取到的员工列表进行缓存,那么对有后续针对GetAll操作的请求,在员工信息没有任何改变的情况下服务端只需要回复一个状态为304(Not Modified)的HTTP消息即可。

为此我们对EmployeesService的GetAll操作方法进行了如下的改造:我们通过当前WebOperationContext得到表示入栈请求上下文的IncomingWebRequestContext对象,并调用其CheckConditionalRetrieve进行条件获取检验,而传入的参数是最新员工列表对象的哈希码。在返回员工列表之前我们将此哈希码作为了回复消息的ETag报头。

   1: public class EmployeesService : IEmployees
   2: {
   3:     //其他成员
   4:     private static IList<Employee> employees = new List<Employee>
   5:     {
   6:         new Employee{ Id = "001", Name="张三", Department="开发部", Grade = "G7"},    
   7:         new Employee{ Id = "002", Name="李四", Department="人事部", Grade = "G6"}
   8:     };
   9:     public IEnumerable<Employee> GetAll()
  10:     {
  11:         int hashCode = employees.GetHashCode();
  12:         WebOperationContext.Current.IncomingRequest.CheckConditionalRetrieve(hashCode);
  13:         WebOperationContext.Current.OutgoingResponse.SetETag(hashCode);
  14:         return employees;
  15:     }
  16: }

我们通过手工发送HTTP请求的方式来调用EmployeesService的GetAll操作,为此我们创建了如下一个GetAllEmployees方法。该方法的参数ifNoneMatch和eTag分别表示请求消息的If-None-Match报头和回复消息的ETag报头。我们通过调用HttpWebRequest的静态方法Create基于服务操作地址创建一个HttpWebRequest对象,并设置该请求的If-None-Match报头的HTTP方法(GET)。

我们通过调用HttpWebRequest对象的GetResponse发送请求并得到回复,在打印回复内容之前我们获取了回复的ETag报头。在回复状态为“304 (Not Modified)”的情况下,GetResponse方法会 抛出一个WebException异常,所以我们对该类型的异常进行的捕获。如果WebException异常的StatusCode属性返回的HTTP状态是我们预知的NotModified,则意味着获取的员工列表未曾改变,于是我们在控制台上打印“服务端数据未发生变化”字样。

   1: static void GetAllEmployees(string ifNoneMatch, out string eTag)
   2: {
   3:     eTag = ifNoneMatch;
   4:     Uri address = new Uri("http://127.0.0.1:3721/employees/all");
   5:     var request = (HttpWebRequest)HttpWebRequest.Create(address);
   6:     if (!string.IsNullOrEmpty(ifNoneMatch))
   7:     {
   8:         request.Headers.Add(HttpRequestHeader.IfNoneMatch, ifNoneMatch);
   9:     }
  10:     request.Method = "GET";
  11:     try
  12:     {
  13:         var response = (HttpWebResponse)request.GetResponse();
  14:         eTag = response.Headers[HttpResponseHeader.ETag];
  15:         using(StreamReader reader = 
  16:             new StreamReader(response.GetResponseStream(), Encoding.UTF8))
  17:         {
  18:             Console.WriteLine(reader.ReadToEnd() + Environment.NewLine);
  19:         }
  20:     }
  21:     catch (WebException ex)
  22:     {
  23:         HttpWebResponse response = ex.Response as HttpWebResponse;
  24:         if (null == response)
  25:         {
  26:             throw;
  27:         }
  28:         if (response.StatusCode == HttpStatusCode.NotModified)
  29:         {
  30:             Console.WriteLine("服务端数据未发生变化");
  31:             return;
  32:         }
  33:         throw;
  34:     }
  35: }

然后我们通过如下的代码调用上面定义的GetAllEmployees方法进行两次服务调用,并将第一次调用返回的ETag报头作为第二次调用的If-None-Match报头。

   1: string etag;
   2: Console.WriteLine("第1次服务调用:");
   3: GetAllEmployees("", out etag);
   4: Console.WriteLine("第2次服务调用:");
   5: GetAllEmployees(etag, out etag);
   6: Console.Read();

在服务成功寄宿的情况下调用这段程序会在控制台上输出如下的结果,从中我们可以看到员工列表数据只在第1次服务调用中返回。

   1: 第1次服务调用:
   2: <ArrayOfEmployee xmlns="http://www.artech.com/" xmlns:i="http://www.w3.org/2001/XMLSchema-instance"><Employee><Department>开发部</Department><Grade>G7</Grade><Id>001</Id><Name>张三</Name></Employee><Employee><Department>人事部</Department><Grade>G6</Grade><Id>002</Id><Name>李四</Name></Employee></ArrayOfEmployee>
   3:  
   4: 第2次服务调用:
   5: 服务端数据未发生变化

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏GuZhenYin

C#开发移动应用系列(2.使用WebView搭建WebApp应用)

前言 上篇文章地址:C#开发移动应用系列(1.环境搭建) 嗯..一周了 本来打算2天一更的 - - ,结果 出差了..请各位原谅.. 今天我们来讲一下使用Web...

23510
来自专栏分布式系统和大数据处理

HttpHandler介绍

在 Http请求处理流程 一文中,我们了解了Http请求的处理过程以及其它一些运作原理。我们知道Http管道中有两个可用接口,一个是IHttpHandler,一...

1242
来自专栏祝威廉

Kafka Zero-Copy 使用分析

Kafka 我个人感觉是性能优化的典范。而且使用Scala开发,代码写的也很漂亮的。重点我觉得有四个

1712
来自专栏熊二哥

快速入门系列--MVC--05行为

    Action执行包含内容比较多,主要有同步/异步Action的概念和执行过程,Authorationfilter, ActionFiltor, Resu...

1977
来自专栏重庆的技术分享区

基于python3连接mysql,实现一个银行转账的小功能(shell中执行)

1903
来自专栏Kirito的技术分享

深入理解RPC之传输篇

RPC 被称为“远程过程调用”,表明了一个方法调用会跨越网络,跨越进程,所以传输层是不可或缺的。一说到网络传输,一堆名词就蹦了出来:TCP、UDP、HTTP,同...

1.1K7
来自专栏IT开发技术与工作效率

VBA按行读取csv文件与分割合并

2053
来自专栏架构之路

HTTP在要传输的内容大小未知时应该怎样

      一般情况HTTP的Header包含Content-Length域来指明报文体的长度。如: ?      有时候服务生成HTTP回应是无法确定消息大小...

3383
来自专栏前端黑板报

HTTP2基础教程-读书笔记(四)

? 记录一下HTTP/2的底层原理,帮助理解协议实现细节。 连接 每个端点都需要发送一个连接作为最终确认使用的协议,并建立http/2连接的初始设置。客户端和...

3506
来自专栏恰同学骚年

自己动手写工具:百度图片批量下载器

开篇:在某些场景下,我们想要对百度图片搜出来的东东进行保存,但是一个一个得下载保存不仅耗时而且费劲,有木有一种方法能够简化我们的工作量呢,让我们在离线模式下也能...

3641

扫码关注云+社区

领取腾讯云代金券