MVC+UnitOfWork+Repository+EF 之我见

UnitOfWork+Repository模式简介：

每次提交数据库都会打开一个连接，造成结果是：多个连接无法共用一个数据库级别的事务，也就无法保证数据的原子性、一致性。解决办法是：在 Repository的CRUD操作基础上再包装一层，提供统一的入口，让服务层调用。同一个UnitOfWork实例对象下所有的Repository 都共同一个数据库上下文对象（ps：EF用的是DbContext），也就是共用一个事物。提交数据库时，只要有一个操作失败，那么所有的操作都被视为失 败。

项目结构：



关键代码：

AggregateRoot.cs：

1 using System;
2 using System.Collections.Generic;
3
4 namespace CMS.Domain.Core
5 {
6     /// <summary>
7     /// 表示聚合根类型的基类型。
8     /// </summary>
9     public abstract class AggregateRoot : IAggregateRoot
10     {
11         #region 方法
12
13         public virtual IEnumerable<BusinessRule> Validate()
14         {
15             return new BusinessRule[] { };
16         }
17
18         #endregion
19
20         #region Object 成员
21
22         public override bool Equals(object obj)
23         {
24             if (obj == null)
25                 return false;
26
27             if (ReferenceEquals(this, obj))
28                 return true;
29
30             IAggregateRoot ar = obj as IAggregateRoot;
31
32             if (ar == null)
33                 return false;
34
35             return this.Id == ar.Id;
36         }
37
38         public override int GetHashCode()
39         {
40             return this.Id.GetHashCode();
41         }
42
43         #endregion
44
45         #region IAggregateRoot 成员
46
47         public Guid Id
48         {
49             get;
50             set;
51         }
52
53         #endregion
54     }
55 }

Channel.cs：

1 using CMS.Domain.Core;
2
3 namespace CMS.Domain.Entities
4 {
5     public class Channel : AggregateRoot
6     {
7         public string Name
8         {
9             get;
10             set;
11         }
12
13         public string CoverPicture
14         {
15             get;
16             set;
17         }
18
19         public string Desc
20         {
21             get;
22             set;
23         }
24
25         public bool IsActive
26         {
27             get;
28             set;
29         }
30
31         public int Hits
32         {
33             get;
34             set;
35         }
36     }
37 }

IUnitOfWork.cs：

1 using System;
2
3 namespace CMS.Domain.Core.Repository
4 {
5     /// <summary>
6     /// 工作单元
7     /// 提供一个保存方法，它可以对调用层公开，为了减少连库次数
8     /// </summary>
9     public interface IUnitOfWork : IDisposable
10     {
11         #region 方法
12
13         IRepository<T> Repository<T>() where T : class, IAggregateRoot;
14
15         void Commit();
16
17         #endregion
18     }
19 }

UnitOfWork.cs：

1 using CMS.Common;
2 using CMS.Domain.Core;
3 using CMS.Domain.Core.Repository;
4 using System;
5 using System.Collections;
6 using System.Collections.Generic;
7
8 namespace CMS.Infrastructure
9 {
10     public class UnitOfWork : IUnitOfWork, IDisposable
11     {
12         #region 变量
13
14         private bool _disposed;
15         private readonly IDbContext _dbContext;
16         private Hashtable _repositories;
17
18         #endregion
19
20         #region 构造函数
21
22         public UnitOfWork(IDbContext dbContext)
23         {
24             this._dbContext = dbContext;
25             this._repositories = new Hashtable();
26         }
27
28         #endregion
29
30         #region 方法
31
32         public virtual void Dispose(bool disposing)
33         {
34             if (!this._disposed)
35                 if (disposing)
36                     this._dbContext.Dispose();
37
38             this._disposed = true;
39         }
40
41         #endregion
42
43         #region IUnitOfWork 成员
44
45         public IRepository<T> Repository<T>() where T : class, IAggregateRoot
46         {
47             var typeName = typeof(T).Name;
48
49             if (!this._repositories.ContainsKey(typeName))
50             {
51                 52
53                 var paramDict = new Dictionary<string, object>();
54                 paramDict.Add("context", this._dbContext);
55
56                 //Repository接口的实现统一在UnitOfWork中执行，通过Unity来实现IOC，同时把IDbContext的实现通过构造函数参数的方式传入
57                 var repositoryInstance = UnityConfig.Resolve<IRepository<T>>(paramDict);
58
59                 if (repositoryInstance != null)
60                     this._repositories.Add(typeName, repositoryInstance);
61             }
62
63             return (IRepository<T>)this._repositories[typeName];
64         }
65
66         public void Commit()
67         {
68             this._dbContext.SaveChanges();
69         }
70
71         #endregion
72
73         #region IDisposable 成员
74
75         public void Dispose()
76         {
77             this.Dispose(true);
78
79             GC.SuppressFinalize(this);
80         }
81
82         #endregion
83     }
84 }

BaseRepository.cs：

1 using CMS.Domain.Core;
2 using CMS.Domain.Core.Repository;
3 using System;
4 using System.Collections.Generic;
5 using System.Data.Entity;
6 using System.Linq;
7 using System.Linq.Expressions;
8
9 namespace CMS.Infrastructure
10 {
11     public class BaseRepository<T> : IRepository<T> where T : class, IAggregateRoot
12     {
13         #region 变量
14
15         private readonly DbContext _db;
16         private readonly IDbSet<T> _dbset;
17
18         #endregion
19
20         #region 构造函数
21
22         public BaseRepository(IDbContext context)
23         {
24             this._db = (DbContext)context;
25             this._dbset = this._db.Set<T>();
26         }
27
28         #endregion
29
30         #region IRepository 成员
31
32         public void Add(T item)
33         {
34             this._dbset.Add(item);
35         }
36
37         public void Remove(T item)
38         {
39             this._dbset.Remove(item);
40         }
41
42         public void Modify(T item)
43         {
44             this._db.Entry(item).State = EntityState.Modified;
45         }
46
47         public T Get(Expression<Func<T, bool>> filter)
48         {
49             return this._dbset.Where(filter).SingleOrDefault();
50         }
51
52         public IEnumerable<T> GetAll()
53         {
54             return this._dbset.ToList();
55         }
56
57         public IEnumerable<T> GetPaged<KProperty>(int pageIndex, int pageSize, out int total, Expression<Func<T, bool>> filter, Expression<Func<T, KProperty>> orderBy, bool ascending = true, string[] includes = null)
58         {
59             pageIndex = pageIndex > 0 ? pageIndex : 1;
60
61             var result = this.GetFiltered(filter, orderBy, ascending, includes);
62
63             total = result.Count();
64
65             return result.Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList();
66         }
67
68         public IEnumerable<T> GetFiltered<KProperty>(Expression<Func<T, bool>> filter, Expression<Func<T, KProperty>> orderBy, bool ascending = true, string[] includes = null)
69         {
70             var result = filter == null ? this._dbset : this._dbset.Where(filter);
71
72             if (ascending)
73                 result = result.OrderBy(orderBy);
74             else
75                 result = result.OrderByDescending(orderBy);
76
77             if (includes != null && includes.Length > 0)
78             {
79                 foreach (var include in includes)
80                 {
81                     result = result.Include(include);
82                 }
83             }
84
85             return result.ToList();
86         }
87
88         #endregion
89     }
90 }

IDbContext.cs：

1 namespace CMS.Infrastructure
2 {
3     public interface IDbContext
4     {
5         #region 方法
6
7         int SaveChanges();
8
9         void Dispose();
10
11         #endregion
12     }
13 }

CMSDbContext.cs：

1 using CMS.Infrastructures.Mapping;
2 using System.Data.Entity;
3 using System.Data.Entity.ModelConfiguration.Conventions;
4
5 namespace CMS.Infrastructure
6 {
7     public class CMSDbContext : DbContext, IDbContext
8     {
9         #region 构造函数
10
11         public CMSDbContext()
12             : base("SqlConnectionString")
13         {
14
15         }
16
17         #endregion
18
19         #region DbContext 重写
20
21         protected override void OnModelCreating(DbModelBuilder modelBuilder)
22         {
23             modelBuilder.Conventions.Remove<OneToManyCascadeDeleteConvention>();
24
25             modelBuilder.Configurations.Add(new ChannelEntityConfiguration());
26         }
27
28         #endregion
29     }
30 }

UnityConfig.cs：

1 using Microsoft.Practices.Unity;
2 using Microsoft.Practices.Unity.Configuration;
3 using System;
4 using System.Collections.Generic;
5
6 namespace CMS.Common
7 {
8     public class UnityConfig
9     {
10         #region 属性
11
12         public static IUnityContainer Container
13         {
14             get
15             {
16                 return container.Value;
17             }
18         }
19
20         #endregion
21
22         #region 方法
23
24         private static Lazy<IUnityContainer> container = new Lazy<IUnityContainer>(
25             () =>
26             {
27                 var container = new UnityContainer();
28
29                 RegisterTypes(container);
30
31                 return container;
32             });
33
34         private static void RegisterTypes(IUnityContainer container)
35         {
36             container.LoadConfiguration();
37         }
38
39         public static T Resolve<T>(IDictionary<string, object> paramDict = null)
40         {
41             var list = new ParameterOverrides();
42
43             if (paramDict != null && paramDict.Count > 0)
44             {
45                 foreach (var item in paramDict)
46                 {
47                     list.Add(item.Key, item.Value);
48                 }
49             }
50
51             return Container.Resolve<T>(list);
52         }
53
54         #endregion
55     }
56 }

ChannelApplcationService.cs：

1 using AutoMapper;
2 using CMS.Domain.Core.Repository;
3 using CMS.Domain.Entities;
4 using CMS.DTO;
5 using Microsoft.Practices.Unity;
6
7 namespace CMS.Applcation
8 {
9     public class ChannelApplcationService
10     {
11         #region 属性
12
13         [Dependency]
14         public IUnitOfWork UnitOfWork { get; set; }
15
16         #endregion
17
18         #region 方法
19
20         public Response<bool> Add(ChannelDTO dto)
21         {
22             var resp = new Response<bool>();
23             var channel = Mapper.Map<Channel>(dto);
24
25             using (this.UnitOfWork)
26             {
27                 var channelAddRepository = this.UnitOfWork.Repository<Channel>();
28
29                 channelAddRepository.Add(channel);
30
31                 this.UnitOfWork.Commit();
32             }
33
34             resp.Result = true;
35
36             return resp;
37         }
38
39         #endregion
40     }
41 }

序列图：





心得体会：

1. Repository的CRUD操作只能作用于继承了AggregateRoot基类的DomainObject（ps：以实际项目情况为准，可以做适当的妥协）。

2. DomainObject中涉及到集合类型（如IList，ISet等）的聚合属性需要加“virtual”关键字，让ORM框架识别做Lazyload处理。

3. 各自独立的业务逻辑写在对应的DomainObject方法中，方法体内只能处理自身以及内部聚合对象的数据和状态等信息，被聚合的对象不建议里面再有方法，只需定义相关属性即可（ps：涉及到对外通知、发布消息等场景以DomainEvent的方式处理，关于DomainEvent的概念和使用会开新章进行简述）。

4. 把需要多个DomainObject交互和协调的业务逻辑放到DomainService中（ps：在Applcation Layer中调用。另外DomainService是否能调用Repository对象我一直很困惑，因为看过有代码是这么写的，但又有人不建议这么 做......）。

5. 在AggregateRoot基类中定义验证BusinessRule的虚方法，供子类重写，并在统一的地方执行（比如Applcation Layer）

6. 定义DomainException，用来封装Domain Layer层的异常信息，对上层（Applcation Layer）暴露。

7. Applcation Layer代码的主要作用（可用WCF、WebAPI或直接Dll引用等方式对上层（UI Layer）暴露）

接收UI Layer传递的DTO对象。

通过AutoMapper组件转换成对应的DomainObject，并调用其方法（ps：内部业务逻辑的封装）。

调用Repository对象来实现CRUD操作（ps：这时数据还只是在内存中）。

调用UnitOfWork的Commit方法来实现数据的真正提交（ps：事物级别的）。

所以可以看出Applcation Layer主要用来处理业务的执行顺序，而不是关键的业务逻辑。

Applcation Layer如果用WCF或WebAPI的方式对外暴露有个好处，可以针对其作负载均衡，坏处是额外增加了IIS的请求开销。

8. DTO和DomainObject区别

DTO（ps：为了简单起见，这里把DTO和ViewModel放在一块说了）：

根据实际业务场景加上Required、StringLength等验证特性，结合MVC框架的内部验证机制，可在Controller层做到数据的有效性验证（ps：永远都不要轻易相信浏览器端提交的数据，即使已经有了js脚本验证......）。

负责View数据的展现和表单提交时数据的封装。

负责把数据从UI Layer传递到Applcation Layer，里面只能有属性，而且是扁平的，结构简单的属性。

DomainObject：通俗点说就是充血模型，包括属性和行为，在DDD整个框架设计体系中占非常重要的地位，其涵盖了整个软件系统的业务逻辑、业务规则、聚合关系等方面。（ps；如果业务很简单，可以只有属性）

9. UI Layer：自我学习UnitOfWork+Repository以来，一直用的是MVC框架做前台展现，选择的理由：1. Unity4MVC的IOC功能非常强大，2. 天生支持AOP的思想，3. 更加传统、原始的Web处理方式，4. Areas模块对插件化设计的支持，5. Ajax、ModelBuilder、JSON、验证，6. 整个Http访问周期内提供的各种扩展点等。

转自http://www.cnblogs.com/chenwei1984/p/4203073.html