标签：WebAPI string Request request Framwork actionExecutedContext var Net public
思路：
通过重写 ActionFilterAttribute 拦截Action的请求及返回信息，实现对接口请求的监听。
最终效果如下：
全局启用需配置如下：
局部启用需配置如下：
源码如下：
1 /// <summary>
2 /// 统一的接口访问监控日志，
3 /// 全局启用-请添加 GlobalConfiguration.Configuration.Filters.Add(new TimingFilterAttribute());
4 /// 局部启用（目前模式）-在Controller或者Action上添加Attribute注入即可
5 /// </summary>
6 public class TimingFilterAttribute : ActionFilterAttribute
7 {
8 private const string Key = "__action_recordtime__";
9 private const string TimeKey = "__action_receivetime__";
10 /// <summary>
11 /// 自定义参数
12 /// </summary>
13 public static string msg { get; set; }
14 public static string ReqParms { get; set; }
15 public TimingFilterAttribute()
16 {
17 msg = string.Empty;
18 }
19
20 /// <summary>
21 /// 初始化时填入类的说明
22 /// </summary>
23 /// <param name="message"></param>
24 public TimingFilterAttribute(string message)
25 {
26 msg = message;
27 }
28 public override void OnActionExecuting(HttpActionContext actionContext)
29 {
30 if (IsRecordTime(actionContext))
31 {
32 return;
33 }
34 // ReqParms= GetRequestValues(actionContext);
35 var stopWatch = new Stopwatch();
36 actionContext.Request.Properties[Key] = stopWatch;
37 actionContext.Request.Properties[TimeKey] = DateTime.Now.ToBinary();
38 stopWatch.Start();
39 }
40
41 public override void OnActionExecuted(HttpActionExecutedContext actionExecutedContext)
42 {
43 if (!actionExecutedContext.Request.Properties.ContainsKey(Key) || !actionExecutedContext.Request.Properties.ContainsKey(TimeKey))
44 {
45 return;
46 }
47 object beginTime = null;
48 if (!actionExecutedContext.Request.Properties.TryGetValue(TimeKey, out beginTime))
49 {
50 return;
51 }
52 var stopWatch = actionExecutedContext.Request.Properties[Key] as Stopwatch;
53 if (stopWatch == null)
54 {
55 return;
56 }
57 stopWatch.Stop();
58
59 DateTime starttime = DateTime.FromBinary(Convert.ToInt64(beginTime));
60 HttpRequest request = HttpContext.Current.Request;
61 string token = string.Empty;
62 var appkey = string.Empty;
63 if (request.Headers.AllKeys.Contains("Token")) { token = request.Headers["Token"]; }
64
65 if (request.Headers.AllKeys.Contains("AppKey")) { appkey = request.Headers["AppKey"]; }
66
67 var actionName = actionExecutedContext.ActionContext.ActionDescriptor.ActionName;
68 var controllerName = actionExecutedContext.ActionContext.ActionDescriptor.ControllerDescriptor.ControllerName;
69
70 var ip = request.UserHostAddress;
71 var UserHostName = request.UserHostName;
72 var paramaters = GetRequestValues(actionExecutedContext);
73 // var paramaters = ReqParms;//获取入参
74 var executeResult = GetResponseValues(actionExecutedContext);//获取response响应的结果
75 var comments = msg;
76 var RequestUri = request.Url.AbsoluteUri;
77 var MethodType= request.HttpMethod.ToString();
78 Bondex.Core.BizTool.LogPlat.LogHelper.Info($"{controllerName}/{actionName}", "E帐通接口监控服务", "TimingFilterAttribute", $"",
79 $"当前接口路径:{RequestUri},请求方式：{MethodType},请求时间:{starttime.ToString("yyyy-MM-dd HH:mm:ss:fff")},返回时间{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")},接口执行时间:{stopWatch.Elapsed};请求IP:{ip},请求DNS:{UserHostName},请求入参：{paramaters},返回值:{executeResult},备注:{comments}");
80
81 }
82 /// <summary>
83 /// 读取request 的提交内容
84 /// </summary>
85 /// <param name="actionExecutedContext"></param>
86 /// <returns></returns>
87 public string GetRequestValues(HttpActionExecutedContext actionExecutedContext)
88 {
89 string result = String.Empty;
90 using (var stream = actionExecutedContext.Request.Content.ReadAsStreamAsync().Result)
91 {
92 if (stream.CanSeek)
93 {
94 stream.Position = 0;
95 }
96 result = actionExecutedContext.Request.Content.ReadAsStringAsync().Result;
97 }
98
99 return result;
100 }
101
102 /// <summary>
103 /// 读取action返回的result
104 /// </summary>
105 /// <param name="actionExecutedContext"></param>
106 /// <returns></returns>
107 public string GetResponseValues(HttpActionExecutedContext actionExecutedContext)
108 {
109 Stream stream = actionExecutedContext.Response.Content.ReadAsStreamAsync().Result;
110 Encoding encoding = Encoding.UTF8;
111 /*
112 这个StreamReader不能关闭，也不能dispose， 关了就傻逼了
113 因为你关掉后，后面的管道 或拦截器就没办法读取了
114 */
115 var reader = new StreamReader(stream, encoding);
116 string result = reader.ReadToEnd();
117 /*
118 这里也要注意： stream.Position = 0;
119 当你读取完之后必须把stream的位置设为开始
120 因为request和response读取完以后Position到最后一个位置，交给下一个方法处理的时候就会读不到内容了。
121 */
122 stream.Position = 0;
123 return result;
124 }
125 /// <summary>
126 /// 判断是否拦截请求，记录接口信息
127 /// </summary>
128 /// <param name="actionContext"></param>
129 /// <returns></returns>
130 private static bool IsRecordTime(HttpActionContext actionContext)
131 {
132 return actionContext.ActionDescriptor.GetCustomAttributes<NoRecordTimeAttribute>().Any() ||
133 actionContext.ControllerContext.ControllerDescriptor.GetCustomAttributes<NoRecordTimeAttribute>().Any();
134 }
135 }
136
137 [AttributeUsage(AttributeTargets.Method | AttributeTargets.Class, Inherited = true)]
138 public class NoRecordTimeAttribute : Attribute
139 {
140
141 }
标签：WebAPI,string,Request,request,Framwork,actionExecutedContext,var,Net,public 来源： https://www.cnblogs.com/chao0219/p/16442807.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。