ASP.NET Core 2.2 : 二十. Action的多种数据返回格式处理机制
上一章讲了系统如何将客户端提交的请求数据格式化处理成我们想要的格式并绑定到对应的参数,本章讲一下它的“逆过程”,如何将请求结果按照客户端想要的格式返回去。(asp.net core 系列目录)
一、常见的返回类型
以系统模板默认生成的home/index这个action来说,为什么当请求它的时候回返回一个html页面呢?除了这之外,还有json、文本等类型,系统是如何处理这些不同的类型的呢?
首先来说几种常见的返回类型的例子,并用fiddler请求这几个例子看一下结果,涉及到的一个名为book的类,代码为:
public class book { public string code { get; set; } public string name { get; set; } }
1.viewresult类型
public class homecontroller : controller { public iactionresult index() { return view(); } }
返回一个html页面,content-type值为: text/html; charset=utf-8
2.string类型
public string getstring() { return "hello core"; }
返回字符串“hello core”,content-type值为:text/plain; charset=utf-8
3.json类型
public jsonresult getjson() { return new jsonresult(new book() { code = "1001", name = "asp" }); }
返回json,值为:
{"code":"1001","name":"asp"}
content-type值为:content-type: application/json; charset=utf-8
4.直接返回实体类型
public book getmodel() { return new book() { code = "1001", name = "asp" }; }
同样是返回json,值为:
{"code":"1001","name":"asp"}
content-type值同样是:content-type: application/json; charset=utf-8
5.void类型
public void getvoid() { }
没有返回结果也没有content-type值。
下面看几个异步方法:
6.task类型
public async task gettasknoresult() { await task.run(() => { }); }
与void类型一样,没有返回结果也没有content-type值。
7.task<string>类型
public async task<string> gettaskstring() { string rtn = string.empty; await task.run(() => { rtn = "hello core"; }); return rtn; }
与string类型一样,返回字符串“hello core”,content-type值为:text/plain; charset=utf-8
8.task<jsonresult>类型
public async task<jsonresult> gettaskjson() { jsonresult jsonresult = null; await task.run(() => { jsonresult = new jsonresult(new book() { code = "1001", name = "asp" }); }); return jsonresult; }
与json类型一样,返回json,值为:
[{"code":"1001","name":"asp"},{"code":"1002","name":"net core"}]
content-type值为:content-type: application/json; charset=utf-8
还有其他类型,这里暂不列举了,总结一下:
- 返回结果有空、html页面、普通字符串、json字符串几种。
- 对应的content-type类型有空、text/html、text/plain、application/json几种。
- 异步action的返回结果,和其对应的同步action返回结果类型一致。
下一节我们看一下系统是如何处理这些不同的类型的。
二、内部处理机制解析
1.总体流程
通过下图 来看一下总体的流程:
图1
这涉及三部分内容:
第一部分,在invoker的生成阶段。在第14章讲invoker的生成的时候,讲到了action的执行者的获取,它是从一系列系统定义的xxxresultexecutor中筛选出来的,虽然它们名为xxxresultexecutor,但它们都是action的执行者而不是actionresult的执行者,都是actionmethodexecutor的子类。以action是同步还是异步以及action的返回值类型为筛选条件,具体这部分内容见图 14‑2所示xxxresultexecutor列表及其后面的筛选逻辑部分。在图 17‑1中,筛选出了被请求的action对应的xxxresultexecutor,若以home/index这个默认的action为例,这个xxxresultexecutor应该是syncactionresultexecutor。
第二部分,在action filters的处理阶段。这部分内容见16.5 filter的执行,此处恰好以action filter为例讲了action filter的执行方式及action被执行的过程。在这个阶段,会调用上文筛选出的syncactionresultexecutor的execute方法来执行home/index这个 action。执行结果返回一个iactionresult。
第三部分,在result filters的处理阶段。这个阶段和action filters的逻辑相似,只不过前者的核心是action的执行,后者的核心是action的执行结果的执行。二者都分为onexecuting和onexecuted两个方法,这两个方法也都在其对应的核心执行方法前后执行。
整体流程是这样,下面看一下细节。
2. actionmethodexecutor的选择与执行
第一部分,系统为什么要定义这么多种xxxresultexecutor并且在请求的时候一个个筛选合适的xxxresultexecutor呢?从筛选规则是以action的同步、异步以及action的返回值类型来看,这么多种xxxresultexecutor就是为了处理不同的action类型。
依然以home/index为例,在筛选xxxresultexecutor的时候,最终返回结果是syncactionresultexecutor。它的代码如下:
private class syncactionresultexecutor : actionmethodexecutor { public override valuetask<iactionresult> execute( iactionresulttypemapper mapper, objectmethodexecutor executor, object controller, object[] arguments) { var actionresult = (iactionresult)executor.execute(controller, arguments); ensureactionresultnotnull(executor, actionresult); return new valuetask<iactionresult>(actionresult); } protected override bool canexecute(objectmethodexecutor executor) => !executor.ismethodasync && typeof(iactionresult).isassignablefrom(executor.methodreturntype); }
xxxresultexecutor的canexecute方法是筛选的条件,通过这个方法判断它是否适合当前请求的目标action。它要求这个action不是异步的并且返回结果类型是派生自iactionresult的。而home/index这个action标识的返回结果是iactionresult,实际是通过view()这个方法返回的,这个方法的返回结果类型实际是iactionresult的派生类viewresult。这样的派生类还有常见的jsonresult和contentresult等,他们都继承了actionresult,而actionresult实现了iactionresult接口。所以如果一个action是同步的并且返回结果是jsonresult或contentresult的时候,对应的xxxresultexecutor也是syncactionresultexecutor。
第二部分中,action的执行是在xxxresultexecutor的execute方法,它会进一步调用了objectmethodexecutor的execute方法。实际上所有的action的都是由objectmethodexecutor的execute方法来执行执行的。而众多的xxxresultexecutor方法的作用是调用这个方法并且对返回结果进行验证和处理。例如syncactionresultexecutor会通过ensureactionresultnotnull方法确保返回的结果不能为空。
如果是sting类型呢?它对应的是syncobjectresultexecutor,代码如下:
private class syncobjectresultexecutor : actionmethodexecutor { public override valuetask<iactionresult> execute( iactionresulttypemapper mapper, objectmethodexecutor executor, object controller, object[] arguments) { // sync method returning arbitrary object var returnvalue = executor.execute(controller, arguments); var actionresult = converttoactionresult(mapper, returnvalue, executor.methodreturntype); return new valuetask<iactionresult>(actionresult); } // catch-all for sync methods protected override bool canexecute(objectmethodexecutor executor) => !executor.ismethodasync; }
由于string不是iactionresult的子类,所以会通过converttoactionresult方法对返回结果returnvalue进行处理。
private iactionresult converttoactionresult(iactionresulttypemapper mapper, object returnvalue, type declaredtype) { var result = (returnvalue as iactionresult) ?? mapper.convert(returnvalue, declaredtype); if (result == null) { throw new invalidoperationexception(resources.formatactionresult_actionreturnvaluecannotbenull(declaredtype)); } return result; }
如果returnvalue是iactionresult的子类,则返回returnvalue,否则调用一个convert方法将returnvalue转换一下:
public iactionresult convert(object value, type returntype) { if (returntype == null) { throw new argumentnullexception(nameof(returntype)); } if (value is iconverttoactionresult converter) { return converter.convert(); } return new objectresult(value) { declaredtype = returntype, }; }
这个方法会判断returnvalue是否实现了iconverttoactionresult接口,如果是则调用该接口的convert方法转换成iactionresult类型,否则会将returnvalue封装成objectresult。objectresult也是actionresult的子类。下文有个actionresult<t> 类型就是这样,该例会介绍。
所以,针对不同类型的action,系统设置了多种xxxresultexecutor来处理,最终结果无论是什么,都会被转换成iactionresult类型。方便在图 17‑1所示的第三部分进行iactionresult的执行。
上一节列出了多种不同的action,它们的处理在这里就不一一讲解了。通过下图 17‑2看一下它们的处理结果:
图 2
这里有void类型没有讲到,它本身没有返回结果,但它会被赋予一个结果emptyresult,它也是actionresult的子类。
图 2被两行虚线分隔为三行,第一行基本都介绍过了,第二行是第一行对应的异步方法,上一节介绍常见的返回类的时候说过,这些异步方法的返回结果和对应的同步方法是一样的。不过通过图 2可知,处理它们的xxxresultexecutor方法是不一样的。
第三行的actionresult<t> 类型是在asp.net core 2.1 引入的,它支持iactionresult的子类也支持类似string和book这样的特定类型。
public sealed class actionresult<tvalue> : iconverttoactionresult { public actionresult(tvalue value) { if (typeof(iactionresult).isassignablefrom(typeof(tvalue))) { var error = resources.formatinvalidtypetforactionresultoft(typeof(tvalue), "actionresult<t>"); throw new argumentexception(error); } value = value; } public actionresult(actionresult result) { if (typeof(iactionresult).isassignablefrom(typeof(tvalue))) { var error = resources.formatinvalidtypetforactionresultoft(typeof(tvalue), "actionresult<t>"); throw new argumentexception(error); } result = result ?? throw new argumentnullexception(nameof(result)); } /// <summary> /// gets the <see cref="actionresult"/>. /// </summary> public actionresult result { get; } /// <summary> /// gets the value. /// </summary> public tvalue value { get; } public static implicit operator actionresult<tvalue>(tvalue value) { return new actionresult<tvalue>(value); } public static implicit operator actionresult<tvalue>(actionresult result) { return new actionresult<tvalue>(result); } iactionresult iconverttoactionresult.convert() { return result ?? new objectresult(value) { declaredtype = typeof(tvalue), }; } }
tvalue不支持iactionresult及其子类。它的值若是iactionresult子类,会被赋值给result属性,否则会赋值给value属性。它实现了iconverttoactionresult接口,想到刚讲解string类型被处理的时候用到的convert方法。当返回结果实现了iconverttoactionresult这个接口的时候,就会调用它的convert方法进行转换。它的convert方法就是先判断它的值是否是iactionresult的子类,如果是则返回该值,否则将该值转换为objectresult后返回。
所以图 2中actionresult<t> 类型返回的结果被加上引号的意思就是结果类型可能是直接返回的iactionresult的子类,也有可能是string和book这样的特定类型被封装后的objectresult类型。
3. result filter的执行
结果被统一处理为iactionresult后,进入图 1所示的第三部分。这部分的主要内容有两个,分别是result filters的执行和iactionresult的执行。result filter也有onresultexecuting和onresultexecuted两个方法,分别在iactionresult执行的前后执行。
自定义一个myresultfilterattribute,代码如下:
public class myresultfilterattribute : attribute, iresultfilter { public void onresultexecuted(resultexecutedcontext context) { debug.writeline("homecontroller=======>onresultexecuted"); } public void onresultexecuting(resultexecutingcontext context) { debug.writeline("homecontroller=======>onresultexecuting"); } }
将它注册到第一节json的例子中:
[myresultfilter] public jsonresult getjson() { return new jsonresult(new book() { code = "1001", name = "asp" }); }
可以看到这样的输出结果:
homecontroller=======>onresultexecuting ……executing jsonresult…… homecontroller=======>onresultexecuted
在onresultexecuting中可以通过设置context.cancel = true;取消后面的工作的执行。
public void onresultexecuting(resultexecutingcontext context) { //用于验证的代码略 context.cancel = true; debug.writeline("homecontroller=======>onresultexecuting"); }
再看输出结果就至于的输出了
homecontroller=======>onresultexecuting
同时返回结果也不再是json值了,返回结果以及content-type全部为空。所以这样设置后,iactionresult以及onresultexecuted都不再被执行。
在这里除了可以做一些iactionresult执行之前的验证,还可以对httpcontext.response做一些简单的操作,例如添加个header值:
public void onresultexecuting(resultexecutingcontext context) { context.httpcontext.response.headers.add("version", "1.2"); debug.writeline("homecontroller=======>onresultexecuting"); }
除了正常返回json结果外,header中会出现新添加的version
content-type: application/json; charset=utf-8 version: 1.2
再看一下onresultexecuted方法,它是在iactionresult执行之后执行。因为在这个方法执行的时候,请求结果已经发送给请求的客户端了,所以在这里可以做一些日志类的操作。举个例子,假如在这个方法中产生了异常:
public void onresultexecuted(resultexecutedcontext context) { throw new exception("exception"); debug.writeline("homecontroller=======>onresultexecuted"); }
请求结果依然会返回正常的json,但从输出结果中看到是不一样的
homecontroller=======>onresultexecuting …… system.exception: exception
发生异常,后面的debug输出没有 执行。但却将正确的结果返回给了客户端。
result filter介绍完了,看一下核心的iactionresult的执行。
4. iactionresult的执行
在resourceinvoker的case state.resultinside阶段会调用iactionresult的执行方法invokeresultasync。该方法中参数iactionresult result会被调用executeresultasync方法执行。
protected virtual async task invokeresultasync(iactionresult result) { var actioncontext = _actioncontext; _diagnosticsource.beforeactionresult(actioncontext, result); _logger.beforeexecutingactionresult(result); try { await result.executeresultasync(actioncontext); } finally { _diagnosticsource.afteractionresult(actioncontext, result); _logger.afterexecutingactionresult(result); } }
由图 2可知,虽然所有类型的action的结果都被转换成了iactionresult,但它们本质上还是有区别的。所以这个iactionresult类型的参数result实际上可能是jsonresult、viewresult、emptyresult等具体类型。下面依然以第一节json的例子为例来看,它返回了一个jsonresult。在这里就会调用jsonresult的executeresultasync方法,jsonresult的代码如下:
public class jsonresult : actionresult, istatuscodeactionresult { //部分代码略 public override task executeresultasync(actioncontext context) { if (context == null) { throw new argumentnullexception(nameof(context)); } var services = context.httpcontext.requestservices; var executor = services.getrequiredservice<jsonresultexecutor>(); return executor.executeasync(context, this); } }
在它的executeresultasync方法中会获取依赖注入中设置的jsonresultexecutor,由jsonresultexecutor来调用executeasync方法执行后面的工作。jsonresultexecutor的代码如下:
public class jsonresultexecutor { //部分代码略 public virtual async task executeasync(actioncontext context, jsonresult result) { //验证代码略 var response = context.httpcontext.response; responsecontenttypehelper.resolvecontenttypeandencoding( result.contenttype, response.contenttype, defaultcontenttype, out var resolvedcontenttype, out var resolvedcontenttypeencoding); response.contenttype = resolvedcontenttype; if (result.statuscode != null) { response.statuscode = result.statuscode.value; } var serializersettings = result.serializersettings ?? options.serializersettings; logger.jsonresultexecuting(result.value); using (var writer = writerfactory.createwriter(response.body, resolvedcontenttypeencoding)) { using (var jsonwriter = new jsontextwriter(writer)) { jsonwriter.arraypool = _charpool; jsonwriter.closeoutput = false; jsonwriter.autocompleteonclose = false; var jsonserializer = jsonserializer.create(serializersettings); jsonserializer.serialize(jsonwriter, result.value); } // perf: call flushasync to call writeasync on the stream with any content left in the textwriter's // buffers. this is better than just letting dispose handle it (which would result in a synchronous write). await writer.flushasync(); } } }
jsonresultexecutor的executeasync方法的作用就是将jsonresult中的值转换成json串并写入context.httpcontext.response. body中。至此jsonresult执行完毕。
viewresult会有对应的viewexecutor来执行,会通过相应的规则生成一个 html页面。
而emptyresult的executeresult方法为空,所以不会返回任何内容。
public class emptyresult : actionresult { /// <inheritdoc /> public override void executeresult(actioncontext context) { } }
5. 下集预告
对于以上几种类型返回结果的格式是固定的,jsonresult就会返回json格式,viewresult就会返回html格式。
但是从第一节的例子可知,string类型会返回string类型的字符串,而book这样的实体类型却会返回json。
由图 2可知这两种类型在执行完毕后,都被封装成了objectresult,那么objectresult在执行的时候又是如何被转换成string和json两种格式的呢?
下一章继续这个话题。
上一篇: Oracle数据库连接超时