亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

封裝業務函數

系統 1909 0

鏈式調用 - 封裝業務函數

用設計模式、AOP能將一個方法/函數包裹起來,并且插入額外的邏輯行為,不過動作比較大,不是很靈活,下面介紹一種鏈式調用方法來封裝的代碼,完成后能實現如下的鏈式調用:

        
          public
        
        
          class
        
        
           BO

        {

            
        
        
          public
        
        
          bool
        
         Add(
        
          string
        
        
           msg)

            {

                Console.WriteLine(
        
        
          "
        
        
          Add
        
        
          "
        
        
          );



                
        
        
          if
        
         (msg == 
        
          null
        
        
          )

                    
        
        
          throw
        
        
          new
        
        
           Exception();



                
        
        
          return
        
        
          true
        
        
          ;

            }

        }



        
        
        
          static
        
        
          void
        
         Main(
        
          string
        
        
          [] args)

        {

            BO bo
        
        =
        
          new
        
        
           BO();



            Pipeline
        
        <
        
          string
        
        , 
        
          bool
        
        > p = Pipeline.Wrap<
        
          string
        
        , 
        
          bool
        
        >
        
          (bo.Add)

                        .BeforeExecute(m
        
        =>Console.WriteLine(
        
          "
        
        
          before execute
        
        
          "
        
        
          ))

                        .AfterExecute((m, n) 
        
        => Console.WriteLine(
        
          "
        
        
          after execute1
        
        
          "
        
        
          ))

                        .AfterExecute((m, n) 
        
        => Console.WriteLine(
        
          "
        
        
          after execute2
        
        
          "
        
        
          ))

                        .Success((m, n) 
        
        => Console.WriteLine(
        
          "
        
        
          success
        
        
          "
        
        
          ))

                        .Fail((m, n) 
        
        => Console.WriteLine(
        
          "
        
        
          fail
        
        
          "
        
        
          ))

                        .Final((m, n) 
        
        => Console.WriteLine(
        
          "
        
        
          final
        
        
          "
        
        
          ));





            Console.WriteLine(
        
        
          "
        
        
          Result: 
        
        
          "
        
        +p.Execute(
        
          "
        
        
          testing
        
        
          "
        
        
          ).Result);



            Console.WriteLine();

            Console.WriteLine();



            Console.WriteLine(
        
        
          "
        
        
          Result: 
        
        
          "
        
         + p.Execute(
        
          null
        
        
          ).Result);



            Console.ReadKey();

        }
        
      

?運行圖:

封裝業務函數

?注意:這個封裝會對目標業務函數加入try/catch來得到業務是否成功執行。

實現起來比較簡單,就是每個函數返回自身,如下:

        
          public
        
        
          static
        
        
          class
        
        
           Pipeline
          
            //這里只實現了2個泛型,可以增加很多個(這點比較麻煩)
          
          

    {

        
        
        
          public
        
        
          static
        
         Pipeline<TIN, TOUT> Wrap<TIN, TOUT>(Func<TIN, TOUT>
        
           method)

        {

            Pipeline
        
        <TIN, TOUT> p = 
        
          new
        
         Pipeline<TIN, TOUT>
        
          (method);

            
        
        
          return
        
        
           p;

        }



        
        
        
          public
        
        
          static
        
         Pipeline<TIN1, TIN2, TOUT> Wrap<TIN1, TIN2, TOUT>(Func<TIN1, TIN2, TOUT>
        
           method)

        {

            Pipeline
        
        <TIN1, TIN2, TOUT> p = 
        
          new
        
         Pipeline<TIN1, TIN2, TOUT>
        
          (method);

            
        
        
          return
        
        
           p;

        }

    }
        
      

?

?最終返回的結果對象:

        
          public
        
        
          struct
        
         PipelineResult<TOUT>
        
          

    {

        
        
        
          ///
        
        
          <summary>
        
        
          ///
        
        
           目標核心函數返回值

        
        
        
          ///
        
        
          </summary>
        
        
          public
        
         TOUT Result { 
        
          get
        
        ; 
        
          set
        
        
          ; }



        
        
        
          ///
        
        
          <summary>
        
        
          ///
        
        
           是否存在異常

        
        
        
          ///
        
        
          </summary>
        
        
          public
        
        
          bool
        
         ExceptionExists { 
        
          get
        
        ; 
        
          set
        
        
          ; }



        
        
        
          ///
        
        
          <summary>
        
        
          ///
        
        
           具體的異常

        
        
        
          ///
        
        
          </summary>
        
        
          public
        
         Exception Exception { 
        
          get
        
        ; 
        
          set
        
        
          ; }

    }
        
      

?

?只有一個輸入參數的Wrapper:

        
          public
        
        
          class
        
         Pipeline<TIN, TOUT>
        
          

    {

        
        
        
          private
        
         Func<TIN, TOUT>
        
           method2Execute;

        
        
        
          private
        
         List<Action<TIN>> beforeExecuteActions = 
        
          new
        
         List<Action<TIN>>
        
          ();

        
        
        
          private
        
         List<Action<TIN, TOUT>> afterExecuteActions = 
        
          new
        
         List<Action<TIN, TOUT>>
        
          ();

        
        
        
          private
        
         Action<TIN, TOUT>
        
           finalAction;

        
        
        
          private
        
         List<Action<TIN, TOUT>> successActions = 
        
          new
        
         List<Action<TIN, TOUT>>
        
          ();

        
        
        
          private
        
         List<Action<TIN, TOUT>> failActions = 
        
          new
        
         List<Action<TIN, TOUT>>
        
          ();



        
        
        
          public
        
         Pipeline(Func<TIN, TOUT>
        
           method)

        {

            
        
        
          this
        
        .method2Execute =
        
           method;

        }



        
        
        
          public
        
         Pipeline<TIN, TOUT> BeforeExecute(Action<TIN>
        
           action)

        {

            beforeExecuteActions.Add(action);



            
        
        
          return
        
        
          this
        
        
          ;

        }



        
        
        
          public
        
         Pipeline<TIN, TOUT> AfterExecute(Action<TIN, TOUT>
        
           action)

        {

            afterExecuteActions.Add(action);



            
        
        
          return
        
        
          this
        
        
          ;

        }



        
        
        
          public
        
         Pipeline<TIN, TOUT> Final(Action<TIN, TOUT>
        
           action)

        {

            
        
        
          this
        
        .finalAction =
        
           action;



            
        
        
          return
        
        
          this
        
        
          ;

        }



        
        
        
          public
        
         Pipeline<TIN, TOUT> Success(Action<TIN, TOUT>
        
           action)

        {

            successActions.Add(action);



            
        
        
          return
        
        
          this
        
        
          ;

        }



        
        
        
          public
        
         Pipeline<TIN, TOUT> Fail(Action<TIN, TOUT>
        
           action)

        {

            failActions.Add(action);



            
        
        
          return
        
        
          this
        
        
          ;

        }



        
        
        
          public
        
         PipelineResult<TOUT>
        
           Execute(TIN argument)

        {

            PipelineResult
        
        <TOUT> result = 
        
          new
        
         PipelineResult<TOUT>
        
          ();



            
        
        
          foreach
        
         (
        
          var
        
         action 
        
          in
        
        
          this
        
        
          .beforeExecuteActions)

                action.Invoke(argument);



            
        
        
          try
        
        
          

            {

                result.Result 
        
        = 
        
          this
        
        
          .method2Execute.Invoke(argument);

                result.ExceptionExists 
        
        = 
        
          false
        
        
          ;

                result.Exception 
        
        = 
        
          null
        
        
          ;

            }

            
        
        
          catch
        
        
           (Exception ex)

            {

                result.ExceptionExists 
        
        = 
        
          true
        
        
          ;

                result.Exception 
        
        =
        
           ex;

            }



            
        
        
          foreach
        
         (
        
          var
        
         action 
        
          in
        
        
          this
        
        
          .afterExecuteActions)

                action.Invoke(argument, result.Result);



            
        
        
          if
        
         (!
        
          result.ExceptionExists)

            {

                
        
        
          foreach
        
         (
        
          var
        
         action 
        
          in
        
        
          this
        
        
          .successActions)

                    action.Invoke(argument, result.Result);

            }

            
        
        
          else
        
        
          

            {

                
        
        
          foreach
        
         (
        
          var
        
         action 
        
          in
        
        
          this
        
        
          .failActions)

                    action.Invoke(argument, result.Result);

            }



            
        
        
          if
        
         (
        
          this
        
        .finalAction != 
        
          null
        
        
          )

                
        
        
          this
        
        
          .finalAction.Invoke(argument, result.Result);



            
        
        
          return
        
        
           result;

        }

    }
        
      

?

支持2個輸入參數的Wrapper:

        
          public
        
        
          class
        
         Pipeline<TIN1, TIN2, TOUT>
        
          

    {

        
        
        
          private
        
         Func<TIN1, TIN2, TOUT>
        
           method2Execute;

        
        
        
          private
        
         List<Action<TIN1, TIN2>> beforeExecuteActions = 
        
          new
        
         List<Action<TIN1, TIN2>>
        
          ();

        
        
        
          private
        
         List<Action<TIN1, TIN2, TOUT>> afterExecuteActions = 
        
          new
        
         List<Action<TIN1, TIN2, TOUT>>
        
          ();

        
        
        
          private
        
         Action<TIN1, TIN2, TOUT>
        
           finalAction;

        
        
        
          private
        
         List<Action<TIN1, TIN2, TOUT>> successActions = 
        
          new
        
         List<Action<TIN1, TIN2, TOUT>>
        
          ();

        
        
        
          private
        
         List<Action<TIN1, TIN2, TOUT>> failActions = 
        
          new
        
         List<Action<TIN1, TIN2, TOUT>>
        
          ();



        
        
        
          public
        
         Pipeline(Func<TIN1, TIN2, TOUT>
        
           method)

        {

            
        
        
          this
        
        .method2Execute =
        
           method;

        }



        
        
        
          public
        
         Pipeline<TIN1, TIN2, TOUT> BeforeExecute(Action<TIN1, TIN2>
        
           action)

        {

            beforeExecuteActions.Add(action);



            
        
        
          return
        
        
          this
        
        
          ;

        }



        
        
        
          public
        
         Pipeline<TIN1, TIN2, TOUT> AfterExecute(Action<TIN1, TIN2, TOUT>
        
           action)

        {

            afterExecuteActions.Add(action);



            
        
        
          return
        
        
          this
        
        
          ;

        }



        
        
        
          public
        
         Pipeline<TIN1, TIN2, TOUT> Final(Action<TIN1, TIN2, TOUT>
        
           action)

        {

            
        
        
          this
        
        .finalAction =
        
           action;



            
        
        
          return
        
        
          this
        
        
          ;

        }



        
        
        
          public
        
         Pipeline<TIN1, TIN2, TOUT> Success(Action<TIN1, TIN2, TOUT>
        
           action)

        {

            successActions.Add(action);



            
        
        
          return
        
        
          this
        
        
          ;

        }



        
        
        
          public
        
         Pipeline<TIN1, TIN2, TOUT> Fail(Action<TIN1, TIN2, TOUT>
        
           action)

        {

            failActions.Add(action);



            
        
        
          return
        
        
          this
        
        
          ;

        }



        
        
        
          public
        
         PipelineResult<TOUT>
        
           Execute(TIN1 argument1, TIN2 argument2)

        {

            PipelineResult
        
        <TOUT> result = 
        
          new
        
         PipelineResult<TOUT>
        
          ();



            
        
        
          foreach
        
         (
        
          var
        
         action 
        
          in
        
        
          this
        
        
          .beforeExecuteActions)

                action.Invoke(argument1, argument2);



            
        
        
          try
        
        
          

            {

                result.Result 
        
        = 
        
          this
        
        
          .method2Execute.Invoke(argument1, argument2);

                result.ExceptionExists 
        
        = 
        
          false
        
        
          ;

                result.Exception 
        
        = 
        
          null
        
        
          ;

            }

            
        
        
          catch
        
        
           (Exception ex)

            {

                result.ExceptionExists 
        
        = 
        
          true
        
        
          ;

                result.Exception 
        
        =
        
           ex;

            }



            
        
        
          foreach
        
         (
        
          var
        
         action 
        
          in
        
        
          this
        
        
          .afterExecuteActions)

                action.Invoke(argument1, argument2, result.Result);



            
        
        
          if
        
         (!
        
          result.ExceptionExists)

            {

                
        
        
          foreach
        
         (
        
          var
        
         action 
        
          in
        
        
          this
        
        
          .successActions)

                    action.Invoke(argument1, argument2, result.Result);

            }

            
        
        
          else
        
        
          

            {

                
        
        
          foreach
        
         (
        
          var
        
         action 
        
          in
        
        
          this
        
        
          .failActions)

                    action.Invoke(argument1, argument2, result.Result);

            }



            
        
        
          if
        
         (
        
          this
        
        .finalAction != 
        
          null
        
        
          )

                
        
        
          this
        
        
          .finalAction.Invoke(argument1, argument2, result.Result);



            
        
        
          return
        
        
           result;

        }

    }
        
      

?

支持更多輸入參數的?不要返回值的?自己搞定吧。?

盡管這個模式很簡單,但是只要擴展一下,就能做簡單的復合業務邏輯,比如xml文件來配置,最終組合成復合業務,很有潛力的一個模式。?

?

自省推動進步,視野決定未來。
心懷遠大理想。
為了家庭幸福而努力。
A2D科技,服務社會。
A2D Framework (Alpha)
  • 1. Cache System(本地緩存與分布式緩存共存、支持Memcache和Redis、支持貼標簽形式(類似Spring 3.x的Cache形式))
  • 2. Event System(本地事件與分布式事件分發)
  • 3. IoC(自動匹配功能,實例數量限制功能)
  • 4. Sql Dispatcher System(支持ADO.NET及EF)
  • 5. Session System(分布式Session系統)
  • 6. 分布式Command Bus(MSMQ實現,解決4M限制,支持Session的讀取)
  • 7. 規則引擎

QQ群:283016070,真材實料的.NET架構師

?

?

?

封裝業務函數


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 免费爱爱的视频太爽了 | 欧美成人性做爰网站免费 | 成人爽a毛片在线视频网站 成人爽视频 | 亚洲伊人精品综合在合线 | 最近中文字幕无免费视频 | 99热久久国产这里有只有精品 | 亚洲国产成人私人影院 | 中国大陆一级毛片 免费 | 激情综合网五月 | 日韩精品一区二区三区中文 | 一区二区三区久久精品 | 激情五月婷婷综合 | 欧美日韩一本 | 美美女高清毛片视频黄的一免费 | 久久99精品这里精品3 | 亚洲天天做日日做天天欢毛片 | 亚洲国产成人麻豆精品 | 四虎影视精品永久免费网站 | 天天做天天爱天天一爽一毛片 | 91精品国产爱久久久久久 | 四虎永久免费在线观看 | 亚洲欧洲视频 | 国产精品爱久久久 | 在线 | 一区二区三区四区 | 精品国产区一区二区三区在线观看 | 日韩欧美中文字幕在线播放 | 五月婷视频 | 国产成人精品精品欧美 | 97国产视频 | 一级h片| 国内精品久久久久久中文字幕 | 奇米网在线视频 | 亚洲国产一区在线二区三区 | 99视频在线永久免费观看 | 国产精品视频专区 | 国语国产真人对白毛片 | 99国产在线播放 | 亚洲欧美日韩中文v在线 | a毛片| 免费国产黄线在线观看视频 | 久久综合视频网 |