[AOP系列]Autofac+Castle實作AOP事務

一、前言

最近公司新項目，需要搭架構進行開發，其中需要保證事務的一緻性，經過一番查找，發現很多博文都是通過Spring.Net、Unity、PostSharp、Castle Windsor這些方式實作AOP的。但是這不是我想要的，是以一番查找後，使用

Autofac、DynamicProxy

該方式實作AOP。

二、使用AOP的優勢

部落客覺得它的優勢主要表現在：

• 将通用功能從業務邏輯中抽離出來，就可以省略大量重複代碼，有利于代碼的操作和維護。
• 在軟體設計時，抽出通用功能（切面），有利于軟體設計的子產品化，降低軟體架構的複雜程度。也就是說通用的功能就是一個單獨的子產品，在項目的主業務裡面是看不到這些通用功能的設計代碼的。

三、引用庫

• Autofac：4.6
• Autofac.Extras.DynamicProxy：4.1.0
• Castle.Core：3.2.2

四、實作思路

4.1 定義屬性

定義屬性，通過目前方法是否包含該屬性進行判斷開啟事務，如果存在該屬性則開啟事務，否則忽略事務。

事務屬性可以設定逾時時間、事務範圍以及事務隔離級别。

代碼如下：

/// <summary>
/// 開啟事務屬性
/// </summary>
[AttributeUsage(AttributeTargets.Method,Inherited = true)]
public class TransactionCallHandlerAttribute:Attribute
{
    /// <summary>
    /// 逾時時間
    /// </summary>
    public int Timeout { get; set; }

    /// <summary>
    /// 事務範圍
    /// </summary>
    public TransactionScopeOption ScopeOption { get; set; }

    /// <summary>
    /// 事務隔離級别
    /// </summary>
    public IsolationLevel IsolationLevel { get; set; }

    public TransactionCallHandlerAttribute()
    {
        Timeout = 60;
        ScopeOption=TransactionScopeOption.Required;
        IsolationLevel=IsolationLevel.ReadCommitted;
    }
}
           

4.2 切面實作

擷取目前方法是否包含

TransactionCallHandlerAttribute

該屬性，如果有該屬性則開啟事務。

本人在此處加入開發模式判斷，用于沒設定MSDTC産生異常的問題，如果不需要可忽略。

另外日志功能自行實作即可。

/// <summary>
/// 事務 攔截器
/// </summary>
public class TransactionInterceptor:IInterceptor
{
    //可自行實作日志器，此處可忽略
    /// <summary>
    /// 日志記錄器
    /// </summary>
    private static readonly ILog Logger = Log.GetLog(typeof(TransactionInterceptor));

    // 是否開發模式
    private bool isDev = false;
    public void Intercept(IInvocation invocation)
    {
        if (!isDev)
        {
            MethodInfo methodInfo = invocation.MethodInvocationTarget;
            if (methodInfo == null)
            {
                methodInfo = invocation.Method;
            }
                            
            TransactionCallHandlerAttribute transaction =
                methodInfo.GetCustomAttributes<TransactionCallHandlerAttribute>(true).FirstOrDefault();
            if (transaction != null)
            {
                TransactionOptions transactionOptions = new TransactionOptions();
                //設定事務隔離級别
                transactionOptions.IsolationLevel = transaction.IsolationLevel;
                //設定事務逾時時間為60秒
                transactionOptions.Timeout = new TimeSpan(0, 0, transaction.Timeout);
                using (TransactionScope scope = new TransactionScope(transaction.ScopeOption, transactionOptions))
                {
                    try
                    {
                        //實作事務性工作
                        invocation.Proceed();
                        scope.Complete();
                    }
                    catch (Exception ex)
                    {
                        // 記錄異常
                        throw ex;
                    }
                }
            }
            else
            {
                // 沒有事務時直接執行方法
                invocation.Proceed();
            }
        }
        else
        {
            // 開發模式直接跳過攔截
            invocation.Proceed();
        }
    }
}
           

4.3 切面注入

部落客對

Autofac

進行了封裝，可能與你們的配置不一樣，但是，

Load(ContainerBuilder builder)

該方法内容是一緻的，是以注入方式一緻的。

通過定義

IDependency

空接口方式，需要注入的類則繼承該接口即可。

/// <summary>
/// 應用程式IOC配置
/// </summary>
public class IocConfig : ConfigBase
{
    // 重寫加載配置
    protected override void Load(ContainerBuilder builder)
    {
        var assembly = this.GetType().GetTypeInfo().Assembly;
        builder.RegisterType<TransactionInterceptor>();
        builder.RegisterAssemblyTypes(assembly)
            .Where(type => typeof(IDependency).IsAssignableFrom(type) && !type.GetTypeInfo().IsAbstract)
            .AsImplementedInterfaces()
            .InstancePerLifetimeScope()
            .EnableInterfaceInterceptors()
            .InterceptedBy(typeof(TransactionInterceptor));
    }
}
           

五、例子

/// <summary>
/// 添加文章
/// </summary>
/// <param name="name"></param>
[TransactionCallHandler]
public void AddArticle(string name)
{
    BasArticle model=new BasArticle();
    model.ArticleID = Guid.Empty;//故意重複，判斷是否會復原。
    model.Code = TimestampId.GetInstance().GetId();
    model.Name = name;
    model.Status = 1;
    model.Creater = "測試";
    model.Editor = "測試";
    this._basArticleRepository.Insert(model);            
}