时间:2021-07-01 10:21:17 帮助过:4人阅读
通过之前的介绍,我们知道要执行页面对象的方法,核心就是反射,是从请求获取参数并执行指定方法的过程。实际上这和asp.net mvc框架的核心思想很类似,它会解析url,从中获取controller和action名称,然后激活controller对象,从请求获取action参数并执action。在web form平台上,我们把方法写在.aspx.cs中,要实现的就是在页面对象还未生成的情况下,执行指定的方法,然后返回结果。
我们先看实现后几个调用例子,这些功能也可以组合使用:
输出结果缓存20秒"; } [AjaxMethod(ServerCache = 20)] public string Test4() { return "在服务端缓存20秒"; } [AjaxMethod(SessionState=SessionState.None)] public void Test5() { //Session未被加载 } [AjaxMethod(SessionState = SessionState.ReadOnly)] public void Test6() { //Session只能读不能写 } [AjaxMethod(SessionState = SessionState.ReadWrite)] public void Test7() { //Session可以读写 } [AjaxMethod(IsAsync = true)] public void Test8() { //异步调用 }前面我们已经熟悉基本的执行流程,现在直接进入主题。
Ajax约定
通常现在主流浏览器在使用ajax发送异步请求时,请求头都会带上一个:X-Requested-With:XMLHttpRequest 的标记。我们也可以直接通过这个标记来判断是不是ajax请求,不过项目中可能有用其它的组件,为了不相互影响,我们加入一个自定义的请求头。这里为:
意思是如果http 的请求头包含一个 AjaxFlag : XHR,就是我们要处理的。另外http header的MethodName就表示我们要执行的方法的名称。
AjaxMethodAttribute标记属性
标记属性是给反射用的,在这里定义我们需要的一些功能。我们希望有:
1. 可以配置Session状态
2. 支持异步Handler
3. 支持Get缓存
4. 支持服务端缓存
定义如下,用AttributeUsag标记该标记只能用于方法上。
各种处理程序和AjaxHandlerFactory
按照上一篇的说法,具体的Handler主要分为两类,异步和非异步;这两类下,对于Session的状态又有3三种,不支持、只支持读(实现IReadOnlySessionState接口)、支持读写(实现IRequiresSessionState接口)。IReadOnlySessionState和IRequiresSessionState都只是标记接口(无任何方法,其实应该用标记属性实现比较合理)。异步的Handler需要实现IHttpAsyncHandler接口,该接口又实现了IHttpHandler。Handler的ProcessRequest方法(或BeginProcessRequest)就是我们要执行方法的地方。定义如下:
非异步状态的Handler:
异步状态的Handler:
AjaxHandlerFactory实现了IHandlerFactory接口,用来根据请求生成具体的Handler,它需要在web.config进行注册使用。AjaxHandlerFactory的GetHandler是我们拦截请求的第一步。通过请求头的AjaxFlag:XHR来判断是否需要我们处理,如果是,则创建一个Handler,否则按照普通的方式进行。由于我们的方法是写在.aspx.cs内的,我们的请求是.aspx后缀的,也就是页面(Page,实现了IHttpHandler)类型,Page是通过PageHandlerFactory创建的,PageHandlerFactory也实现了IHandlerFactory接口,表示它是用来创建处理程序的。所以我们需要用PageHandlerFactory来创建一个IHttpHandler,不过PageHandlerFactory的构造函数是protected internal类型的,我们无法直接new一个,所以需要通过一个CommonPageHandlerFactory继承它来实现。
通过PageHandlerFactory获得Page后,结合方法名称,我们就可以反射获取AjaxMethodAttribute标记属性了。然后根据它的相关属性生成具体的Handler。具体代码如下:
上面的CacheMethodInfo是用于缓存调用方法的相关信息的,第一篇我们有提到过优化缓存的一些方法,其中就包括缓存+委托。但这里我们并不直接缓存方法的MethodInfo,因为缓存MethodInfo的话,需要通过Invoke去执行,这样的效率比较低。这里我缓存的是方法的委托,该委托的签名为:Func<object, object[], object>,该委托的返回值为object类型,表示可以返回任意的类型(我们可以在组件内部进行处理,例如如果是引用类型(非string),就将其序列化为json,但这里并没有实现)。该委托接收两个参数,第一个参数是方法所属的对象,如果是静态方法就是null;第二个参数是方法的参数,定义为object[]表示可以接收任意类型的参数。通过委托执行方法,与直接调用方法的效率差别就不是很大(对委托不熟悉的朋友可以参见:委托)。CacheMethodInfo的定义如下:
核心方法
1. Eexcutor.GetDelegateInfo 获取方法相关信息
该方法用于遍历页面类,获取所有AjaxMethodAttribute标记的方法信息,生成一个CacheMethodInfo对象,包括标记信息、方法名称、参数信息,以及最重要的方法委托。该对象会缓存在一个哈希表中,下次获取时,直接从内存获得。
获取方法的委托的是通过一个ReflectionUtil获得的,该类主要用来优化反射,它通过Expression,可以将MethodInfo编译成Func<object,object[],object>委托,为Type编译一个Func<object>委托,用于创建实例对象。
通过Expression优化反射
Expression(表达式树)允许我们将代码逻辑以表达式的形式存储在树状结构里,然后在运行时去动态解析,实现动态编辑和执行代码。熟悉ORM框架的朋友对Expression肯定很熟悉,因为大部分方法都有一个Expression<TDelegate>类型的参数。访问关系型数据库的本质还是sql语句,orm的工作就是为开发人员屏蔽这个过程,以面向对象的方式去读写数据库,而不是自己编写sql语句。例如,Users.Where(u => u.Age > 18) 就可查询年龄大于18的用户。这里不对应用在orm的过程进行详解,下面我们介绍如何用Expression并利用它来生成委托。
.net定义了许多表达式类型,这些类型都派生自Expression,Expression是一个抽象类,而且是一个工厂类,所有类型的表达式都通过它来创建。如图:
先看一个 1 * 2 + 2 例子,我们用表达树来描述来描述它:
可以看到我们最终将其编译为一个具体类型的委托了。下面看我们真正用到的方法是如何实现的,代码如下:
具体代码都有注释解释,最终我们获得了一个Func<object,object[],object>类型的委托,它会作为CacheMethodInfo的属性进行缓存。有兴趣测试反射性能的朋友,也不妨去测试对比一下这几种方式执行的效率差别:1.直接执行方法 2.Emit 3. 缓存+委托 4.Delegate.DynamicInvoke。
2. Executor.Execute 执行委托
在执行委托前,我们需要先从请求获取参数,映射到方法。参数可以是简单的类型,如 string Test(int i,int j); 也可以是一个对象,如 string Test(User user); 如果是 string Test(User user1, User user2) 也行,提交参数时只需要加上 user1或 user2 前缀即可,例如 user1.Name,user2.Name。这里没有支持更多的匹配方式,像mvc,它还支持嵌套类型等等,这些可以自己去实现。如果参数是一个对象,我们可能需要为它的字段进行赋值,也可能为它的属性进行赋值。这里我们定义一个DataMember,用来表示字段或属性的父类。如:
接着定义属性类型PropertyMember和字段类型FieldMember,分别继承了DataMember。
PropertyMember定义:
FieldMember定义:
定义一个DataMemberManager,用来遍历Type,获取所有字段和属性的,实现如下:
在前面我们定义的Handler的ProcessRequest方法中,我们调用了Executor.Execute,该方法用于执行委托,实现如下:
CacheMethodInfo我们已经获得了,现在只要获得参数我们就可以执行方法。
GetParameterFromRequest用于从请求获取object[]参数数组。根据上面所说的,如果参数是一个简单类型,那么直接进行转换;如果是实例对象,那么我们先要创建new一个实例对象,然后为其字段或属性赋值。实现如下:
/// <summary> /// 从请求获取参参数 /// </summary> /// <param name="request">HttpRequest</param> ///<param name="parameters">参数信息</param> /// <returns>参数数组</returns> private static object[] GetParametersFromRequest(HttpRequest request, ParameterInfo[] parameters) { if (parameters.IsNullOrEmpty()) { return null; } int length = parameters.Length; object[] realParameters = new object[length]; for (int i = 0; i < length; i++) { ParameterInfo pi = parameters[i]; Type piType = pi.ParameterType.GetRealType(); object value = null; if (piType.IsValueType()) { //值类型 value = ModelUtil.GetValue(request, pi.Name, piType); value = value ?? Activator.CreateInstance(piType); } else if (piType.IsClass) { //引用类型 object model = ModelUtil.CreateModel(piType); ModelUtil.FillModelByRequest(request, pi.Name, piType, model); value = model; } else { throw new NotSupportedException(pi.Name + " 参数不被支持"); } realParameters[i] = value; } return realParameters; }
ModelUtil会从Http Request获取参数,并进行类型转换处理:
internal static class ModelUtil { /// <summary> /// 缓存构造函数 /// </summary> private static Hashtable constructorTable = Hashtable.Synchronized(new Hashtable()); /// <summary> /// 根据名称从HttpRequest获取值 /// </summary> /// <param name="request">HttpRequest</param> /// <param name="name">键名称</param> /// <param name="type">参数类型</param> /// <returns></returns> public static object GetValue(HttpRequest request, string name, Type type) { string[] values = null; if (string.Compare(request.RequestType, "POST", true) == 0) { values = request.Form.GetValues(name); } else { values = request.QueryString.GetValues(name); } if (values.IsNullOrEmpty()) { return null; } string data = values.Length == 1 ? values[0] : string.Join(",", values); return Convert.ChangeType(data, type); } /// <summary> /// 创建实例对象 /// </summary> /// <param name="type">实例类型</param> /// <returns></returns> public static object CreateModel(Type type) { if (type == null) { throw new ArgumentNullException("type"); } Func<object> func = constructorTable[type.AssemblyQualifiedName] as Func<object>; if (func == null) { func = ReflectionUtil.GetConstructorDelegate(type); constructorTable[type.AssemblyQualifiedName] = func; } if (func != null) { return func(); } return null; } /// <summary> /// 填充模型 /// </summary> /// <param name="request">HttpRequest</param> /// <param name="name">键名称</param> /// <param name="prefix">参数类型</param> /// <parparam name="model">实例对象</parparam> public static void FillModelByRequest(HttpRequest request, string name, Type type, object model) { if (model == null) { return; } IEnumerable<DataMember> members = DataMemberManager.GetDataMember(type); if (members.IsNullOrEmpty()) { return; } object value = null; foreach (DataMember member in members) { value = GetValue(request, string.Format("{0}.{1}", name, member.Name), member.MemberType); value = value ?? GetValue(request, member.Name, member.MemberType); member.SetValue(model, value); } } }
如果是引用类型,需要通过构造函数创建对象,像前面用于,这里我们也用Expression来构建一个Func<object>类型的委托来优化,它调用了ReflectionUtil.GetConstructorDelegate方法。实现如下:
/// <summary> /// 获取构造函数委托 /// </summary> /// <param name="type">实例类型</param> /// <returns></returns> public static Func<object> GetConstructorDelegate(Type type) { if (type == null) { throw new ArgumentNullException("type"); } ConstructorInfo ci = type.GetConstructor(Type.EmptyTypes); if (ci == null) { throw new MissingMemberException("类型必须有一个无参public构造函数!"); } NewExpression newExp = Expression.New(type); Expression<Func<object>> lambda = Expression.Lambda<Func<object>>(newExp); return lambda.Compile(); }
最后再输出结果时,如果是Get请求,并且需要缓存,我们还需要设置一下Response.Cache。如下:
private static void EndRequest(HttpContext context, object data, int outPutCache, ContentType contentType) { HttpResponse response = context.Response; if (outPutCache != 0) { if (string.Compare(context.Request.HttpMethod, "GET", true) == 0) { if (outPutCache > 0) { response.Cache.SetCacheability(HttpCacheability.Public); response.Cache.SetMaxAge(new TimeSpan(0, 0, outPutCache)); response.Cache.SetExpires(DateTime.Now.AddSeconds(outPutCache)); } else { response.Cache.SetCacheability(HttpCacheability.NoCache); response.Cache.SetNoStore(); } } } response.ContentType = GetContentType(contentType); response.ContentEncoding = System.Text.Encoding.UTF8; if (data != null) { response.Write(data); } response.End(); }
上面是我整理给大家的,希望今后会对大家有帮助。
相关文章:
ajax返回object Object的快速解决方法
jQuery中ajax的4种常用请求方式介绍
使用原生ajax处理json字符串的方法
以上就是编写轻量ajax组件第三篇实现的详细内容,更多请关注Gxl网其它相关文章!