如何解决EnterLib异常处理框架最大的局限——基于异常类型的异常处理策略

坪钗 · 2025-5-29 19:27:32

个人觉得EnterLib的EHAB（Exception Handling Application Block）是一个不错的异常处理框架，借助于EHAB，我们可以配置的方式来自定义异常处理策略，从而带来最大的灵活性和可维护性。但是，在我看来，EHAB有一个最大的局限，把就是异常处理策略的粒度过大——只能提供基于异常类型级别。本篇文章通过一个自定义ExceptionHandler很好地解决了这个问题。
  一、EnterLib基于异常类型的异常处理策略

  EnterLib的异常处理策略基本上可以通过这样的的公式来表示：Exception Policy = Exception Type + Exception Handlers + Post Handling Action，它表达的意思是：“对于某种类型的异常，应该采用哪些Exception Handler去处理，而被处理后的异常还需要采用怎样的后续操作（将异常吃掉、或者是重新抛出）”。
  也就是说，抛出类型的异常类型决定了最终采取的处理策略，这在大部分情况下是可以接受的。但是在很多场景中，不同情况下也可以抛出相同类型的异常，我们期望的行为是：尽管异常类型一样，我们也可以根据具体抛出的异常定义不同的异常处理策略。
  一个最为典型的场景就是基于数据库的数据存取，如果你采用的SQL Server，抛出的异常永远只有一种：SqlException。如果完全按照EnterLib EHAB的做法，在任何情况下抛出的SqlException对应的处理方式都是一样的。但是抛出SqlException的情况非常多，比如Server连接断开、认证失败、数据库对象不存在、违反一致性约束等等，如果异常处理框架能够根据最终抛出的异常的具体属性，“智能”地应用相应的策略去处理，这才是我们乐于看到的。
  二、一个特殊的ExceptionHandler——FilterableHandler
  为了解决这个问题，我创建了一个特殊的Exception Handler，我将它起名为FilterableHandler。说它特别，是因为FilterableHandler并不从事具体的异常处理操作（比如异常封装、替换、日志等），而是为某个具体的异常类型重新定义了异常处理策略。
  实际上，我在很早之前就定义了一个相似的FilterableHandler，有兴趣的话可以参考《创建一个自定义Exception Handler改变ELAB的异常处理机制》。由于在最新的EnterLib中，底层的实现机制发生了根本性的改变，这个ExceptionHandler已经不能在使用。所以我对其进行的了修正，同时根据可扩展性进行重新设计。
  之所以称这个ExceptionHandler为FilterableHandler，是在于它具有对抛出的异常具有“筛选”的功能。说得具体点，FilterableHandler将抛出的异常对象，传入一组具有筛选功能的ExceptionHandler列表，我个人将这个列表命名为FiterableExceptionHandlerPipeline。FiterableExceptionHandlerPipeline对象包含一个筛选器和一组ExceptionHandler，如果传入的异常通过了筛选器的筛选，该异常最终被分发到相应的ExceptionHandler列表中进行处理。FiterableExceptionHandlerPipeline大概的定义如下：

1: <?xml version="1.0" encoding="utf-8" ?>public class FilterableHandlerPipeline

复制代码

2: <configuration>{

复制代码

3: public IFilter Filter { get; private set; }

复制代码

4: <exceptionHandling>public IEnumerable<IExceptionHandler> ExceptionHandlers { get; private set; }

复制代码

5:

复制代码

6: <filters> public FilterableHandlerPipeline(IFilter filter, IEnumerable<IExceptionHandler> exceptionHandlers)

复制代码

7: {

复制代码

8: <exceptionHandlers> Guard.ArgumentNotNull(filter, "filter");

复制代码

9: Guard.ArgumentNotNull(exceptionHandlers, "exceptionHandlers");

复制代码

10: this.Filter = filter;

复制代码

11: this.ExceptionHandlers = exceptionHandlers;

复制代码

12: }

复制代码

13: }

复制代码

而IFilter接口在更为简单，仅仅具有如下一个唯一的Match方法。布尔类型的返回值表明是否和指定的异常相匹配，当返回值为True的时候，FiterableExceptionHandlerPipeline采用用自己的ExceptionHandler列表去处理抛出的异常，否则就直接忽略掉。

1: <?xml version="1.0" encoding="utf-8" ?>public interface IFilter

复制代码

2: <configuration>{

复制代码

3: bool Match(Exception ex);

复制代码

4: }

复制代码

你可以从下面给出的关于FilterableHandler的完整的代码去分析具体的异常处理实现原理。而实际上，最为复杂的不是FilterableHandler本身的实现，而是与之相关的配置元素的定义。由于这会涉及到很多关于EnterLib底层和Unity相关的知识点，不是三言两语就能讲明白的，所以在这里就不对FilterableHandler的配置体系作介绍了，有兴趣的话可以通过这里直接下载源代码。

1: <?xml version="1.0" encoding="utf-8" ?>[ConfigurationElementType(typeof(FilterableHandlerData))]

复制代码

2: <configuration>public class FilterableHandler:IExceptionHandler

复制代码

3: {

复制代码

4: <exceptionHandling>public IEnumerable<FilterableHandlerPipeline> FilterableHandlerPipelines { get; private set; }

复制代码

5: </default> public IEnumerable<IExceptionHandler> DefaultHandlers { get; private set; }

复制代码

6:

复制代码

7: public FilterableHandler(IEnumerable<FilterableHandlerPipeline> filterableHandlerPipelines, IEnumerable<IExceptionHandler> defaultHandlers)

复制代码

8: {

复制代码

9: Guard.ArgumentNotNull(defaultHandlers, "defaultHandlers");

复制代码

10: filterableHandlerPipelines = filterableHandlerPipelines ?? new List<FilterableHandlerPipeline>();

复制代码

11: this.FilterableHandlerPipelines = filterableHandlerPipelines;

复制代码

12: </exceptionHandlers> this.DefaultHandlers = defaultHandlers;

复制代码

13: </add>}

复制代码

14: public Exception HandleException(Exception exception, Guid handlingInstanceId)

复制代码

15: {

复制代码

16: <exceptionHandlers> Guard.ArgumentNotNull(exception,"exception");

复制代码

17: var handlerPipeline = (from pipeline in this.FilterableHandlerPipelines

复制代码

18: <filters> where pipeline.Filter.Match(exception)

复制代码

19: select pipeline).FirstOrDefault();

复制代码

20: </exceptionHandlers> if (null != handlerPipeline)

复制代码

21: </add> {

复制代码

22: </filters> return ExecuteHandlerChain(exception, handlingInstanceId, handlerPipeline.ExceptionHandlers);

复制代码

23: </add> }

复制代码

24: else

复制代码

25: {

复制代码

26: return ExecuteHandlerChain(exception, handlingInstanceId, DefaultHandlers);

复制代码

27: }

复制代码

28: }

复制代码

29:

复制代码

30: private static Exception ExecuteHandlerChain(Exception exception, Guid handlingInstanceId, IEnumerable<IExceptionHandler> handlers)

复制代码

31: {

复制代码

32: var lastHandlerName = String.Empty;

复制代码

33: try

复制代码

34: {

复制代码

35: foreach (var handler in handlers)

复制代码

36: {

复制代码

37: lastHandlerName = handler.GetType().Name;

复制代码

38: exception = handler.HandleException(exception, handlingInstanceId);

复制代码

39: }

复制代码

40: }

复制代码

41: catch (Exception ex)

复制代码

42: </exceptionPolicies>{

复制代码

43: </exceptionHandling> var errorMsg = string.Format("Unable to handle the exception: {0}", lastHandlerName);

复制代码

44: </configuration> throw new ExceptionHandlingException(errorMsg, ex);

复制代码

45: }

复制代码

46: return exception;

复制代码

47: }

复制代码

48: }

复制代码

三、通过FilterableHandler对SqlException进行针对性处理
我现在通过一个简单的例子来演示FilterableHandler如何使用（源代码从这里下载），我们使用的场景就是上面提到过的对SqlException的针对性处理。根据SqlException抛出的场景，本例将起分为三种类型：

系统异常：基于SQL Server自身抛出的异常，我们将异常编号，即SqlException的Number小于50000的称为系统异常；
业务异常：编程人员根在编写SQL脚本的时候，根据相应的业务逻辑，通过调用RAISERROR语句手工抛出的异常。在默认情况下这种异常的编号为50000；
其他：任何编号高于50000的异常。

注：关于RAIERROR语句以及SQL Server异常处理相关的内容，你可以参阅我下面三篇文章：
谈谈基于SQL Server的Exception Handling - PART I
谈谈基于SQL Server 的Exception Handling - PART II
谈谈基于SQL Server 的Exception Handling - PART III
为了对SqlException进行针对处理，我们对抛出的SqlException进行封装。对应于上述三种类型，我定义如如下三种异常：SqlSystemException、SqlBusinessException和DbException。

1: <?xml version="1.0" encoding="utf-8" ?>namespace Artech.ExceptionHandling.Demo

复制代码

2: <configuration>{

复制代码

3: [Serializable]

复制代码

4: <exceptionHandling>public class SqlSystemException : Exception

复制代码

5: </default> {

复制代码

6: <filters> public SqlSystemException() { }

复制代码

7: public SqlSystemException(string message) : base(message) { }

复制代码

8: <exceptionHandlers> public SqlSystemException(string message, Exception inner) : base(message, inner) { }

复制代码

9: protected SqlSystemException(

复制代码

10: System.Runtime.Serialization.SerializationInfo info,

复制代码

11: System.Runtime.Serialization.StreamingContext context)

复制代码

12: </exceptionHandlers> : base(info, context) { }

复制代码

13: </add>}

复制代码

14:

复制代码

15: [Serializable]

复制代码

16: public class SqlBusinessException : Exception

复制代码

17: {

复制代码

18: public SqlBusinessException() { }

复制代码

19: public SqlBusinessException(string message) : base(message) { }

复制代码

20: </exceptionHandlers> public SqlBusinessException(string message, Exception inner) : base(message, inner) { }

复制代码

21: </add> protected SqlBusinessException(

复制代码

22: </filters> System.Runtime.Serialization.SerializationInfo info,

复制代码

23: </add> System.Runtime.Serialization.StreamingContext context)

复制代码

24: : base(info, context) { }

复制代码

25: }

复制代码

26:

复制代码

27: [Serializable]

复制代码

28: public class DbException : Exception

复制代码

29: {

复制代码

30: public DbException() { }

复制代码

31: public DbException(string message) : base(message) { }

复制代码

32: public DbException(string message, Exception inner) : base(message, inner) { }

复制代码

33: protected DbException(

复制代码

34: System.Runtime.Serialization.SerializationInfo info,

复制代码

35: System.Runtime.Serialization.StreamingContext context)

复制代码

36: : base(info, context) { }

复制代码

37: }

复制代码

38: }

复制代码

我们需要作的进行通过配置定义处理SqlException的处理策略，整个配置定义在如下的代码片断中。

1: <?xml version="1.0" encoding="utf-8" ?>

复制代码

2: <configuration>

复制代码

3: ... ...

复制代码

4: <exceptionHandling>

复制代码

5: </default> <exceptionPolicies>

复制代码

6: <filters>

复制代码

7: <exceptionTypes>

复制代码

8: <exceptionHandlers>

复制代码

11: <exceptionHandlers>

复制代码

12: </exceptionHandlers>

复制代码

13: </add> <default>

复制代码

14:

复制代码

17: </default>

复制代码

18: <filters>

复制代码

19:

复制代码

21: </add> <exceptionHandlers>

复制代码

22: </filters>

复制代码

25: </exceptionHandlers>

复制代码

26: </add>

复制代码

27:

复制代码

29: <exceptionHandlers>

复制代码

30:

复制代码

34: </exceptionHandlers>

复制代码

35: </add>

复制代码

36: </filters>

复制代码

37: </add>

复制代码

38: </exceptionHandlers>

复制代码

39: </add>

复制代码

40: </exceptionTypes>

复制代码

41: </add>

复制代码

42: </exceptionPolicies>

复制代码

43: </exceptionHandling>

复制代码

44: </configuration>

复制代码

虽然配置稍微复杂了一点，但是结构还算是很清楚的。我们将FilterableHandler作为处理SqlException的唯一的ExceptionHandler。而FilterableHandler整个配置包含如下两个部分和。自然就是定义的一组筛选分支，而则是定义了一个后备——如果抛出的异常满足所有的筛选分支，则通过定义在中的ExceptionHandler列表进行才处理。

1: <?xml version="1.0" encoding="utf-8" ?>

复制代码

2: <configuration>

复制代码

3:

复制代码

5: </default>

复制代码

6: <filters>

复制代码

7:

复制代码

8: <exceptionHandlers>

复制代码

9:

复制代码

12: </exceptionHandlers>

复制代码

13: </add>

复制代码

14:

复制代码

16: <exceptionHandlers>

复制代码

17:

复制代码

20: </exceptionHandlers>

复制代码

21: </add>

复制代码

22: </filters>

复制代码

23: </add>

复制代码

在中定义了两个FilterableHandlerPipeline：PropertyValueEquivalencePipeline和PropertyValueRangePipeline。PropertyValueEquivalencePipeline的筛选器根据抛出异常的某个属性的值是否等于指定的值进行筛选，而PropertyValueRangePipeline的筛选器则根据抛出异常的某个属性值是否在指定的范围内进行筛选。在这里用作筛选的属性名名称为Number，PropertyValueRangePipeline指定的上限为5000，upperRangeBoundType为“Exclusive”表示包含此上限，并且没有指定下限，所以这里的筛选逻辑就Number[/code]

1: private static void HandleException(Action task)

复制代码

4: <exceptionHandling> var connstring = "Server=.; Database=TestDb; Uid=sa; Pwd=invalidPwd";

复制代码

5: </default> <exceptionPolicies> var conection = new SqlConnection(connstring);

复制代码

6: <filters> conection.Open();

复制代码

5: try

复制代码

6: {

复制代码

7: task();

复制代码

8: }

复制代码

9: catch (SqlException ex)

复制代码

12: </exceptionHandlers> var connstring = "Server=.; Database=TestDb; Uid=sa; Pwd=password";

复制代码

13: </add> var conection = new SqlConnection(connstring);

复制代码

12: {

复制代码

13: throw;

复制代码

16: <exceptionHandlers> conection.Open();

复制代码

15: }

复制代码

16: }

复制代码

17: catch (Exception ex)

复制代码

18: {

复制代码

21: </add> () =>

复制代码

22: </filters> {

复制代码

23: </add> var connstring = "Server=.; Database=TestDb; Uid=sa; Pwd=password";

复制代码

1: HandleException(

复制代码

2: () =>

复制代码

3: {

复制代码

4: var connstring = "Server=.; Database=TestDb; Uid=sa; Pwd=invalidPwd";

复制代码

5: var conection = new SqlConnection(connstring);

复制代码

6: conection.Open();

复制代码

以下的输出和我们的预期完全一致：

1: <?xml version="1.0" encoding="utf-8" ?>Artech.ExceptionHandling.Demo.SqlSystemException

复制代码

2: <configuration>Artech.ExceptionHandling.Demo.SqlBusinessException

复制代码

9: HandleException(

复制代码

四、FiterableHandler的可扩展性
FilterableHandler的核心在于有一组具有不同筛选器的FiterableExceptionHandlerPipeline。我默认定义了两个基于属性比较的FiterableExceptionHandlerPipeline，即PropertyValueEquivalencePipeline和PropertyValueRangePipeline。实际上你可以通过继承FiterableExceptionHandlerPipeline基类，实现你自定义的筛选方式。

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

账号		自动登录	找回密码
密码			立即注册

如何解决EnterLib异常处理框架最大的局限——基于异常类型的异常处理策略

浏览过的版块

签约作者