色尼玛亚洲综合影院,亚洲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),轉載需保留來源!

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

主站蜘蛛池模板: 宜都市| 浮山县| 中江县| 久治县| 连南| 宁国市| 六安市| 车致| 济阳县| 徐水县| 南投市| 拜城县| 黄山市| 基隆市| 郑州市| 洛隆县| 吉木乃县| 太白县| 监利县| 蕉岭县| 三门峡市| 龙胜| 察哈| 延长县| 恩平市| 新昌县| 巧家县| 萍乡市| 嘉义市| 鱼台县| 吴江市| 尼玛县| 綦江县| 和龙市| 桃江县| 广西| 洛隆县| 英吉沙县| 河津市| 黄石市| 招远市|