淺談C# AOP的簡單實(shí)現(xiàn)

public class Order
  {
    public int Id { set; get; }
    public string Name { set; get; }
    public int Count { set; get; }
    public double Price { set; get; }
    public string Desc { set; get; }
  }

  public interface IOrderProcessor
  {
    void Submit(Order order);
  }
  public class OrderProcessor : IOrderProcessor
  {
    public void Submit(Order order)
    {
      Console.WriteLine("提交訂單");
    }
  }

  public class OrderProcessorDecorator : IOrderProcessor
  {
    public IOrderProcessor OrderProcessor { get; set; }
    public OrderProcessorDecorator(IOrderProcessor orderprocessor)
    {
      OrderProcessor = orderprocessor;
    }
    public void Submit(Order order)
    {
      PreProceed(order);
      OrderProcessor.Submit(order);
      PostProceed(order);
    }
    public void PreProceed(Order order)
    {
      Console.WriteLine("提交訂單前，進(jìn)行訂單數(shù)據(jù)校驗(yàn)....");
      if (order.Price < 0)
      {
        Console.WriteLine("訂單總價(jià)有誤，請重新核對訂單。");
      }
    }

    public void PostProceed(Order order)
    {
      Console.WriteLine("提交帶單后，進(jìn)行訂單日志記錄......");
      Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "提交訂單，訂單名稱：" + order.Name + "，訂單價(jià)格：" + order.Price);
    }
  }

static void Main(string[] args)
    {
      Order order = new Order() { Id = 1, Name = "lee", Count = 10, Price = 100.00, Desc = "訂單測試" };
      IOrderProcessor orderprocessor = new OrderProcessorDecorator(new OrderProcessor());
      orderprocessor.Submit(order);
      Console.ReadLine();
    }

public class User
  {
    public string Name { set; get; }
    public string PassWord { set; get; }
  }

  #region 1、定義特性方便使用
  public class LogHandlerAttribute : HandlerAttribute
  {
    public string LogInfo { set; get; }
    public int Order { get; set; }
    public override ICallHandler CreateHandler(IUnityContainer container)
    {
      return new LogHandler() { Order = this.Order, LogInfo = this.LogInfo };
    }
  }
  #endregion

  #region 2、注冊對需要的Handler攔截請求
  public class LogHandler : ICallHandler
  {
    public int Order { get; set; }
    public string LogInfo { set; get; }

    //這個(gè)方法就是攔截的方法，可以規(guī)定在執(zhí)行方法之前和之后的攔截
    public IMethodReturn Invoke(IMethodInvocation input, GetNextHandlerDelegate getNext)
    {
      Console.WriteLine("LogInfo內(nèi)容" + LogInfo);
      //0.解析參數(shù)
      var arrInputs = input.Inputs;
      if (arrInputs.Count > 0)
      {
        var oUserTest1 = arrInputs[0] as User;
      }
      //1.執(zhí)行方法之前的攔截
      Console.WriteLine("方法執(zhí)行前攔截到了");
      //2.執(zhí)行方法
      var messagereturn = getNext()(input, getNext);

      //3.執(zhí)行方法之后的攔截
      Console.WriteLine("方法執(zhí)行后攔截到了");
      return messagereturn;
    }
  }
  #endregion

  #region 3、用戶定義接口和實(shí)現(xiàn)
  public interface IUserOperation
  {
    void Test(User oUser);
    void Test2(User oUser, User oUser2);
  }


  //這里必須要繼承這個(gè)類MarshalByRefObject，否則報(bào)錯(cuò)
  public class UserOperation : MarshalByRefObject, IUserOperation
  {
    private static UserOperation oUserOpertion = null;
    public UserOperation()
    {
      //oUserOpertion = PolicyInjection.Create<UserOperation>();
    }

    //定義單例模式將PolicyInjection.Create<UserOperation>()產(chǎn)生的這個(gè)對象傳出去，這樣就避免了在調(diào)用處寫這些東西
    public static UserOperation GetInstance()
    {
      if (oUserOpertion == null)
        oUserOpertion = PolicyInjection.Create<UserOperation>();

      return oUserOpertion;
    }
    //調(diào)用屬性也會(huì)攔截
    public string Name { set; get; }

    //[LogHandler]，在方法上面加這個(gè)特性，只對此方法攔截
    [LogHandler(LogInfo = "Test的日志為aaaaa")]
    public void Test(User oUser)
    {
      Console.WriteLine("Test方法執(zhí)行了");
    }

    [LogHandler(LogInfo = "Test2的日志為bbbbb")]
    public void Test2(User oUser, User oUser2)
    {
      Console.WriteLine("Test2方法執(zhí)行了");
    }
  }
  #endregion

static void Main(string[] args)
    {
      try
      {
        var oUserTest1 = new User() { Name = "test2222", PassWord = "yxj" };
        var oUserTest2 = new User() { Name = "test3333", PassWord = "yxj" };
        var oUser = UserOperation.GetInstance();
        oUser.Test(oUserTest1);
        oUser.Test2(oUserTest1,oUserTest2);
      }
      catch (Exception ex)
      {
        //throw;
      }
    }

[Serializable]
  public class TestAop : PostSharp.Aspects.OnMethodBoundaryAspect
  {
　　　　 //發(fā)生異常時(shí)進(jìn)入此方法
    public override void OnException(MethodExecutionArgs args)
    {
      base.OnException(args);
    }

　　　　 //執(zhí)行方法前執(zhí)行此方法
    public override void OnEntry(MethodExecutionArgs args)
    {
      base.OnEntry(args);
    }

　　　　 //執(zhí)行方法后執(zhí)行此方法
    public override void OnExit(MethodExecutionArgs args)
    {
      base.OnExit(args);
    }
  }

[TestAop]public class Impc_TM_PLANT : Ifc_TM_PLANT
  {
    /// <summary>
    /// 獲取或設(shè)置服務(wù)接口。
    /// </summary>
    private Ic_TM_PLANTService service { get; set; }
    
    public IList<DTO_TM_PLANT> Find()
    {
      DTO_TM_PLANT otest = null;
      otest.NAME_C = "test";//異常，會(huì)進(jìn)入OnException方法
　　　　　　　　return service.FindAll(); 
　　　　 }
　　}

[TestAop]
    public IList<DTO_TM_PLANT> Find()
    {
      DTO_TM_PLANT otest = null;
      otest.NAME_C = "test";
      return service.FindAll();
    }

public class AOPFilterAttribute : ActionFilterAttribute, IExceptionFilter
  {

    public void OnException(ExceptionContext filterContext)
    {
      throw new System.NotImplementedException();
    }
    public override void OnActionExecuting(ActionExecutingContext filterContext)
    {
      
      base.OnActionExecuting(filterContext);
    }

    public override void OnActionExecuted(ActionExecutedContext filterContext)
    {
      base.OnActionExecuted(filterContext);
    }
  }

[AOPFilter]
    public JsonResult GetEditModel(string strType)
    {
      var lstRes = new List<List<DragElementProp>>();
      var lstResPage = new List<PageProperty>();

　　　　　　 //.........todo

      return Json(new { lstDataAttr = lstRes, PageAttr = lstResPage, lstJsConnections = lstJsPlumbLines }, JsonRequestBehavior.AllowGet);
    }