项目背景:ITOO.Teacher.Service提供一套访问教师数据库的WCF服务,ITOO.Student.Service提供一套访问学生数据库的WCF服务。学生服务端的B层在进行业务处理时,需要调用教师的WCF服务,我们需要在学生服务端的B层加上分布式事务处理,向教师库和学生库更新数据,要么都成功,要么都不成功。
1.在教师服务端,我们需要在WCF的接口上加上WCF分布式事务特性:
[OperationContract] [TransactionFlow(TransactionFlowOption.Allowed)] bool AddTeacher(TeacherViewModel vmTeacher);
在教师服务端的B层实现上加上WCF分布式事务特性:
/// <summary> /// 增加学生 /// </summary> /// <param name="vmTeacher">教师ViewModel</param> /// <returns>布尔值</returns> [OperationBehavior(TransactionScopeRequired = true, TransactionAutoComplete = true)] public bool AddTeacher(TeacherViewModel vmTeacher) { //创建转换规则 Mapper.CreateMap<TeacherViewModel, TeacherEntity>(); //转换实体 TeacherEntity enStudent = Mapper.Map<TeacherEntity>(vmTeacher); //调用dal层增加方法 this.CurrentDal.Add(enStudent); //提交事务,返回结果 return this.DbSession.SaveChanges() > 0; }
2.在学生服务端的B层采用system.transactions进行分布式事务处理:
public void AddStudentTeacher(StudentViewModel vmStudent) { //创建转换规则 Mapper.CreateMap<StudentViewModel, StudentEntity>(); //转换实体 StudentEntity enStudent = Mapper.Map<StudentEntity>(vmStudent); //调用dal层增加方法 this.CurrentDal.Add(enStudent); this.DbSession.SaveChanges(); //调用老师的添加方法 ITeacherContracts teacherContracts = ServiceFactory.GetTeacherService(); TeacherViewModel vmTeacher = new TeacherViewModel { TeacherID = "123", TeacherName = "11" }; teacherContracts.AddTeacher(vmTeacher); }
3.由于每个事务处理都需要using TransactionScope、 trans.Complete,所以我们用Spring.Net的AOP管理这些相同的处理:
public class AroundAdvice : IMethodInterceptor { public object Invoke(IMethodInvocation invocation) { object result; using (TransactionScope trans = new TransactionScope()) { result = invocation.Proceed(); trans.Complete(); } return result; } }
4.配置数据库服务器的MSDTC服务:
4.1开启MSDTC服务,在DOS中输入net start msdtc;
4.2设置MSDTC,在DOS中输入dcomcnfg.exe,按下图所示设置:
4.3关闭windows防火墙;
4.4开启数据库的分布式事务支持,设置如下图所示:
当前版本是用system.transactions实现的分布式事务,用Spring.Net的AOP切了一下,至于Spring.Net的声明式事务是否可以实现对WCF分布式事务的管理,这个还有待研究。
框架的源码下载地址:http://pan.baidu.com/s/1hqvOC6K (最好用VS2012打开)。
时间: 2024-11-04 17:04:36