|
在Azure Services Platform上對于工作流服務的支持,一直是我很感興趣的內容。當然也是疑問比較多的領域。鑒于這方面的資料太少,所以今天就從AzureServicesKit中的一個DEMO出發,來大概了解一下這方面相關內容。
注:今天的示例位于AzureServicesKit安裝目錄/Labs/Ex02-RoutingWithXPath/end文件夾。
(編輯注:是AzureServicesKit/Labs/IntroWorkflowService/Ex02-RoutingWithXPath/end文件夾)
該示例場景展示的是一個定單(order)流程,如下圖:
注:圖中的兩個服務可能布置在1臺或N臺機器上。
在上圖中,我們看出在當前場景中存在兩個服務,即:
BillService(即定單生成)。 ShipOrderService(定單處理:包括處理定單相關信息等)
其中的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"會以鏈接方式綁定到工作流CloudServiceBusSend活動(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會以鏈接方式綁定到工作流CloudServiceBusSend活動(activity)的Action屬性上,即:
http://Microsoft.ServicePlatformLabs/Shipping/ProcessOrder
而這兩個服務都會被暴露到ServiceBus中以便讓用戶進行訪問操作,從而完成一個客戶下訂單的完整流程(CreateOrder)
而如何對這兩個服務進行安排組裝,就是通過WorkFlow的進行的。如果有開發過工作流經驗的開發者應該會很容易理解這個概念。不過這里還是要解釋一下,就是在云中運行的工作流與我們平時所了解的工作流(主要是在Activities方面)還是有些差異的,當然這并不意味著云中的工作流要更難于理解,恰恰相反,就目前而言,還是很容易的,下面是其在VS中的設計器中的截圖:
有關這幾個新添加的工作流activity,可能就要幾個篇幅來介紹和說明,因為今天的目的不在于此,所以就先略過這塊內容了。
另外就是目前在云中只支持CloudSequentialWorkFlow,如下圖:
目前還不支持狀態機工作流,但并不確保將來就不會出現。當然將來會不會出現workflow4中的flowchart型工作流就更不好說了。
假設我們最終要實現的工作流程如下:
1.接受客戶端post過來的請求,并獲取其中指定的節點信息,本DEMO中節點路徑為:
<root> <order> <total>節點值</total> </order></root>
2.通過對該節點值進行比較判斷,當值大于1000時則將工作流程轉入一個CloudDelay活動中,以進行延時操作(設置CloudDelay活動的TimeOut屬性)。當值小于或等于1000時則順序執行上面所介紹的兩個服務(BillingService,ShippingService)
將上面的流程中工作流進行表示(創建)的結果如下圖:
好了,現在我們有了工作流和服務,接下來就是通過編碼將服務運行起來以及將工作流發布到Azure上了。下面是服務的創建運行代碼:
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中進行配置的:

NET技術:Azure Services Bus(服務總線)中的工作流(workflow),轉載需保留來源!
鄭重聲明:本文版權歸原作者所有,轉載文章僅為傳播更多信息之目的,如作者信息標記有誤,請第一時間聯系我們修改或刪除,多謝。