[EntLib]微软企业库5.0 学习之路——第三步、为项目加上异常处理(采用自定义扩展方式记录到数据库中)

本文涉及的产品
密钥管理服务KMS,1000个密钥,100个凭据,1个月
日志服务 SLS,月写入数据量 50GB 1个月
简介:

     在前一篇文章:[EntLib]微软企业库5.0 学习之路——第二步、使用VS2010+Data Access模块建立多数据库项目中我们搭建好了项目的整体多数据库环境,实现了项目的多数据库访问,而整个项目中最主要的异常处理却没有进行部署,今天我们就使用企业库中的Exception Handling+Logging模块为项目加上异常处理以及异常日志记录。

(注:关于Exception Handling和Logging模块的相关基本概念可以查看TerryLee的异常处理日志检测这2篇文章)

     首先说一下企业库Logging模块的个人感觉,个人感觉企业库的日志记录太繁琐了,而且要自定义也比较烦,无法通过简单的配置达到我自己的要求,企业库中的日志记录模块在可以记录许多信息如下:

Timestamp: 2010-6-12 3:16:39

Message: HandlingInstanceID: 669fed01-a758-434b-896e-a8e25ebf8c9b 
An exception of type 'System.Exception' occurred and was caught. 
---------------------------------------------------------------- 
06/12/2010 11:16:39 
Type : System.Exception, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089 
Message : Test 
Source : EntLibStudy.Helper 
Help link : 
Data : System.Collections.ListDictionaryInternal 
TargetSite : System.String Test() 
Stack Trace :    在 EntLibStudy.Helper.BasePage.Test() 位置 F:\EntLibStudy\Helper\BasePage.cs:行号 87 
   在 EntLibStudy.Helper.BasePage.<Page_Load>b__0() 位置 F:\EntLibStudy\Helper\BasePage.cs:行号 81 
   在 Microsoft.Practices.EnterpriseLibrary.ExceptionHandling.ExceptionManagerImpl.Process[TResult](Func`1 action, TResult defaultResult, String policyName) 位置

以下省略N行。。。。。。

这些信息很多都不是我想要的,我想要的仅仅是异常的提示信息,异常发生的时间,以及异常发生的位置,好方便我们第一时间到异常发生的源头进行调试检查(可能企业库的这些异常信息更加有用,但是我个人认为很多时候都会干扰我们),所以我们仅仅需要其中的几条有用的信息就够了,比如Message,Timestamp、Stack Trace和Severity这4个就基本上够用了,所以我做了个处理,就是使用企业库中Logging模块提供的自定义CustomerTraceListener来实现我们需要的功能。

首先建立一个异常日志记录表(SQLite版)

1
2
3
4
5
6
7
CREATE  TABLE  [ExceptionLog] (
     [Id] integer  PRIMARY  KEY  AUTOINCREMENT NOT  NULL ,
     [Message] nvarchar(1024) NOT  NULL ,
     [LogDate] nvarchar(1024) NOT  NULL ,
     [ExceptionLevel] nvarchar(32) NOT  NULL ,
     [Exception] ntext NOT  NULL
)

我编写了一个类继承自CustomTraceListener,并重写了记录方法,具体代码如下:

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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
using  System;
using  System.Collections.Generic;
using  System.Data;
using  System.Data.Common;
using  System.Diagnostics;
using  System.Globalization;
using  System.Linq;
using  System.Text;
 
using  Microsoft.Practices.EnterpriseLibrary.Common.Configuration;
using  Microsoft.Practices.EnterpriseLibrary.Data;
using  Microsoft.Practices.EnterpriseLibrary.Logging;
using  Microsoft.Practices.EnterpriseLibrary.Logging.Configuration;
using  Microsoft.Practices.EnterpriseLibrary.Logging.Formatters;
using  Microsoft.Practices.EnterpriseLibrary.Logging.TraceListeners;
 
namespace  EntLibStudy.Helper.EntLibExtension.ExceptionExtension
{
     [ConfigurationElementType( typeof (CustomTraceListenerData))]
     public  class  ExceptionCustomerListener : CustomTraceListener
     {
         string  writeLogSQL = String.Empty;
         Database database;
         Exception ex;
 
         public  ExceptionCustomerListener()
             : base ()
         {
             database = DBHelper.CreateDataBase();
         }
 
         public  override  void  TraceData(TraceEventCache eventCache, string  source,
             TraceEventType eventType, int  id, object  data)
         {
             if  (( this .Filter == null ) || this .Filter.ShouldTrace(eventCache, source, eventType, id, null , null , data, null ))
             {
                 if  (data is  LogEntry)
                 {
                     LogEntry logEntry = data as  LogEntry;
                     ExecuteSQL(logEntry);
                 }
                 else  if  (data is  string )
                 {
                     Write(data as  string );
                 }
                 else
                 {
                     base .TraceData(eventCache, source, eventType, id, data);
                 }
             }
         }
 
         public  override  void  Write( string  message)
         {
             ExecuteWriteLogSQL(TraceEventType.Information, DateTime.Now, message, database);
         }
 
         public  override  void  WriteLine( string  message)
         {
             Write(message);
         }
 
         /// <summary>
         ///执行SQL
         /// </summary>
         /// <param name="logEntry">日志对象</param>
         private  void  ExecuteSQL(LogEntry logEntry)
         {
             using  (DbConnection connection = database.CreateConnection())
             {
                 try
                 {
                     connection.Open();
                     using  (DbTransaction transaction = connection.BeginTransaction())
                     {
                         try
                         {
                             ExecuteWriteLogSQL(logEntry, database, transaction);
                             transaction.Commit();
                         }
                         catch
                         {
                             transaction.Rollback();
                             throw ;
                         }
                     }
                 }
                 finally
                 {
                     connection.Close();
                 }
             }
         }
 
         /// <summary>
         /// 执行写入日志数据库语句
         /// </summary>
         /// <param name="severity">异常等级</param>
         /// <param name="message">消息</param>
         /// <param name="db">保存日志的数据库实例</param>
         private  void  ExecuteWriteLogSQL(TraceEventType severity, DateTime timeStamp, string  message, Database db)
         {
             writeLogSQL = ( string ) this .Attributes[ "writeLogSQL" ];
             DbCommand cmd = db.GetSqlStringCommand(writeLogSQL);
             string  exceptionMessage = Utils.GetBetweenString(message, "Message :" , "Source :" , 9);
             string  exceptionInfo = Utils.GetBetweenString(message, "Stack Trace :" , "Additional Info:" , 13);
             db.AddInParameter(cmd, "@Message" , DbType.String, exceptionMessage);
             db.AddInParameter(cmd, "@LogDate" , DbType.DateTime, timeStamp);
             db.AddInParameter(cmd, "@Level" , DbType.String, message);
             db.AddInParameter(cmd, "@Exception" , DbType.String, exceptionInfo);
             db.ExecuteNonQuery(cmd);
         }
 
         /// <summary>
         /// 执行写入日志数据库语句
         /// </summary>
         /// <param name="logEntry">日志对象</param>
         /// <param name="db">保存日志的数据库实例</param>
         /// <param name="transaction">事务对象</param>
         private  void  ExecuteWriteLogSQL(LogEntry logEntry, Database db, DbTransaction transaction)
         {
             writeLogSQL = ( string ) this .Attributes[ "writeLogSQL" ];
             DbCommand cmd = db.GetSqlStringCommand(writeLogSQL);
             string  exceptionMessage = Utils.GetBetweenString(logEntry.Message, "Message :" , "Source :" , 9);
             string  exceptionInfo = Utils.GetBetweenString(logEntry.Message, "Stack Trace :" , "Additional Info:" , 13);
             db.AddInParameter(cmd, "@Message" , DbType.String, exceptionMessage);
             db.AddInParameter(cmd, "@LogDate" , DbType.DateTime, logEntry.TimeStamp.ToLocalTime());
             db.AddInParameter(cmd, "@Level" , DbType.String, logEntry.LoggedSeverity);
             db.AddInParameter(cmd, "@Exception" , DbType.String, exceptionInfo);
             db.ExecuteNonQuery(cmd, transaction);
         }
     }
}

其中在类的初始化的时候获取配置文件的默认数据库对象,通过重写TraceData方法来调用ExecuteSQL方法来执行异常日志插入。

在ExecuteWriteLogSQL方法中有句代码:

1
writeLogSQL = ( string ) this .Attributes[ "writeLogSQL" ];

这个代码就是从配置文件中Listener的Attributes中获取所配置的执行SQL语句(这里不同于Logging模块自带的数据库以存储过程的记录方式,而是使用配置的SQL语句的方式,因为本项目是面向多数据库的,并不是所有的数据库都有存储过程的,比如SQLite),下面看下具体的配置信息:

pic14

配置文件创建主要分为以下2步:

1、在企业库的配置工具添加一个Exception Handle模块,然后添加一个名为Exception Policy的策略,再为这个策略添加异常类型,默认我选择所有异常类型(All Exceptions),Post Handle Action为: NotifyRethow(对不理解Post Handle Action的处理方式的可以看下下面的解释)

PostHandlingAction 决定了在异常处理链完成后将发生什么活动。默认情况下,PostHandlingAction 被设置为 NotifyRethrow 。 
None:应用程序块为此异常执行所有的处理程序,然后在 HandleException 方法的调用点上返回 false 给应用程序。应用程序检查此值以继续运行。 
NotifyRethrow:应用程序块为此异常执行所有的处理程序,然后在 HandleException 方法的调用点上返回 true 给应用程序。应用程序检查到此值就重新抛出原始异常。 
ThrowNewException:应用程序块为此异常执行所有的处理程序,然后在所有处理程序运行后抛出存在的异常。

2、为异常策略创建处理方式,我这边选择Loggin Exception Handler(在创建的同时配置工具会我们自动创建好Logging模块,并自动创建了一个日志分类:General,不过这个日志分类的默认Listener为event log,就是记录到系统的事件中),这时我们再创建一个CustomerTraceListener选择From File->自定义Listener所在DLL。

这边我碰到了一个问题就是添加了CustomerTraceListener,在对话框中我点击From File选择我编写的自定义Listener所在DLL,可惜没任何反应,不知道是不是要在DLL中做什么处理,所以我只能采用老办法:手写配置文件

首先看下Exception Handle模块的配置信息:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
<exceptionHandling>
     <exceptionPolicies>
       <add name="ExceptionPolicy">
         <exceptionTypes>
           <add name="All Exceptions" type="System.Exception, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"
             postHandlingAction="NotifyRethrow">
             <exceptionHandlers>
               <add name="Logging Exception Handler" type="Microsoft.Practices.EnterpriseLibrary.ExceptionHandling.Logging.LoggingExceptionHandler, Microsoft.Practices.EnterpriseLibrary.ExceptionHandling.Logging, Version=5.0.414.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35"
                 logCategory="General" eventId="100" severity="Error" title="Enterprise Library Exception Handling"
                 formatterType="Microsoft.Practices.EnterpriseLibrary.ExceptionHandling.TextExceptionFormatter, Microsoft.Practices.EnterpriseLibrary.ExceptionHandling"
                 priority="0" />
             </exceptionHandlers>
           </add>
         </exceptionTypes>
       </add>
     </exceptionPolicies>
   </exceptionHandling>

接下来是日志模块配置,在日志模块下我配置了3个Listener,其中Custom Trace Listener为我自定义的异常日志记录,Event Log Listener(系统日志记录)Rolling Flat File Trace Listener(文本文件记录,按天回滚记录)为在日志分类General无法正常记录日志时的记录下日志分类General为何无法记录,因为异常日志默认保存到数据库中,但是如果数据库中存在问题,或者链接被关闭这时就无法正常记录异常,所以:

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
<loggingConfiguration name="" tracingEnabled="true" defaultCategory="General">
     <listeners>
       <add listenerDataType="Microsoft.Practices.EnterpriseLibrary.Logging.Configuration.CustomTraceListenerData, Microsoft.Practices.EnterpriseLibrary.Logging"
         writeLogSQL="insert into ExceptionLog(Message,LogDate,ExceptionLevel,Exception) values(@Message,@LogDate,@Level,@Exception)"
         type="EntLibStudy.Helper.EntLibExtension.ExceptionExtension.ExceptionCustomerListener, EntLibStudy.Helper, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null"
         traceOutputOptions="None" name="Custom Trace Listener" initializeData=""
         formatter="Text Formatter" />
       <add name="Event Log Listener" type="Microsoft.Practices.EnterpriseLibrary.Logging.TraceListeners.FormattedEventLogTraceListener, Microsoft.Practices.EnterpriseLibrary.Logging, Version=5.0.414.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35"
         listenerDataType="Microsoft.Practices.EnterpriseLibrary.Logging.Configuration.FormattedEventLogTraceListenerData, Microsoft.Practices.EnterpriseLibrary.Logging, Version=5.0.414.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35"
         source="Enterprise Library Logging" formatter="Text Formatter"
         log="" machineName="." traceOutputOptions="None" />
       <add name="Rolling Flat File Trace Listener" type="Microsoft.Practices.EnterpriseLibrary.Logging.TraceListeners.RollingFlatFileTraceListener, Microsoft.Practices.EnterpriseLibrary.Logging, Version=5.0.414.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35"
         listenerDataType="Microsoft.Practices.EnterpriseLibrary.Logging.Configuration.RollingFlatFileTraceListenerData, Microsoft.Practices.EnterpriseLibrary.Logging, Version=5.0.414.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35"
         fileName="rolling.log" formatter="Text Formatter" rollInterval="Day" />
     </listeners>
     <formatters>
       <add type="Microsoft.Practices.EnterpriseLibrary.Logging.Formatters.TextFormatter, Microsoft.Practices.EnterpriseLibrary.Logging, Version=5.0.414.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35"
         template="Timestamp: {timestamp}{newline}&#xA;Message: {message}{newline}&#xA;Category: {category}{newline}&#xA;Priority: {priority}{newline}&#xA;EventId: {eventid}{newline}&#xA;Severity: {severity}{newline}&#xA;Title:{title}{newline}&#xA;Machine: {localMachine}{newline}&#xA;App Domain: {localAppDomain}{newline}&#xA;ProcessId: {localProcessId}{newline}&#xA;Process Name: {localProcessName}{newline}&#xA;Thread Name: {threadName}{newline}&#xA;Win32 ThreadId:{win32ThreadId}{newline}&#xA;Extended Properties: {dictionary({key} - {value}{newline})}"
         name="Text Formatter" />
     </formatters>
     <categorySources>
       <add switchValue="All" name="General">
         <listeners>
           <add name="Custom Trace Listener" />
         </listeners>
       </add>
     </categorySources>
     <specialSources>
       <allEvents switchValue="All" name="All Events" />
       <notProcessed switchValue="All" name="Unprocessed Category" />
       <errors switchValue="All" name="Logging Errors &amp; Warnings">
         <listeners>
           <add name="Event Log Listener" />
           <add name="Rolling Flat File Trace Listener" />
         </listeners>
       </errors>
     </specialSources>
   </loggingConfiguration>

在配置完后我们就可以进行代码编写,在页面里进行异常控制。

在ASP.NET中,异常处理主要有4种,执行顺序为:Page_Error事件>ErrorPage属性>Application_Error事件> <customErrors>,我这边采用Page_Error,由于在本项目中我已经建立了BasePage,所有的页面都继承这个页面,所以我只需在这个页面中编写Page_Error事件:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
protected  void  Page_Error( object  sender, EventArgs e)
         {
             //获取最新的异常信息
             var  ex = Server.GetLastError();
             //处理异常
             HandleException(ex, "ExceptionPolicy" );
             //清空异常
             Server.ClearError();
         }
         /// <summary>
         /// 异常处理方法
         /// </summary>
         /// <param name="ex">异常信息</param>
         /// <param name="policy">异常处理策略</param>
         protected  void  HandleException(Exception ex, string  policy)
         {
             bool  rethrow = false ;
             var  exManager = EnterpriseLibraryContainer.Current.GetInstance<ExceptionManager>();
             rethrow = exManager.HandleException(ex, policy);
             if  (rethrow)
             {
                 this .RedirectPermanent( "~/error.aspx" );
             }
         }

其中exManager.HandleException(ex, policy)为根据策略名处理异常,我这边使用的ExceptionPolicy,这个策略的处理方式为异常日志记录,它会帮我们调用到我们自定义的ExceptionCustomerListener 类,进行异常日志记录。

这样我们就完成了统一捕获系统中发生的异常了,本文也到此结束,欢迎大家指点!

 

--------------------------------文章扩展分割线-----------------------------------------------

当然企业库中的Exception Handle和Logging模块远不止这些,Exception Handle还提供了异常替换(将指定的异常替换成其他的异常信息),异常包装(将一个异常包装到另外一个异常当中)

Logging模块提供了许多的记录方式,如文本,XML,邮件,消息队列等等,所以我们可以根据我们的需求自由的选择。

本文仅仅就我的实际项目需求进行了简单的扩展,所以可能还有许多的不足,大家可根据自己的需求进行研究扩展,如果大家有好的异常记录处理办法可以提出来让我借鉴下。:)

 

PS:我在文中提到了企业库的Logging模块太繁琐,大家可以看下我的使用log4net完成程序异常日志记录(使用SQLite数据库记录和普通文本记录)这篇文章,如果仅仅是要进行系统的异常记录的话log4net是个不错的选择,配置又方便而且也轻便,单若想完整使用企业库的功能的话就还是使用Exception Handle+Logging这个组合了。

注意:

1、MSSQL数据库在DataBase目录下(需要自行附加数据库),SQLite数据库在Web目录的App_Data下,由于考虑到项目的大小,所以每个项目的BIN目录都已经删除,如出现无法生成项目请自行添加相关企业库的DLL。

2、由于微软企业库5.0 学习之路这个系列我是准备以一个小型项目的形式介绍企业库的各模块,所以源代码会根据系列文章的更新而更新,所以源代码不能保证与文章中所贴代码相同。

3、项目开发环境为:VS2010+SQL2005。

4、管理员帐户:admin

              密码:admin

源代码下载地址:点我下载

 

微软企业库5.0 学习之路系列文章索引:

第一步、基本入门

第二步、使用VS2010+Data Access模块建立多数据库项目

第三步、为项目加上异常处理(采用自定义扩展方式记录到数据库中) 

第四步、使用缓存提高网站的性能(EntLib Caching)

第五步、介绍EntLib.Validation模块信息、验证器的实现层级及内置的各种验证器的使用方法——上篇

第五步、介绍EntLib.Validation模块信息、验证器的实现层级及内置的各种验证器的使用方法——中篇 

第五步、介绍EntLib.Validation模块信息、验证器的实现层级及内置的各种验证器的使用方法——下篇

第六步、使用Validation模块进行服务器端数据验证

第七步、Cryptographer加密模块简单分析、自定义加密接口及使用—上篇

第七步、Cryptographer加密模块简单分析、自定义加密接口及使用—下篇

第八步、使用Configuration Setting模块等多种方式分类管理企业库配置信息

第九步、使用PolicyInjection模块进行AOP—PART1——基本使用介绍

第九步、使用PolicyInjection模块进行AOP—PART2——自定义Matching Rule

第九步、使用PolicyInjection模块进行AOP—PART3——内置Call Handler介绍

第九步、使用PolicyInjection模块进行AOP—PART4——建立自定义Call Handler实现用户操作日志记录 

第十步、使用Unity解耦你的系统—PART1——为什么要使用Unity?

第十步、使用Unity解耦你的系统—PART2——了解Unity的使用方法(1)

第十步、使用Unity解耦你的系统—PART2——了解Unity的使用方法(2)

第十步、使用Unity解耦你的系统—PART2——了解Unity的使用方法(3)

第十步、使用Unity解耦你的系统—PART3——依赖注入

第十步、使用Unity解耦你的系统—PART4——Unity&PIAB

扩展学习:

扩展学习篇、库中的依赖关系注入(重构 Microsoft Enterprise Library)[转]

 


本文转自kyo-yo博客园博客,原文链接:http://www.cnblogs.com/kyo-yo/archive/2010/06/17/Learning-EntLib-Third.html,如需转载请自行联系原作者


目录
相关文章
|
1月前
|
存储 关系型数据库 MySQL
一个项目用5款数据库?MySQL、PostgreSQL、ClickHouse、MongoDB区别,适用场景
一个项目用5款数据库?MySQL、PostgreSQL、ClickHouse、MongoDB——特点、性能、扩展性、安全性、适用场景比较
|
7天前
|
Java 数据库连接 数据库
如何构建高效稳定的Java数据库连接池,涵盖连接池配置、并发控制和异常处理等方面
本文介绍了如何构建高效稳定的Java数据库连接池,涵盖连接池配置、并发控制和异常处理等方面。通过合理配置初始连接数、最大连接数和空闲连接超时时间,确保系统性能和稳定性。文章还探讨了同步阻塞、异步回调和信号量等并发控制策略,并提供了异常处理的最佳实践。最后,给出了一个简单的连接池示例代码,并推荐使用成熟的连接池框架(如HikariCP、C3P0)以简化开发。
20 2
|
15天前
|
SQL JavaScript 关系型数据库
node博客小项目:接口开发、连接mysql数据库
【10月更文挑战第14天】node博客小项目:接口开发、连接mysql数据库
|
27天前
|
SQL 关系型数据库 MySQL
Go语言项目高效对接SQL数据库:实践技巧与方法
在Go语言项目中,与SQL数据库进行对接是一项基础且重要的任务
47 11
|
22天前
|
存储 关系型数据库 MySQL
PACS系统 中 dicom 文件在mysql 8.0 数据库中的 存储和读取(pydicom 库使用)
PACS系统 中 dicom 文件在mysql 8.0 数据库中的 存储和读取(pydicom 库使用)
18 2
|
23天前
|
SQL NoSQL 关系型数据库
数据库学习
【10月更文挑战第8天】
19 1
|
24天前
|
关系型数据库 MySQL Java
Django学习二:配置mysql,创建model实例,自动创建数据库表,对mysql数据库表已经创建好的进行直接操作和实验。
这篇文章是关于如何使用Django框架配置MySQL数据库,创建模型实例,并自动或手动创建数据库表,以及对这些表进行操作的详细教程。
54 0
Django学习二:配置mysql,创建model实例,自动创建数据库表,对mysql数据库表已经创建好的进行直接操作和实验。
|
25天前
|
Java 关系型数据库 MySQL
springboot学习五:springboot整合Mybatis 连接 mysql数据库
这篇文章是关于如何使用Spring Boot整合MyBatis来连接MySQL数据库,并进行基本的增删改查操作的教程。
40 0
springboot学习五:springboot整合Mybatis 连接 mysql数据库
|
25天前
|
Java 关系型数据库 MySQL
springboot学习四:springboot链接mysql数据库,使用JdbcTemplate 操作mysql
这篇文章是关于如何使用Spring Boot框架通过JdbcTemplate操作MySQL数据库的教程。
19 0
springboot学习四:springboot链接mysql数据库,使用JdbcTemplate 操作mysql
|
28天前
|
关系型数据库 MySQL 数据库
mysql关系型数据库的学习
mysql关系型数据库的学习
17 0

热门文章

最新文章