色尼玛亚洲综合影院,亚洲3atv精品一区二区三区,麻豆freexxxx性91精品,欧美在线91

Azure Services Bus(服務總線)中的工作流(workflow)

在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),轉載需保留來源!

鄭重聲明:本文版權歸原作者所有,轉載文章僅為傳播更多信息之目的,如作者信息標記有誤,請第一時間聯系我們修改或刪除,多謝。

主站蜘蛛池模板: 宁陵县| 司法| 大冶市| 绍兴市| 洛南县| 元谋县| 金溪县| 威宁| 绍兴县| 北安市| 德州市| 澄迈县| 班戈县| 梨树县| 通化市| 新宾| 怀集县| 石台县| 南和县| 石柱| 洛扎县| 泌阳县| 景东| 铜川市| 岳普湖县| 金门县| 探索| 耿马| 故城县| 内江市| 会泽县| 汶上县| 静安区| 萍乡市| 南靖县| 洛南县| 峨眉山市| 鄂伦春自治旗| 合川市| 建水县| 鹿邑县|