.net webapi 过滤器使用（记录访问日志）

常用的过滤器有三种：OnAuthorization、ActionFilterAttribute、ExceptionFilterAttribute

本文件主要记录使用ActionFilterAttribute记录接口的访问日志，包括请求参数、响应结果，耗时等

直接上代码：

using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Web;
using System.Web.Http.Controllers;
using System.Web.Http.Filters;
using WebApi.Models;

namespace WebApi.App_Start
{
    /// <summary>
    /// 在Action方法运行之前调用
    /// 1、所有请求流水先写TXT日志
    /// 2、再启动作业程序把日志转存到指定位置
    /// 3、分析日志进指定表，并删除日志
    /// </summary>
    [AttributeUsage(AttributeTargets.Class | AttributeTargets.Method, AllowMultiple = false)]
    public class WebApiTrackerAttribute : ActionFilterAttribute
    {
        private readonly string Key = "_thisWebApiOnActionMonitorLog_";
        public override void OnActionExecuting(HttpActionContext actionContext)
        {
            base.OnActionExecuting(actionContext);
            WebApiMonitorLog MonLog = new WebApiMonitorLog();
            MonLog.ExecuteStartTime = DateTime.Now;
            //获取Action 参数
            MonLog.ActionParams = actionContext.ActionArguments;
            MonLog.HttpRequestHeaders = actionContext.Request.Headers.ToString();
            MonLog.HttpMethod = actionContext.Request.Method.Method;

            actionContext.Request.Properties[Key] = MonLog;
            var form = System.Web.HttpContext.Current.Request.Form;
            #region 如果参数是实体对象，获取序列化后的数据
            Stream stream = actionContext.Request.Content.ReadAsStreamAsync().Result;
            Encoding encoding = Encoding.UTF8;
            stream.Position = 0;
            string responseData = "";
            using (StreamReader reader = new StreamReader(stream, encoding))
            {
                responseData = reader.ReadToEnd().ToString();
            }
            if (!string.IsNullOrWhiteSpace(responseData) && !MonLog.ActionParams.ContainsKey("__EntityParamsList__"))
            {
                MonLog.ActionParams["__EntityParamsList__"] = responseData;
            }
            #endregion
        }

        /// <summary>
        /// 在Action方法运行之后调用
        /// </summary>
        /// <param name="actionExecutedContext"></param>
        public override void OnActionExecuted(HttpActionExecutedContext actionExecutedContext)
        {
            //加上按线程数存
            int thread = 0;
            try
            {
                thread = System.Threading.Thread.CurrentThread.ManagedThreadId;
            }
            catch
            {
                thread = 0;
            }
            WebApiMonitorLog MonLog = actionExecutedContext.Request.Properties[Key] as WebApiMonitorLog;
            MonLog.ExecuteEndTime = DateTime.Now;
            MonLog.ActionName = actionExecutedContext.ActionContext.ActionDescriptor.ActionName;
            MonLog.ControllerName = actionExecutedContext.ActionContext.ActionDescriptor.ControllerDescriptor.ControllerName;
            MonLog.Response = actionExecutedContext.Response.Content.ReadAsStringAsync().Result;
            //Aisidi.Log.LogBuilder.Write(MonLog.ControllerName + "_" + System.DateTime.Now.Hour, MonLog.GetLoginfo());
            //高并发，用线程写法

            string pathtxt = HttpContext.Current.Server.MapPath("/WebApiLog/");
            //TODO 写日志（txt格式）


            //Aisidi.Log.LogBuilder.Write(MonLog.ControllerName + "_" + System.DateTime.Now.Hour + "_ThreadNum_" + thread, MonLog.GetLoginfo());
            if (actionExecutedContext.Exception != null)
            {
                string apiname = "";
                string Msg = string.Format(@"
                请求【{0}Controller】的【{1}】产生异常：
                Action参数：{2}
                Http请求头:{3}
                客户端IP：{4},
                HttpMethod:{5}", MonLog.ControllerName, MonLog.ActionName, MonLog.GetCollections(MonLog.ActionParams, out apiname), MonLog.HttpRequestHeaders, MonLog.GetIP(), MonLog.HttpMethod);

                //TODO 写日志（txt格式）
            }
        }
    }
    /// <summary>
    /// 监控日志对象
    /// </summary>
    public class WebApiMonitorLog
    {
        public string ControllerName
        {
            get;
            set;
        }
        public string ActionName
        {
            get;
            set;
        }

        public DateTime ExecuteStartTime
        {
            get;
            set;
        }
        public DateTime ExecuteEndTime
        {
            get;
            set;
        }
        /// <summary>
        /// 请求的Action 参数
        /// </summary>
        public Dictionary<string, object> ActionParams
        {
            get;
            set;
        }
        /// <summary>
        /// Http请求头
        /// </summary>
        public string HttpRequestHeaders
        {
            get;
            set;
        }

        /// <summary>
        /// 请求方式
        /// </summary>
        public string HttpMethod
        {
            get;
            set;
        }
        /// <summary>
        /// 请求的IP地址
        /// </summary>
        public string IP
        {
            get;
            set;
        }

        public string Response { get; set; }

        public string GetLoginfo()
        {
            string apiname = "";
            string reqcontent = GetCollections(ActionParams, out apiname);
            if (reqcontent.ToLower().Contains("apiname"))
            {
                apiname = JsonConvert.DeserializeObject<ApiRequest>(apiname).apiname;
            }
            string arguments = JsonConvert.SerializeObject(new webapi_logtxt
            {
                reqtime = ExecuteStartTime,
                rsptime = ExecuteEndTime,
                dealtime = (ExecuteEndTime - ExecuteStartTime).TotalSeconds.ToString(),
                reqcontent = reqcontent,
                rspcontent = Response,
                apiname = apiname
            });
            return arguments;
        }

        /// <summary>
        /// 获取Action 参数
        /// </summary>
        /// <param name="Collections"></param>
        /// <returns></returns>
        public string GetCollections(Dictionary<string, object> Collections, out string apiname)
        {
            apiname = "";
            string Parameters = string.Empty;
            if (Collections == null || Collections.Count == 0)
            {
                return Parameters;
            }
            foreach (string key in Collections.Keys)
            {
                Parameters += string.Format("{0}={1}&", key, Collections[key]);
                if (key == "__EntityParamsList__")
                {
                    apiname = Collections[key].ToString();
                }
            }
            if (!string.IsNullOrWhiteSpace(Parameters) && Parameters.EndsWith("&"))
            {
                Parameters = Parameters.Substring(0, Parameters.Length - 1);
            }
            return Parameters;
        }

        /// <summary>
        /// 获取IP
        /// </summary>
        /// <returns></returns>
        public string GetIP()
        {
            string ip = string.Empty;
            if (!string.IsNullOrEmpty(System.Web.HttpContext.Current.Request.ServerVariables["HTTP_VIA"]))
                ip = Convert.ToString(System.Web.HttpContext.Current.Request.ServerVariables["HTTP_X_FORWARDED_FOR"]);
            if (string.IsNullOrEmpty(ip))
                ip = Convert.ToString(System.Web.HttpContext.Current.Request.ServerVariables["REMOTE_ADDR"]);
            return ip;
        }
    }
    public class webapi_logtxt
    {
        /// <summary>
        /// 请求时间
        /// </summary>
        public DateTime reqtime { get; set; }
        /// <summary>
        /// 响应时间
        /// </summary>
        public DateTime rsptime { get; set; }
        /// <summary>
        /// 处理时长
        /// </summary>
        public string dealtime { get; set; }
        /// <summary>
        /// 请求内容
        /// </summary>
        public string reqcontent { get; set; }
        /// <summary>
        /// 响应内容
        /// </summary>
        public string rspcontent { get; set; }
        /// <summary>
        /// 接口方法名称
        /// </summary>
        public string apiname { get; set; }
    }
}

编写作业，定时去分析上面日志（只动过时日志），高并发控制，防止异常，估不建议在正常接口中进行操作数据库或分析作业日志

public void ReadFildWebApiLog()
        {
            //读取文件（1小时之前的文件）
            //检验临时文件夹的文件是否超过1小时
            string webLogTxt = System.Configuration.ConfigurationManager.AppSettings["WebApiLogFilePath"];
            if (!string.IsNullOrEmpty(webLogTxt))
            {
                IsoDateTimeConverter timeFormat = new IsoDateTimeConverter();
                timeFormat.DateTimeFormat = "yyyy-MM-dd HH:mm:ss.fff";
                List<string> webLogTxtList = new FileUtilHelper().GetFiles(webLogTxt, -60);
                string content = "";
                List<webapi_log> webapi_logList = null;
                List<ishop_webapi_log> ishop_webapi_logList = null;
                List<ishop_webapi_log_dtl> ishop_webapi_log_dtlList = null;
                foreach (var weblog in webLogTxtList)
                {
                    ishop_webapi_logList = new List<ishop_webapi_log>();
                    ishop_webapi_log_dtlList = new List<ishop_webapi_log_dtl>();
                    webapi_logList = new List<webapi_log>();
                    content = System.IO.File.ReadAllText(webLogTxt + weblog);
                    var contentList = content.Split('
');
                    foreach (var con in contentList)
                    {
                        if (!string.IsNullOrEmpty(con))
                        {
                            webapi_logList.Add(JsonConvert.DeserializeObject<webapi_log>(con));
                        }
                    }
                    foreach (var log in webapi_logList)
                    {
                        string logid = Guid.NewGuid().ToString();
                        string logdtlid = Guid.NewGuid().ToString();
                        ishop_webapi_logList.Add(new ishop_webapi_log
                        {
                            id = logid,
                            apiname = log.apiname,
                            controllers = weblog.Split('_')[0].ToString(),
                            createtime = System.DateTime.Now,
                            dealtime = log.dealtime,
                            reqtime = log.reqtime,
                            rsptime = log.rsptime
                        });
                        ishop_webapi_log_dtlList.Add(new ishop_webapi_log_dtl
                        {
                            id = logdtlid,
                            refid = logid,
                            reqcontent = log.reqcontent,
                            rspcontent = log.rspcontent
                        });
                    }
                    //存储数据库
                    if (ishop_webapi_logDal.BatchAdd_SQL(ishop_webapi_logList, "ishop_webapi_log", ishavekey: false) > 0 && ishop_webapi_log_dtlDal.BatchAdd_SQL(ishop_webapi_log_dtlList, "ishop_webapi_log_dtl", ishavekey: false) > 0)
                    {

                        //删除文件
                        System.IO.File.Delete(webLogTxt + weblog);
                    }
                }
            }

        }