|
|
在Azure Services Platform上對(duì)于工作流服務(wù)的支持，一直是我很感興趣的內(nèi)容。當(dāng)然也是疑問(wèn)比較多的領(lǐng)域。鑒于這方面的資料太少，所以今天就從AzureServicesKit中的一個(gè)DEMO出發(fā)，來(lái)大概了解一下這方面相關(guān)內(nèi)容。
注：今天的示例位于AzureServicesKit安裝目錄/Labs/Ex02-RoutingWithXPath/end文件夾。
(編輯注：是AzureServicesKit/Labs/IntroWorkflowService/Ex02-RoutingWithXPath/end文件夾)
該示例場(chǎng)景展示的是一個(gè)定單(order)流程，如下圖：
注：圖中的兩個(gè)服務(wù)可能布置在1臺(tái)或N臺(tái)機(jī)器上。
在上圖中，我們看出在當(dāng)前場(chǎng)景中存在兩個(gè)服務(wù)，即：
BillService（即定單生成）。 ShipOrderService(定單處理：包括處理定單相關(guān)信息等)
其中的BillService的代碼如下：
[ServiceContract(Name = "Billing", Namespace = "http://Microsoft.ServicePlatformLabs")]public class BillingService{ [OperationContract(Name = "Invoice", IsOneWay = true)] public void Invoice(string orderId, string total) { Console.WriteLine("Invoice for Order {0} ({1}) generated", orderId, total); }}
注：上面的ServiceContract屬性Name="Billing"和OperationContract屬性Name = "Invoice"會(huì)以鏈接方式綁定到工作流CloudServiceBusSend活動(dòng)(activity)的Action屬性上，即：
http://Microsoft.ServicePlatformLabs/Billing/Invoice
ShippingService的代碼如下：
[ServiceContract(Name = "Shipping", Namespace = "http://Microsoft.ServicePlatformLabs")]public class ShippingService{ [OperationContract(Name = "ProcessOrder", IsOneWay = true)] public void ProcessOrder(string orderId) { Console.WriteLine("Processing Shipping information for Order {0}", orderId); }}
同理，ShippingService會(huì)以鏈接方式綁定到工作流CloudServiceBusSend活動(dòng)(activity)的Action屬性上，即：
http://Microsoft.ServicePlatformLabs/Shipping/ProcessOrder
而這兩個(gè)服務(wù)都會(huì)被暴露到ServiceBus中以便讓用戶進(jìn)行訪問(wèn)操作，從而完成一個(gè)客戶下訂單的完整流程（CreateOrder）
而如何對(duì)這兩個(gè)服務(wù)進(jìn)行安排組裝，就是通過(guò)WorkFlow的進(jìn)行的。如果有開(kāi)發(fā)過(guò)工作流經(jīng)驗(yàn)的開(kāi)發(fā)者應(yīng)該會(huì)很容易理解這個(gè)概念。不過(guò)這里還是要解釋一下，就是在云中運(yùn)行的工作流與我們平時(shí)所了解的工作流（主要是在Activities方面）還是有些差異的，當(dāng)然這并不意味著云中的工作流要更難于理解，恰恰相反，就目前而言，還是很容易的，下面是其在VS中的設(shè)計(jì)器中的截圖：
有關(guān)這幾個(gè)新添加的工作流activity，可能就要幾個(gè)篇幅來(lái)介紹和說(shuō)明，因?yàn)榻裉斓哪康牟辉谟诖耍跃拖嚷赃^(guò)這塊內(nèi)容了。
另外就是目前在云中只支持CloudSequentialWorkFlow,如下圖：
目前還不支持狀態(tài)機(jī)工作流，但并不確保將來(lái)就不會(huì)出現(xiàn)。當(dāng)然將來(lái)會(huì)不會(huì)出現(xiàn)workflow4中的flowchart型工作流就更不好說(shuō)了。
假設(shè)我們最終要實(shí)現(xiàn)的工作流程如下：
1.接受客戶端post過(guò)來(lái)的請(qǐng)求，并獲取其中指定的節(jié)點(diǎn)信息，本DEMO中節(jié)點(diǎn)路徑為：
<root> <order> <total>節(jié)點(diǎn)值</total> </order></root>
2.通過(guò)對(duì)該節(jié)點(diǎn)值進(jìn)行比較判斷，當(dāng)值大于1000時(shí)則將工作流程轉(zhuǎn)入一個(gè)CloudDelay活動(dòng)中，以進(jìn)行延時(shí)操作（設(shè)置CloudDelay活動(dòng)的TimeOut屬性）。當(dāng)值小于或等于1000時(shí)則順序執(zhí)行上面所介紹的兩個(gè)服務(wù)（BillingService，ShippingService）
將上面的流程中工作流進(jìn)行表示（創(chuàng)建）的結(jié)果如下圖：
好了，現(xiàn)在我們有了工作流和服務(wù)，接下來(lái)就是通過(guò)編碼將服務(wù)運(yùn)行起來(lái)以及將工作流發(fā)布到Azure上了。下面是服務(wù)的創(chuàng)建運(yùn)行代碼：
internal static void Main(){ var billingServiceHost = new ServiceHost(typeof(BillingService)); Console.WriteLine("BillingService hosted at:"); Console.WriteLine("/t" + billingServiceHost.Description.Endpoints[0].Address.Uri); billingServiceHost.Open(); var shippingServiceHost = new ServiceHost(typeof(ShippingService)); Console.WriteLine("ShippingService hosted at:"); Console.WriteLine("/t" + shippingServiceHost.Description.Endpoints[0].Address.Uri); shippingServiceHost.Open(); Console.WriteLine(); Console.WriteLine("Press [Enter] to exit"); Console.ReadLine(); billingServiceHost.Close(); shippingServiceHost.Close();}
上面代碼中的Address.Uri屬性是在app.config中進(jìn)行配置的：
代碼在這里展開(kāi) 
NET技術(shù)：Azure Services Bus(服務(wù)總線)中的工作流(workflow)，轉(zhuǎn)載需保留來(lái)源！
鄭重聲明：本文版權(quán)歸原作者所有，轉(zhuǎn)載文章僅為傳播更多信息之目的，如作者信息標(biāo)記有誤，請(qǐng)第一時(shí)間聯(lián)系我們修改或刪除，多謝。
