欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

利用Asp.Net Core的MiddleWare思想如何處理復(fù)雜業(yè)務(wù)流程詳解

 更新時(shí)間：2018年08月10日 08:58:06   作者：碼農(nóng)阿宇  
這篇文章主要給大家介紹了關(guān)于利用Asp.Net Core的MiddleWare思想如何處理復(fù)雜業(yè)務(wù)流程的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起看看吧

前言

最近利用Asp.Net Core 的MiddleWare思想對(duì)公司的古老代碼進(jìn)行重構(gòu)，在這里把我的設(shè)計(jì)思路分享出來(lái)，希望對(duì)大家處理復(fù)雜的流程業(yè)務(wù)能有所幫助。

背景

一個(gè)流程初始化接口，接口中根據(jù)傳入的流程類型，需要做一些不同的工作。

1.有的工作是不管什么類型的流程都要做的（共有），有的工作是某一流程特有的。

2.各個(gè)處理任務(wù)基本不存在嵌套關(guān)系，所以代碼基本是流水賬式的。

3.流程的種類較多，代碼中if或者switch判斷占了很大的篇幅。

4.這些處理工作大致可分為三大類，前期準(zhǔn)備工作（參數(shù)的校驗(yàn)等），處理中的工作（更新數(shù)據(jù)庫(kù)，插入數(shù)據(jù)等），掃尾工作（日志記錄，通知等）

Asp.Net Core中的MiddleWare

注意第二條，流水賬式的代碼，這讓我想到《管道模型》，而Asp.Net Core的MiddleWare正是放在這個(gè)管道中的。

看下圖：

有middleware1,middleware2,middleware3這三個(gè)中間件放在一個(gè)中間件的集合（PipeLine，管道）中并有序排列，Request請(qǐng)求1從流向2載流向3，隨之產(chǎn)生的Response從底層依此流出。

這個(gè)Request和Resopnse就封裝在我們經(jīng)?？吹降腃ontext上下文中，Context傳入到中間件1，中間件1處理后再傳出Context給中間件2 >>>>   一直這樣傳出去，直到傳到最后一個(gè)。

我們經(jīng)常在startup的configure中調(diào)用的app.use()方法，其實(shí)也就是向這個(gè)集合中添加一個(gè)middleware,Context進(jìn)入后，必須被該middleware處理。

不知道我這么說(shuō)，大家有沒(méi)有這種管道模型處理任務(wù)的概念了？

代碼解讀

不懂？沒(méi)關(guān)系，那我們結(jié)合代碼看看。

上面說(shuō)過(guò)，每個(gè)MiddleWare會(huì)把Context從自己的身體里面過(guò)一遍并主動(dòng)調(diào)用下一個(gè)中間件。

所以，中間件是什么？ 是一個(gè)傳入是Context,傳出也是Context的方法嗎？不是！

是一個(gè)傳入是委托，傳出也是委托，而這傳入傳出的委托的參數(shù)是Context,該委托如下：

/// <summary>
 /// 管道內(nèi)的委托任務(wù)
 /// </summary>
 /// <param name="context"></param>
 /// <returns></returns>
 public delegate Task PipeLineDelegate<in TContext>(TContext context);

所以中間件是下面這樣的一個(gè)Func，它肩負(fù)起了調(diào)用下一個(gè)中間件（委托）的重任：

Func<PipeLineDelegate<TContext>, PipeLineDelegate<TContext>>

而管道又是什么呢？  是Func的集合，如下：

IList<Func<PipeLineDelegate<TContext>, PipeLineDelegate<TContext>>> _components = new List<Func<PipeLineDelegate<TContext>, PipeLineDelegate<TContext>>>();

我們?cè)賁tartup方法里面的Configure方法里面的Use是在做什么呢？其實(shí)就是在給上面的管道_components添加一個(gè)func,如下：

public IPipeLineBuilder<TContext> Use(Func<PipeLineDelegate<TContext>, PipeLineDelegate<TContext>> func)
  {
   _components.Add(func);
   return this;
  }

但是在今天的Use中呢，我還想對(duì)原有的Use進(jìn)行一次重載，如下：

public IPipeLineBuilder<TContext> Use(Action<TContext> action, int? index = null)
  {
   Func<PipeLineDelegate<TContext>, PipeLineDelegate<TContext>> pipleDelegate = next =>
   {
    return context =>
    {
     action.Invoke(context);
     return next.Invoke(context);
    };
   };
   if (index.HasValue)
    if (index.Value > _components.Count)
     throw new Exception("插入索引超出目前管道大小");
    else
    {
     _components.Insert(index.Value, pipleDelegate);
    }
   else
   {
    _components.Add(next =>
    {
     return context =>
     {
      action.Invoke(context);
      return next.Invoke(context);
     };
    });
   }
   return this;
  }

可以看到，重載之后，傳入的變成了Action<TContext> action，因?yàn)槲蚁胪獠繉Ｗ⒂谧约阂嬲幚淼臉I(yè)務(wù)，而調(diào)用下一個(gè)middleware的事情封裝到方法內(nèi)部，不用外部來(lái)關(guān)心了，并且，可以通過(guò)傳入的index指定插入的中間件的位置，以此來(lái)控制業(yè)務(wù)的執(zhí)行順序。

最后，需要把傳入的委托鏈接起來(lái)，這就是管道的Build工作，代碼如下：

public PipeLineDelegate<TContext> Build()
  {
   var requestDelegate = (PipeLineDelegate<TContext>)(context => Task.CompletedTask);

   foreach (var func in _components.Reverse())
    requestDelegate = func(requestDelegate);

   return requestDelegate;
  }

到這里，管道相關(guān)的差不多說(shuō)完了，那我，我如何利用上面的思想來(lái)處理我的業(yè)務(wù)呢？

處理業(yè)務(wù) 

處理示意圖

步驟：

Ø 初始化三條處理管道（根本是New三個(gè)List<Task>集合，對(duì)應(yīng)前期準(zhǔn)備工作集合，處理中工作的集合，掃尾工作的集合）。

Ø 向三條管道中注入公共的處理任務(wù)。

Ø 根據(jù)傳入的流程類型動(dòng)態(tài)加載對(duì)應(yīng)的處理方法Handle()。

Ø Handle方法向三條管道中注入該類型的流程所對(duì)應(yīng)的特有任務(wù)。

Ø Build三條管道。

Ø 依此執(zhí)行準(zhǔn)備工作管道=>處理中管道=>處理后管道。

上面步驟可以概括成下面的代碼。

private void InitApproveFlow(ApproveFlowInitContext context)
  {
   var beforePipeLineBuilder = InitBeforePipeLine();
   var handlingPipeLineBuilder = InitHandlingPipeLine();
   var afterPipeLineBuilder = InitAfterPipeLine();

   RegisterEntityPipeLine(context.flowType, beforePipeLineBuilder, handlingPipeLineBuilder, afterPipeLineBuilder);

   var beforePipeLine = beforePipeLineBuilder.Build();
   var handlingPipeLine = handlingPipeLineBuilder.Build();
   var afterPipeLine = afterPipeLineBuilder.Build();
   
   beforePipeLine.Invoke(context);
   handlingPipeLine.Invoke(context);
   afterPipeLine.Invoke(context);
  }

其中，RegisterEntityPipLine()方法根據(jù)flowType動(dòng)態(tài)加載對(duì)應(yīng)的類，所有類繼承了一個(gè)公共的接口，接口暴露出了Handle方法。

private void RegisterEntityPipeLine(string flowType, IPipeLineBuilder<ApproveFlowInitContext> beforePipeLineBuilder,
   IPipeLineBuilder<ApproveFlowInitContext> handlingPipeLineBuilder,
   IPipeLineBuilder<ApproveFlowInitContext> afterPipeLineBuilder)
  {
   var handleClassName = ("類名的前綴" + flowType).ToLower();
   var type = AppDomain.CurrentDomain.GetAssemblies()
    .Where(a => a.FullName.Contains("程序及名稱"))
    .SelectMany(a =>
     a.GetTypes().Where(t =>
      t.GetInterfaces().Contains(typeof(類繼承的接口名稱))
     )
    ).FirstOrDefault(u =>
     u.FullName != null && u.Name.ToLower() == handleClassName
    );

   if (type == null)
    throw new ObjectNotFoundException("未找到名稱為[" + handleClassName + "]的類");

   var handle = (類繼承的接口名稱)_serviceProvider.GetService(type);
   handle.Handle(beforePipeLineBuilder, handlingPipeLineBuilder, afterPipeLineBuilder);
  }

Handle方法里面又做了什么呢？

public void Handle(IPipeLineBuilder<ApproveFlowInitContext> beforePipeLineBuilder, IPipeLineBuilder<ApproveFlowInitContext> handlingPipeLineBuilder, IPipeLineBuilder<ApproveFlowInitContext> afterPipeLineBuilder)
  {
   HandleBefore(beforePipeLineBuilder);
   Handling(handlingPipeLineBuilder);
   HandleAfter(afterPipeLineBuilder);
  }

分別向三個(gè)管道中添加 前、中、后 對(duì)應(yīng)的任務(wù)。

Q&A

Q1:如果處理任務(wù)依賴于上一個(gè)處理任務(wù)的處理結(jié)果怎么辦？

PipeLineDelegate<TContext> 中的TContext是一個(gè)對(duì)象，可以向該對(duì)象中添加對(duì)應(yīng)的屬性，上游任務(wù)處理任務(wù)并對(duì)Context中的屬性賦值，供下游的任務(wù)使用。

Q2:如果某一個(gè)任務(wù)需要在其他任務(wù)之前執(zhí)行怎么辦（需要插隊(duì)）？

PipeLineBuilder.Use() 中，有Index參數(shù)，可以通過(guò)該參數(shù)，指定插入任務(wù)的位置。

Q3:如果保證管道的通用性（不局限于某一業(yè)務(wù)）？

TContext是泛型，可以不同的任務(wù)創(chuàng)建一個(gè)對(duì)應(yīng)的TContext即可實(shí)現(xiàn)不同業(yè)務(wù)下的PipleLine的復(fù)用。

總結(jié)

以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)腳本之家的支持。

相關(guān)文章

最新評(píng)論