.net 记录http请求

记录http请求

环境

• .net7
  

一、过滤器(Filter)

这个过程用的的是操作过滤器（ActionFilter）
二、

2.1 继承IAsyncActionFilter

2.2 重写OnActionExecutionAsync

OnActionExecutionAsync - 在调用操作方法前调用
OnActionExecutionAsync(ActionExecutingContext, ActionExecutionDelegate)
ActionExecutingContext 实例化新 ActionExecutingContext 实例,返回关于调用操作方法的信息
ActionExecutionDelegate

• 异步返回的 ActionExecutedContext 委托，指示已执行操作或下一个操作筛选器
  
• 完成后 Task 返回 的 ActionExecutedContext。
  

三、示例

1. public class AuditLogActionFilter : IAsyncActionFilter
2. {
3.     //AuditLog服务对象，用于保存/查询等操作
4.     //private readonly IAuditLogService _auditLogService;
5.     //当前登录用户对象，获取当前用户信息
7.     // 这些都是Abp中的，使用会报错。还没去看具体实现
8.     //private readonly IAbpSession _admSession;
9.     //系统日志接口，用于记录一些系统异常信息
10.     //private readonly ILogger<AuditActionFilter> _logger;
11.     //客户端信息接口，获取浏览器，IP等信息
12.     //private readonly IClientInfoProvider _clientInfoProvider;
14.     public MysqlDbContext _dbContext;
16.     public AuditLogActionFilter(MysqlDbContext dbContext)
17.     {
18.         _dbContext = dbContext;
19.     }
21.     // 方法进去前执行
22.     public async Task OnActionExecutionAsync(ActionExecutingContext context, ActionExecutionDelegate next)
23.     {
24.         //接口Type
25.         var type = (context.ActionDescriptor as ControllerActionDescriptor).ControllerTypeInfo.AsType();
26.         //方法信息
27.         var method = (context.ActionDescriptor as ControllerActionDescriptor).MethodInfo;
28.         //方法参数
29.         var arguments = context.ActionArguments;
30.         //开始计时
31.         var stopwatch = Stopwatch.StartNew();
34.         var Request = context.HttpContext.Request;
35.         var Response = context.HttpContext.Response;
38.         var auditInfoLog = new AuditInfoLog
39.         {
40.             Url = Request.Host.Value + Request.Path.Value, // 请求的URL
41.             Host = Request.Host.Host.ToString(), // 请求地址
42.             Port = Request.Host.Port, // 请求端口
43.             Headers = Request.Headers.ToString(), // 请求头
44.             Method = Request.Method, // 请求方法
45.             ExcuteStartTime = DateTime.Now, // 执行开始时间
46.             ServiceName = type != null ? type.FullName : "",
47.             Parameters = JsonConvert.SerializeObject(arguments), // 请求参数
48.             StatusCode = Response.StatusCode // 返回状态码
49.         };
51.         ActionExecutedContext result = null;
52.         try
53.         {
54.             result = await next();
55.             if (result.Exception != null && !result.ExceptionHandled)
56.             {
57.                 auditInfoLog.Exception = result.Exception.ToString(); // 异常信息
58.             }
59.         }
60.         catch (Exception ex)
61.         {
62.             auditInfoLog.Exception = ex.ToString(); // 异常信息
63.             throw;
64.         }
65.         finally
66.         {
67.             stopwatch.Stop();
68.             auditInfoLog.ExecutionDuration = Convert.ToInt32(stopwatch.Elapsed.TotalMilliseconds);
70.             if (result != null)
71.             {
72.                 switch (result.Result)
73.                 {
74.                     case ObjectResult objectResult:
75.                         auditInfoLog.ReturnValue = objectResult.Value.ToString();
76.                         break;
78.                     case JsonResult jsonResult:
79.                         auditInfoLog.ReturnValue = jsonResult.Value.ToString();
80.                         break;
82.                     case ContentResult contentResult:
83.                         auditInfoLog.ReturnValue = contentResult.Content;
84.                         break;
85.                 }
86.             }
87.             Console.WriteLine(auditInfoLog.ToString());
88.             auditInfoLog.ReturnValue = auditInfoLog.ReturnValue; // 请求返回值
90.             //保存审计日志
92.             #region  存储到数据库
93.             auditInfoLog.ExcuteEndTime = auditInfoLog.ExcuteStartTime.Add(stopwatch.Elapsed);
94.             await _dbContext.AuditInfoLog.AddAsync(auditInfoLog);
95.             _dbContext.SaveChanges();
96.             #endregion
98.             #region 存储到本地
99.             var date = DateTime.Now.ToString("yyyy-MM-dd");
100.             var HttpLogPage = ($"LocalLogs/HttpLogs");
102.             // 判断是否有这个文件夹,没有则生成
103.             if (!Directory.Exists(HttpLogPage))
104.             {
105.                 Directory.CreateDirectory(HttpLogPage);
106.             }  
107.             using (StreamWriter sw = new StreamWriter($"{HttpLogPage}/HttpLog{date}.txt",true))
108.             {
109.                 sw.WriteLine($"接口服务名称:   {auditInfoLog.ServiceName}");
110.                 sw.WriteLine($"请求URL:   {auditInfoLog.Url}");
111.                 sw.WriteLine($"请求地址:   {auditInfoLog.Host}");
112.                 sw.WriteLine($"请求端口:   {auditInfoLog.Port}");
113.                 sw.WriteLine($"请求方法:   {auditInfoLog.Method}");
114.                 sw.WriteLine($"请求参数:   {auditInfoLog.Parameters}");
115.                 sw.WriteLine($"返回状态码:   {auditInfoLog.StatusCode}");
116.                 sw.WriteLine($"返回数据:   {auditInfoLog.ReturnValue}");
117.                 sw.WriteLine($"执行开始时间:   {auditInfoLog.ExcuteStartTime.ToString("yyyy-MM-dd HH:mm:ss.fffffff")}");
118.                 sw.WriteLine($"执行时间:   {auditInfoLog.ExecutionDuration}ms");
119.                 sw.WriteLine($"执行结束时间:   {auditInfoLog.ExcuteEndTime.ToString("yyyy-MM-dd HH:mm:ss.fffffff")}");
120.                 sw.WriteLine($"异常信息:   {auditInfoLog.Exception}");
121.                 sw.WriteLine("======================================================");
122.                 sw.WriteLine();
123.             }
124.             #endregion
126.             //await _auditLogService.SaveAsync(auditInfo);
127.         }
128.     }
129. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！