鏈式調用 - 封裝業務函數
用設計模式、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元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
