[WCF REST] 解决资源并发修改的一个有效的手段:条件更新(Conditional Update)
条件获取(Conditional Update)可以避免相同数据的重复传输,进而提高性能。条件更新(Conditional Update)用于解决资源并发操作问题。如果我们预先获取一个资源进行修改或者删除,条件更新检验帮助我们确认资源被获取出来到针对它的修改/删除操作被提交的这段时间内是否被其他人改动过。[源代码从这里下载]
一、HTTP对条件更新的支持
HTTP为条件更新提供了相应的报头,我们按照分析条件获取的方式来分析条件更新在HTTP请求/回复过程中的实现。客户端第一次向服务端发起针对某个资源的请求,服务端除了将资源数据作为回复消息主体返回之外,会将与资源关联并且能够可以用于对其进行对等性判断的某个值作为回复的ETag报头,这与条件获取时一致的。
客户端通过回复获得请求的资源和ETag报头值。对于资源修改操作,客户端直接针对获取的资源进行相应的修改,并将修改后的资源以HTTP请求的方式向服务端提交;对于资源删除操作,则可以指定被删除资源的唯一标识直接向服务端发送删除的请求。而之前获取的ETag指将会作为请求消息的If-Match报头。
服务端接收到资源修改/删除请求后先获取到现有的资源的ETag值,并将此值与请求消息的If-Match报头值进行比较。如果两者不一致,则表明试图被修改/删除的资源已经被修改了,在这种情况下会直接回复一个HTTP状态为“412 (Precondition Failed)”的空消息。条件更新同时支持针对PUT、POST和DELETE这三种方法的HTTP请求。
二、WebOperationContext与条件更新
服务端进行条件更新检测,以及客户端对If-Match请求报头的设置都可以通过当前的WebOperationContext来完成。如下面的代码片断所示,表示入栈请求上下文的IncomingWebRequestContext类型具有如下四个CheckConditionalUpdate方法重载用于进行添加更新检测。
1: public class IncomingWebRequestContext
2: {
3: //其他成员
4: public void CheckConditionalUpdate(Guid entityTag);
5: public void CheckConditionalUpdate(int entityTag);
6: public void CheckConditionalUpdate(long entityTag);
7: public void CheckConditionalUpdate(string entityTag);
8: }
实现在CheckConditionalUpdate方法中的条件更新检测具有这样的逻辑:对于HTTP方法为PUT的请求,如果If-Match报头值不为“*”,则直接抛出HTTP状态为PreconditionFailed的WebFaultException异常;对于HTTP方法为POST和DELETE的请求来说,如果If-Match报头值为“*”或者包含指定的entityTag则验证通过,否则同样则直接抛出HTTP状态为PreconditionFailed的WebFaultException异常。
表示出栈请求上下文的OutgoingWebRequestContext类型具有如下一个IfMatch属性,客户端可以通过该属性对请求消息的If-Match报头进行设置。
1: public class OutgoingWebRequestContext
2: {
3: //其他成员
4: public string IfMatch { get; set; }
5: }
三、实例演示:通过条件更新解决对相同资源的并发修改
我们同样通过对EmployeesService进行相应的改造来模拟如何通过添加更新实现对相同资源的并发操作问题,这次我们修改的是用于获取指定ID员工信息的Get操作和用于修改员工信息的Update操作。Get操作在返回与指定员工ID匹配的Employee对象之前我们将该对象的哈希码作为了回复消息的ETag报头(Employee类型重写了GetHashCode方法)。
1: public class EmployeesService : IEmployees
2: {
3: //其他成员
4: public Employee Get(string id)
5: {
6: Employee employee = employees.FirstOrDefault(e => e.Id == id);
7: if (null == employee)
8: {
9: throw new WebFaultException(HttpStatusCode.NotFound);
10: }
11: WebOperationContext.Current.OutgoingResponse.SetETag(employee.GetHashCode());
12: return employee;
13: }
14: public void Update(Employee employee)
15: {
16: var existing = employees.FirstOrDefault(e => e.Id == employee.Id);
17: if (null == existing)
18: {
19: throw new WebFaultException(HttpStatusCode.NotFound);
20: }
21: //模拟并发修改
22: existing.Name += Guid.NewGuid().ToString();
23:
24: WebOperationContext.Current.IncomingRequest.CheckConditionalUpdate(existing.GetHashCode());
25: employees.Remove(existing);
26: employees.Add(employee);
27: WebOperationContext.Current.OutgoingResponse.SetETag(employee.GetHashCode());
28:
29: }
30: }
Update方法中我们通过手工修改相应员工的Name属性的方式来模拟针对相同员工信息的并发修改。在真正实施修改之前调用当前IncomingWebRequestContext的CheckConditionalUpdate方法进行条件更新检测,而作为参数传入的ETag值为代表目前员工的Employee对象的哈希码。方法的最后我们对回复消息的ETag报头作了更新。
我们通过手工创建HTTP请求的方式对上述的两个服务操作进行调用。如下面的代码片断所示,我们首先通过创建的HttpWebRequest对象调用Get操作获得ID为001的员工信息并将其打印出来。然后创建调用Update操作的HttpWebRequest,并对HTTP方法(POST)和内容类型(application/xml)进行了相应的设置。我们之前针对员工获取请求得到ETag报头和员工数据作为本次请求的If-Match报头和主体。如果调用GetResponse方法抛出WebException异常,并且其回复状态为PreconditionFailed,则表明试图修改的员工信息已被另一个用户修改过了,所以我么打印“服务端数据已发生变化”字样。
1: Uri address = new Uri("http://127.0.0.1:3721/employees/001");
2: var request = (HttpWebRequest)HttpWebRequest.Create(address);
3: request.Method = "GET";
4: var response = (HttpWebResponse)request.GetResponse();
5: string employee;
6: using (StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8))
7: {
8: employee = reader.ReadToEnd();
9: Console.WriteLine("获取员工信息:");
10: Console.WriteLine(employee + "n");
11: }
12: try
13: {
14: address = new Uri("http://127.0.0.1:3721/employees/");
15: request = (HttpWebRequest)HttpWebRequest.Create(address);
16: request.Method = "POST";
17: request.ContentType = "application/xml";
18: byte[] buffer = Encoding.UTF8.GetBytes(employee);
19: request.GetRequestStream().Write(Encoding.UTF8.GetBytes(employee), 0, buffer.Length);
20: request.Headers.Add(HttpRequestHeader.IfMatch, response.Headers[HttpResponseHeader.ETag]);
21: Console.WriteLine("修改员工信息:");
22: request.GetResponse();
23: }
24: catch (WebException ex)
25: {
26: response = ex.Response as HttpWebResponse;
27: if (null == response)
28: {
29: throw;
30: }
31: if (response.StatusCode == HttpStatusCode.PreconditionFailed)
32: {
33: Console.WriteLine("服务端数据已发生变化");
34: }
35: else
36: {
37: throw;
38: }
39: }
在服务成功寄宿的情况下调用这段程序会在控制台上输出如下的结果。由于并发错误的发生,员工信息其实并没有被真正修改。
1: 获取员工信息:
2: <Employee xmlns="http://www.artech.com/" xmlns:i="http://www.w3.org/2001/XMLSchema-instance"><Department>开发部</Department><Grade>G7</Grade><Id>001</Id><Name>张三</Name></Employee>
3:
4: 修改员工信息:
5: 服务端数据已发生变化
- Gradle 10分钟上手指南
- gradle项目中profile的实现
- 欧盟推出“数字经济税收制度”优化了税收制度,却影响区块链行业
- CSS魔法堂:你一定误解过的Normal flow
- ASP.NET输出JSON格式数据
- haproxy 新手上路
- 区块链是如何保护交易隐私的?eprint这篇论文告诉你答案
- gradle项目中资源文件的相对路径打包处理技巧
- Markdown 语法手册 (完整整理版)
- WordPress3.5安装出现的几个问题
- java并发编程学习: 原子变量(CAS)
- gradle项目中如何支持java与scala混合使用?
- 开始使用Linux
- .Net魔法堂:开启IIS的WebGarden、WebFarm和StateServer之旅
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 《Offer一箩筐》求职之前你必须知道的 4 件事!!
- 3分钟短文:有趣的Laravel命令行交互,输入和输出!
- MySQL limit导致的执行计划差异
- 3分钟短文:用Laravel的方式管理服务器的文件们
- 漫画:什么是 “抽象工厂模式” ?
- 啥?Grafana 还能为日志添加告警?
- Docker映射详解,没问题了!
- 写了很久!详细理解Spring和IoC
- 一位摸金校尉决定转行前端
- CentOS7下搭建并体验HFish开源蜜罐系统
- 唐朝人更懂React
- 唐朝人更懂React
- 一起学习PHP的runkit扩展如何使用
- CentOS7下部署开源网络流量回溯分析系统Moloch
- spring源码(八)