迷失网络

朋友要求到。帖一个实现 IHttpModule 的例子：
/* CREATE TABLE [Logs] ( [dt] [datetime] NOT NULL CONSTRAINT [DF_Logs_dt] DEFAULT (getdate()), [SERVER_NAME] [nvarchar] (20) COLLATE Chinese_PRC_CI_AS NOT NULL , [UserHostAddress] [nvarchar] (50) COLLATE Chinese_PRC_CI_AS NOT NULL , [Path] [nvarchar] (500) COLLATE Chinese_PRC_CI_AS NOT NULL , [QueryString] [nvarchar] (500) COLLATE Chinese_PRC_CI_AS NOT NULL , [UserName] [nvarchar] (50) COLLATE Chinese_PRC_CI_AS NOT NULL , [Category] [nvarchar] (50) COLLATE Chinese_PRC_CI_AS NOT NULL , [Message] [nvarchar] (500) COLLATE Chinese_PRC_CI_AS NOT NULL , CONSTRAINT [PK_Logs] PRIMARY KEY CLUSTERED ( [dt] ) ON [PRIMARY] ) ON [PRIMARY] GO CREATE TABLE [Exceptions] ( [dt] [datetime] NOT NULL CONSTRAINT [DF_Exceptions_dt] DEFAULT (getdate()), [SERVER_NAME] [nvarchar] (50) COLLATE Chinese_PRC_CI_AS NOT NULL , [UserHostAddress] [nvarchar] (50) COLLATE Chinese_PRC_CI_AS NOT NULL , [Path] [nvarchar] (500) COLLATE Chinese_PRC_CI_AS NOT NULL , [QueryString] [nvarchar] (500) COLLATE Chinese_PRC_CI_AS NOT NULL , [UserName] [nvarchar] (50) COLLATE Chinese_PRC_CI_AS NOT NULL , [Message] [nvarchar] (500) COLLATE Chinese_PRC_CI_AS NOT NULL , [ToString] [ntext] COLLATE Chinese_PRC_CI_AS NOT NULL , CONSTRAINT [PK_Exceptions] PRIMARY KEY CLUSTERED ( [dt] ) ON [PRIMARY] ) ON [PRIMARY] TEXTIMAGE_ON [PRIMARY] GO */ namespace AspNetMonitor { using System; using System.Collections; using System.Collections.Specialized; using System.Configuration; using System.Data; using System.Data.SqlClient; using System.IO; using System.Threading; using System.Web; using System.Text; public class Module : IHttpModule { HttpApplication app; DateTime dtstart=DateTime.Now; System.Timers.Timer timer; HttpContext Context { get { return app.Context; } } public void Init(HttpApplication application) { if(app!=null)throw(new InvalidOperationException()); app=application; app.PreRequestHandlerExecute+=new EventHandler(app_PreRequestHandlerExecute); app.PostRequestHandlerExecute+=new EventHandler(app_PostRequestHandlerExecute); app.Error+=new EventHandler(app_Error); } public void Dispose() { app.PreRequestHandlerExecute-=new EventHandler(app_PreRequestHandlerExecute); app.PostRequestHandlerExecute-=new EventHandler(app_PostRequestHandlerExecute); app.Error-=new EventHandler(app_Error); app=null; } private void app_Error(object sender, EventArgs e) { if(timer!=null) { timer.Dispose(); timer=null; } Exception x=Context.Server.GetLastError(); while(x is HttpUnhandledException) x=x.InnerException; if(x==null)return; NameValueCollection nvc=new NameValueCollection(); HttpRequest request=Context.Request; nvc.Add("SERVER_NAME" ,request.ServerVariables["SERVER_NAME"]); nvc.Add("UserHostAddress" ,request.UserHostAddress); nvc.Add("Path" ,request.Path); nvc.Add("QueryString" ,request.ServerVariables["QUERY_STRING"]); nvc.Add("UserName",Context.User.Identity.Name); nvc.Add("Message",x.Message); nvc.Add("ToString",x.ToString()); InsertAsync(nvc,"Exceptions"); } private void app_PreRequestHandlerExecute(object sender, EventArgs e) { if(timer!=null) { timer.Dispose(); timer=null; } dtstart=DateTime.Now; timer=new System.Timers.Timer(10000); timer.Elapsed+=new System.Timers.ElapsedEventHandler(timer_Elapsed); timer.AutoReset=true; timer.Start(); } private void timer_Elapsed(object sender, System.Timers.ElapsedEventArgs e) { if(timer!=null) { TimeSpan ts=DateTime.Now-dtstart; NameValueCollection nvc=new NameValueCollection(); HttpRequest request=Context.Request; nvc.Add("SERVER_NAME" ,request.ServerVariables["SERVER_NAME"]); nvc.Add("UserHostAddress" ,request.UserHostAddress); nvc.Add("Path" ,request.Path); nvc.Add("QueryString" ,request.ServerVariables["QUERY_STRING"]); nvc.Add("UserName",Context.User.Identity.Name); nvc.Add("Category","Handler"); nvc.Add("Message",">"+ts.TotalSeconds.ToString()); InsertAsync(nvc,"Logs"); } } private void app_PostRequestHandlerExecute(object sender, EventArgs e) { if(timer!=null) { timer.Dispose(); timer=null; } } static void InsertAsync(NameValueCollection nvc,string tablename) { new Thread(new ThreadStart(new Job(nvc,tablename).Start)).Start(); } class Job { static void AddParameter(SqlCommand cmd,string pname,string value) { if(value==null) { value=""; } if(value.Length<4000) { cmd.Parameters.Add("@"+pname,SqlDbType.NVarChar,4000).Value=value; return; } cmd.Parameters.Add("@"+pname,SqlDbType.NText).Value=value; } static string _connstr; static SqlConnection CreateConnection() { if(_connstr==null)_connstr=ConfigurationSettings.AppSettings["AspNetMonitorConnectionString"]; return new SqlConnection(_connstr); } NameValueCollection n; string t; public Job(NameValueCollection nvc,string tablename) { n=nvc; t=tablename; } public void Start() { using(SqlConnection conn=CreateConnection()) { using(SqlCommand cmd=conn.CreateCommand()) { StringBuilder sb1=new StringBuilder(); StringBuilder sb2=new StringBuilder(); foreach(string key in n.Keys) { AddParameter(cmd,key,n[key]); if(sb1.Length!=0)sb1.Append(","); if(sb2.Length!=0)sb2.Append(","); sb1.Append(key); sb2.Append("@"); sb2.Append(key); } cmd.CommandText="INSERT INTO "+t+" ( "+sb1+" ) VALUES ( "+sb2+" ) "; conn.Open(); cmd.ExecuteNonQuery(); conn.Close(); } } } } } }

要应用这个例子，需要在 web.config/machine.config 里添加 IHttpModule 的注册。详细看 DotNet SDK 里的 httpModules 的配置节。

当然 appSettings 也要注册连接字符串。

打印 | 张贴于 2004-06-03 09:45:00 | Tag:DotNet  AspNet