.NET可逆框架设计
前段时间一直在学习和研究.NET事务处理,慢慢的我发现可以使用事务处理来实现一种可逆的系统框架。这种框架在一些IT社区似乎还没有见过,但是在我们日常开发中确实有这个需求。所以我花了点时间深入的研究了一下事务的原理和使用,实现了以事务为纽带,以资源为操作对象的可逆框架。[王清培版权所有,转载请给出署名]
这里我假设您对事务有了整体的认识,也对自定义事务管理器有过了解。
(可以参考本人的:.NET简谈事务本质论、.NET简谈自定义事务资源管理器)
1. 什么是可逆的程序框架
什么叫可逆的?程序的执行是可以被无限制回滚的。
什么叫可逆的框架?实现了对可逆功能的封装,并能通过简单的接口调用进行使用。框架可能有大有小,我想这么称呼它是为了表达它的整体性和重要性。
那么到底可逆的需求在哪里?其实在我们开发程序的时候经常会使用事务来进行业务的控制。比如删除订单,然后删除订单明细等等,对于这样的要求很多,我们只能将逻辑控制在一个事务范围内,不能在没有事务性的逻辑代码中编写这种要求的业务功能。等出现未知错误的时候在进行事务的回滚。[王清培版权所有,转载请给出署名]
你也许会问,使用原来的事务处理不是也能进行回滚吗?当然不是这么简单的,我们使用事务回滚时只能将资源回滚到最初未进行事务处理前的状态。(这里不仅仅指的是数据库事务,而是全局的事务处理) 我们用图做个比较。
传统的事务处理图:
可逆的事务处理图:
从这两幅图中我们可以很明显的看出,传统的事务处理在事务处理的过程当中无法控制中间数据,也就是说无法对事务处理进行分段,然后在进行统一的提交或回滚。[王清培版权所有,转载请给出署名]
在可逆框架的事务处理里我们就可以控制事务的执行阶段,在必要的时候我们只需提交或者回滚某一阶段的数据。
1.1环境事务
在可逆框架的事务处理图中,我们看到事务的开始,然后就进行下一步、下一步这样的操作。在每进行一个下一步操作的时候,就是进入到了一个子事务里处理,在.NET中是可以进行事务的嵌套,其实也就是依赖事务Dependent Transaction实现。通过使用环境事务可以让事务性感知代码能自动的识别出您将要使用事务进行操作。所以在每进行下一步操作的时候,只有将当前环境事务切换为您将依赖的子事务才行。如果只是单纯的使用依赖事务对象实例在使用,那么将无法进行诸多其他的事务处理。
2可逆框架的实现原理
由于我们只能控制自定义事务资源管理器的内部实现,所以我们在构建自己的数据处理时问题变的简单多了。
实现可逆框架的核心技术就是使用依赖事务进行事务的克隆操作。将一个大的事务处理逻辑上切割成多了小的事务操作,然后在进行统一的提交或回滚。
在实现上其实就是将Committable Transaction对象进行包装,实现简单的调用接口。这里参照了环境代码的概念,将对象的生命周期控制在代码片段中。
2.1自定义资源管理器的实现
我们需要扩展IEnlistmentNotification接口的实现,加入对“上一步”、“下一步”的数据操作。
请看代码:
1. /***
2. * author:深度训练
3. * blog:http://wangqingpei557.blog.51cto.com/
4. * **/
5. using System;
6. using System.Collections.Generic;
7. using System.Text;
8. using System.Transactions;
9.
10. namespace ReversibleLib
11. {
12. /// <summary>
13. /// 可逆范围内的资源管理器。
14. /// 可以使用该类对易失性资源进行事务范围内的管理。在事务操作范围内进行可逆操作。
15. /// </summary>
16. /// <typeparam name="T">需要管理的资源类型</typeparam>
17. /// <typeparam name="Xcopy">资源在使用、恢复过程中的数据复制对象。</typeparam>
18. public class ReResourceManager<T, Xcopy> : IEnlistmentNotification, IReversibleGetResourceData<T>
19. where T : class, new()
20. where Xcopy : class
21. {
22. /// <summary>
23. /// 私有字段。资源的持久引用。
24. /// </summary>
25. T _commitfrontvalue;
26. /// <summary>
27. /// 私有字段。事务性操作数据对象。
28. /// </summary>
29. T _rollbackfrontvalue = new T();
30. /// <summary>
31. /// 保存数据复制对象。
32. /// </summary>
33. Xcopy _copy;
34. /// <summary>
35. /// 泛型约束需要,内部使用。
36. /// </summary>
37. public ReResourceManager() { }
38. /// <summary>
39. /// 资源管理器内部名称。便于追踪
40. /// </summary>
41. public string Name { get; set; }
42. /// <summary>
43. /// 重载默认构造函数,使用资源类型和数据复制对象初始化资源管理器。
44. /// </summary>
45. public ReResourceManager(T t, Xcopy icopy)
46. {
47. (icopy as IResourceCopy<T>).Copy(_rollbackfrontvalue, t);
48. _commitfrontvalue = t;
49. _copy = icopy;
50. }
51.
52. #region IEnlistmentNotification 成员
53. public void Prepare(PreparingEnlistment preparingEnlistment)
54. {
55. preparingEnlistment.Prepared();
56. }
57. public void Commit(Enlistment enlistment)
58. {
59. enlistment.Done();
60. }
61. public void InDoubt(Enlistment enlistment)
62. {
63. enlistment.Done();
64. }
65. public void Rollback(Enlistment enlistment)
66.
补充:Web开发 , ASP.Net ,