在《《ASP.NET Core 6框架揭秘》实例演示[17]:利用IHttpClientFactory工厂来创建HttpClient》之后,我们将关注点放到HttpClient对象上。我们知道ASP.NET的核心就是由中间件组成的请求处理管道,HttpClient也采用了类似的设计。HttpClient管道由一组HttpMessageHandler对象构成,这些HttpMessageHandler相当于ASPNET的中间件。如下这些示例演示帮助我们更清楚地认识HttpMessageHandler处理管道。[本文节选《ASP.NET Core 6框架揭秘》第12章]

[S1208]HttpClient的默认管道结构(源代码)
[S1209]定制HttpClient管道(源代码)
[S1210]针对HTTP调用的日志输出(>=Information)(源代码)
[S1211]针对HTTP调用的日志输出(>=Trace)(源代码)

[S1208]HttpClient的默认管道结构

接下来我们通过如下的演示程序使用IHttpClientFactory工厂创建了 一个HttpClient对象,并查看其管道依次由哪些类型的HttpMessageHandler对象组成。如代码片段所示,我们定义了一个辅助方法PrintPipeline方法以递归的形式将指定HttpMessageHandler对象及其下一个处理器的类型输出到控制台上。

using Microsoft.Extensions.DependencyInjection;
using System.Reflection;var httpClient = new ServiceCollection().AddHttpClient().BuildServiceProvider().GetRequiredService<IHttpClientFactory>().CreateClient();
var handlerField = typeof(HttpMessageInvoker).GetField("_handler", BindingFlags.NonPublic | BindingFlags.Instance);
PrintPipeline((HttpMessageHandler?)handlerField?.GetValue(httpClient), 0);static void PrintPipeline(HttpMessageHandler? handler, int index)
{if (index == 0){Console.WriteLine(handler?.GetType().Name);}else{Console.WriteLine($"{new string(' ', index * 4)}=>{handler?.GetType().Name}");}if (handler is DelegatingHandler delegatingHandler){PrintPipeline(delegatingHandler.InnerHandler, index + 1);}
}

我们利用依赖注入容器提供的IHttpClientFactory工厂创建出HttpClient对象,并利用反射方式得到表示处理器的HttpMessageHandler对象,它实际上就是管道的第一个DelegatingHandler对象。我们将这个对象作为参数调用PrintPipeline方法将构成管道的每个处理器类型名称打印出来,图1为最终的输出结果。


图1 默认处理器管道

从图1所示的输出结果可以看出,对于采用默认配置构建的IHttpClientFactory工厂创建的HttpClient对象来说,它的处理器管道由如下四个类型的处理器构成:

  • LifetimeTrackingHttpMessageHandler:在指定的生命周期内复用HttpMessageHandler对象的以提供更好的性能。

  • LoggingScopeHttpMessageHandler:在整个调用的边界(从开始调用到返回结果)输出相应的跟踪诊断日志(比如记录整个调用耗时)。

  • LoggingHttpMessageHandler:在网络交互边界(从请求发送到响应接收)输出相应的跟踪诊断日志(比如单纯记录网络通信耗时)。

  • HttpClientHandler:完成基于网络传输的请求发送和响应接收。

[S1209]定制HttpClient管道

对于任何一个由IHttpClientFactory工厂创建的HttpClient对象来说,除了位于管道末端作为主处理器的HttpClientHandler可以替换之外,上述的其它三个处理器总是存在的。我们可以通过配置添加为构建的管道上添加任意处理器,它们最终会被添加到LoggingScopeHttpMessageHandler和LoggingHttpMessageHandler之间。我们编写了一个简单的实例来演示针对自定义处理器的注册。如下面的代码片段所示,我们定义了四个HttpMessageHandler类型,其中派生于HttpClientHandler的ExtendedHttpClientHandler将作为管道末端的主处理器,其他三个派生于DelegatingHandler的处理器将额外“注入”管道中。

public class ExtendedHttpClientHandler     : HttpClientHandler { }
public class FooHttpMessageHandler : DelegatingHandler { }
public class BarHttpMessageHandler : DelegatingHandler { }
public class BazHttpMessageHandler : DelegatingHandler { }
如下所示的演示程序在调用AddClient扩展方法得到返回的IHttpClientBuilder对象之后,调用了它的ConfigurePrimaryHttpMessageHandler扩展方法,并利用提供了一个Func<HttpMessageHandler>委托将ExtendedHttpClientHandler对象注册为主处理器。我们接下来调用了这个IHttpClientBuilder对象的AddHttpMessageHandler扩展方法利用提供的Func<IServiceProvider, DelegatingHandler>委托添加了额外的三个处理器。
using App;
using Microsoft.Extensions.DependencyInjection;
using System.Reflection;var services = new ServiceCollection();
services.AddHttpClient(string.Empty).ConfigurePrimaryHttpMessageHandler(_ => new ExtendedHttpClientHandler()).AddHttpMessageHandler(_ => new FooHttpMessageHandler()).AddHttpMessageHandler(_ => new BarHttpMessageHandler()).AddHttpMessageHandler(_ => new BazHttpMessageHandler());var httpClient = services.BuildServiceProvider().GetRequiredService<IHttpClientFactory>().CreateClient();
var handlerField = typeof(HttpMessageInvoker).GetField("_handler", BindingFlags.NonPublic | BindingFlags.Instance);
PrintPipeline((HttpMessageHandler?)handlerField?.GetValue(httpClient), 0);static void PrintPipeline(HttpMessageHandler? handler, int index)
{if (index == 0){Console.WriteLine(handler?.GetType().Name);}else{Console.WriteLine($"{new string(' ', index * 4)}=>{handler?.GetType().Name}");}if (handler is DelegatingHandler delegatingHandler){PrintPipeline(delegatingHandler.InnerHandler, index + 1);}
}

在利用IServiceProvider对象构建出IHttpClientFactory工厂之后,我们利用它将HttpClient对象创建出来,并采用与前一个实例相同的方式将它的处理器管道结构打印出来。组成管道的处理器顺序体现在如图2所示的输出结果中。


图2 定制处理器管道

[S1210]针对HTTP调用的日志输出(>=Information)

对于由IHttpClientFactory工厂创建的HttpClient来说,它的处理器管道总是包含两个与日志相关的处理器,对应的类型分别是LoggingScopeHttpMessageHandler和LoggingHttpMessageHandler,它们会在不同的边界或范围输出相应的跟踪诊断日志。前者的边界是针对的是基于整个管道的调用,后者则是针对的是最后一个面向网络传输。它们究竟会输出怎样的日志呢?我们不妨通过一个简单的实例来寻找答案。如下面代码片段所示,我们自定义了一个继承自DelegatingHandler的DelayHttpMessageHanadler类型,它会在调用后续处理器前后模拟1秒和2秒的耗时。

public class DelayHttpMessageHanadler : DelegatingHandler
{protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken){await Task.Delay(TimeSpan.FromSeconds(1), cancellationToken);var response = await base.SendAsync(request, cancellationToken);await Task.Delay(TimeSpan.FromSeconds(2), cancellationToken);return response;}
}

在调用AddHttpClient扩展方法对DelayHttpMessageHanadler进行注册之前,我们还添加了针对日志的服务注册。具体来说,我们添加了针对控制台的输出,并开启了针对日志范围的支持。在利用IHttpClientFactory工厂将HttpClient对象创建出来后,我们用它向地址“http://www.baidu.com”发送了一个GET请求。

using App;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;var services = new ServiceCollection().AddLogging(logging => logging.AddConsole().AddSimpleConsole(options => options.IncludeScopes = true));
services.AddHttpClient(string.Empty).AddHttpMessageHandler(() => new DelayHttpMessageHanadler());
var httpClient = services.BuildServiceProvider().GetRequiredService<IHttpClientFactory>().CreateClient();
await httpClient.GetAsync("http://www.baidu.com");

程序运行之后,我们会在控制台上看到如图3所示的四条日志。日志第一条和最后一条是LoggingScopeHttpMessageHandler输出的,它创建了一个日志范围,范围名称采用模板为“HTTP {Method} {URL}”,最后一条日志会输出针对整个管道上的调用耗时。第2条和第3条日志是LoggingHttpMessageHandler对象输出的,它们写入的时机分别是发送请求前和接收到请求后,最后一条还是输出两者之间的时间间隔,也就是面向网络传输的耗时。从输出的内容可以看出,两个耗时基本上相差三秒,刚好是我们注册的DelayHttpMessageHanadler对象模拟延时。


图3 诊断日志(Level >=Information)

[S1211]针对HTTP调用的日志输出(>=Trace)

由于在默认情况下只有等级不低于Information的日志才会输出到控制台上,所以看不到上述两个输出的更低等级(Trace)的日志。接下来我们对程序作如下的改动,通过添加日志过滤器输出所有等级的日志。

using App;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;var services = new ServiceCollection().AddLogging(logging => logging.SetMinimumLevel(LogLevel.Trace).AddConsole().AddSimpleConsole(options => options.IncludeScopes = true));
services.AddHttpClient(string.Empty).AddHttpMessageHandler(() => new DelayHttpMessageHanadler());
var httpClient = services.BuildServiceProvider().GetRequiredService<IHttpClientFactory>().CreateClient();
await httpClient.GetAsync("http://www.baidu.com");

再次运行我们的演示程序,控制台上将会输出如图4所示的日志。我们可以看出LoggingScopeHttpMessageHandler和LoggingHttpMessageHandler会将请求和响应的报头写入到等级为Trace的日志之中。


图4 诊断日志(All)

《ASP.NET Core 6框架揭秘》实例演示[01]:编程初体验
《ASP.NET Core 6框架揭秘》实例演示[02]:各种形式的API开发
《ASP.NET Core 6框架揭秘》实例演示[03]:Dapr初体验
《ASP.NET Core 6框架揭秘》实例演示[04]:自定义依赖注入框架
《ASP.NET Core 6框架揭秘》实例演示[05]:依赖注入基本编程模式
《ASP.NET Core 6框架揭秘》实例演示[06]:依赖注入框架设计细节
《ASP.NET Core 6框架揭秘》实例演示[07]:文件系统
《ASP.NET Core 6框架揭秘》实例演示[08]:配置的基本编程模式
《ASP.NET Core 6框架揭秘》实例演示[09]:将配置绑定为对象
《ASP.NET Core 6框架揭秘》实例演示[10]:Options基本编程模式
《ASP.NET Core 6框架揭秘》实例演示[11]:诊断跟踪的几种基本编程方式 
《ASP.NET Core 6框架揭秘》实例演示[13]:日志的基本编程模式
《ASP.NET Core 6框架揭秘》实例演示[14]:日志的进阶用法
《ASP.NET Core 6框架揭秘》实例演示[15]:针对控制台的日志输出
《ASP.NET Core 6框架揭秘》实例演示[16]:内存缓存与分布式缓存的使用
《ASP.NET Core 6框架揭秘》实例演示[17]:利用IHttpClientFactory工厂来创建HttpClient

《ASP.NET Core 6框架揭秘》实例演示[18]:HttpClient处理管道相关推荐

  1. 《ASP.NET Core 6框架揭秘》实例演示[19]:数据加解密与哈希

    数据保护(Data Protection)框架旨在解决数据在传输与持久化存储过程中的一致性(Integrity)和机密性(confidentiality)问题,前者用于检验接收到的数据是否经过篡改,后 ...

  2. 《ASP.NET Core 6框架揭秘》实例演示[10]:Options基本编程模式

    依赖注入使我们可以将依赖的功能定义成服务,最终以一种松耦合的形式注入消费该功能的组件或者服务中.除了可以采用依赖注入的形式消费承载某种功能的服务,还可以采用相同的方式消费承载配置数据的Options对 ...

  3. 《ASP.NET Core 6框架揭秘》实例演示[32]:错误页面的N种呈现方式

    由于ASP.NET是一个同时处理多个请求的Web应用框架,所以在处理某个请求过程中出现异常并不会导致整个应用的中止.出于安全方面的考量,为了避免敏感信息外泄,客户端在默认情况下并不会得到详细的出错信息 ...

  4. 《ASP.NET Core 3 框架揭秘(上下册)》送书结果公告

    [免费送书].Net5实操后的我一夜未眠,来个大胆预测!的送书抽奖结果已经出来了: 这位中奖的同学尽快填写收货地址,4/2 日还没有完成填写将作废,奖品可是热门的<ASP.NET Core 3 ...

  5. [ASP.NET Core 3框架揭秘] 异步线程无法使用IServiceProvider?

    标题反映的是上周五一个同事咨询我的问题,我觉得这是一个很好的问题.这个问题有助于我们深入理解依赖注入框架在ASP.NET Core中的应用,以及服务实例的生命周期. 一.问题重现 我们通过一个简单的实 ...

  6. [ASP.NET Core 3框架揭秘] 依赖注入:依赖注入模式

    IoC主要体现了这样一种设计思想:通过将一组通用流程的控制权从应用转移到框架之中以实现对流程的复用,并按照"好莱坞法则"实现应用程序的代码与框架之间的交互.我们可以采用若干设计模式 ...

  7. [ASP.NET Core 3框架揭秘] 文件系统[1]:抽象的“文件系统”

    ASP.NET Core应用 具有很多读取文件的场景,比如配置文件.静态Web资源文件(比如CSS.JavaScript和图片文件等)以及MVC应用的View文件,甚至是直接编译到程序集中的内嵌资源文 ...

  8. [ASP.NET Core 3框架揭秘] 跨平台开发体验: Docker

    对于一个 .NET Core开发人员,你可能没有使用过Docker,但是你不可能没有听说过Docker.Docker是Github上最受欢迎的开源项目之一,它号称要成为所有云应用的基石,并把互联网升级 ...

  9. [ASP.NET Core 3框架揭秘] 跨平台开发体验: Mac OS

    除了微软自家的Windows平台, .NET Core针对Mac OS以及各种Linux Distribution(RHEL.Ubuntu.Debian.Fedora.CentOS和SUSE等)都提供 ...

最新文章

  1. 试读angular源码第三章:初始化zone
  2. Django常用的模块
  3. 三十一、Python读写docx文件
  4. 计算机伺服系统的作用是,伺服系统简介及其在数控加工中的应用
  5. Clickhouse Engine kafka 将kafka数据同步clickhouse
  6. pytorch 1.7.x训练保存的模型在1.4低版本无法加载
  7. mongdb 群集_群集文档的文本摘要
  8. 微型计算机十号功能,青岛理工大学练习题微机原理(10页)-原创力文档
  9. Gprinter Android SDK V2.1.4 使用说明
  10. 稳定币协议Fei Protocol通过FIP-2提案
  11. 关于苹果Mac上设置固件密码的方法?
  12. Linux内核维护工作流程曝光,程序员必须拜读!
  13. WIN10配置JAVA环境变量
  14. Java -- 定时任务实现方式
  15. android小米卸载app,MIUI系统软件卸载工具
  16. google gflags 库完全使用
  17. MapStruct - Ambiguous constructors found
  18. 服务器远程关机后开机开不了,远程开关机系统安全吗
  19. 天才程序员之陨落:在业余项目创业 Cloudflare,公司上市前患病失去自理能力...
  20. Mysql密码忘记怎么修改?

热门文章

  1. PuTTY的下载安装和基本使用方法教程
  2. android 变量onchange,Android内容查看器-onChange方法检查上一个呼...
  3. ios web input.onchange 不执行
  4. 年薪80万!AI革了程序员的命
  5. css3里面怎么引用外部字体包,不再是单调的微软雅黑和宋体
  6. 07. vue3+vite+qiankun搭建微应用前端框架,并接入vue3微应用
  7. 案例解读 | 三大缺失 败在源头 1.75 亿元智慧城市失败项目解析
  8. 刷高词指数做权重?买链一定要睁大双眼,快排站点需提防。
  9. 云发布的Docker部署文档
  10. 数字图像与机器视觉基础补充(1)——区分位图和图像处理