1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
| /// <summary>
/// 執行 Web Api 的呼叫記錄
/// </summary>
/// <remarks>
/// 紀錄資料:
///
/// 呼叫時間
/// USER
/// URL
/// METHOD
/// BODY
/// StatusCode
/// Duration
///
/// Logger 的紀錄格式，參考 https://logging.apache.org/log4net/release/sdk/log4net.Layout.PatternLayout.html
/// </remarks>
public class WebApiActionFilter : ActionFilterAttribute
{
private ILog Logger { get; set; }
public WebApiActionFilter()
{
Logger = LogManager.GetLog(GetType());
}
public WebApiActionFilter(ILog logger)
{
Logger = logger;
}
private ThreadLocal<Stopwatch> counter = new ThreadLocal<Stopwatch>(() => new Stopwatch());
public static ThreadLocal<Task<string>> RequestBody = new ThreadLocal<Task<string>>();
public override void OnActionExecuting(HttpActionContext actionContext)
{
RequestBody.Value = actionContext.Request.Content.ReadAsStringAsync();
counter.Value.Start();
}
public override void OnActionExecuted(HttpActionExecutedContext actionExecutedContext)
{
counter.Value.Stop();
LogActivity(actionExecutedContext.ActionContext, actionExecutedContext.Response);
}
private void LogActivity(HttpActionContext actionContext, HttpResponseMessage response)
{
try
{
var loggerProp = ThreadContext.Properties;
loggerProp["Uri"] = actionContext.Request.RequestUri.PathAndQuery;
loggerProp["Method"] = actionContext.Request.Method.Method;
loggerProp["Duration"] = counter.Value.ElapsedMilliseconds;
loggerProp["StatusCode"] = (int) response.StatusCode;
Logger.Info(RequestBody.Value.Result);
}
catch (Exception e)
{
Console.WriteLine(e);
}
}
}
/// <summary>
/// 用來擷取傳入的 Request Content Body, 因為沒辦法在 Filter 中取得 Body
/// </summary>
/// <remark>
/// 如果需要抓傳遞資料才需要
/// </remark>
public class LogBodyDelegateHandler : DelegatingHandler
{
protected async override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, System.Threading.CancellationToken cancellationToken)
{
if (request.Content != null)
{
var requestText = request.Content.ReadAsStringAsync();
WebApiActionFilter.RequestBody.Value = requestText;
}
// Execute the request, this does not block
var response = base.SendAsync(request, cancellationToken);
return response.Result;
}
}
|