服务行为 之 并发与实例化
本章節介紹 服務行為中的 并發與實例化行為,服務行為的介紹可以參考 《 WCF Behaviors(行為)》
并發與實例化的引入,相關的名詞解釋
并發(Concurrency):對同時執行的任務數量,度量單位為任務(如請求、作業、事務等);
執行時間(Execution Time):完成任務所用的時間,度量單位為時間(如秒、毫秒等);
吞吐量(Throughput):固定時間內完成的任務數量,度量單位為 任務/時間 如:請求/秒、事務/分鐘;
提高吞吐量的辦法:
????? 通過修改任務內部算法或增加硬件資源來完成,WCF在此方面作用有限。
?????? 通過提高單位時間內的并發數量, WCF中控制另發的兩個行為:InstanceContextMode 和 ConcurrencyMode
?
ServiceBehavior 屬性不定義在接口上,而是服務類上,因為ServiceBehavior屬性針對的是服務的行為,而不是服務的契約。
InstanceContextMode 服務行為用于控制實例化,取值說明:
InstanceContextMode 的默認值為PerSession,但當使用無會話的信道(通道)或者無會話綁定時,會變化為PerCall行為。
ConcurrencyMode 服務行為用于控制服務實例內的線程并發,取值說明:
Single:同一時刻僅能有一個線程訪問服務類,默認值;
Reentrant:同一個是僅能有一個線程訪問服務類,但該線程可以暫時離開服務類進入等待狀態,而后又激活繼續訪問;
Multiple:多線程并發訪問服務類。
Single 是最安全的設置,服務操作不需要擔心線程安全問題,Multiple 需要類具有內置的線程安全能力。
同時使用 InstanceContextMode 與 ConcurrencyMode 這兩個設置,可以配置服務的實例化和并發來滿足特定的性能需求。
會話實例 - 單線程 - 默認-示例
定義服務接口
[ServiceContract]public interface IStockService{ [OperationContract]double GetPrice(string ticker);}實現服務,輸出線程ID
public class StockService : IStockService{public StockService(){Console.WriteLine("{0}:Created new instance of StockService on thread", DateTime.Now);}#region IStockService Memberspublic double GetPrice(string ticker){Console.WriteLine("{0}: GetPrice called on thread {1}", DateTime.Now, Thread.CurrentThread.ManagedThreadId);return 94.95;}#endregion}客戶端異步調用代碼
public static void GetPriceWithAsync(string address, Binding binding){//IStockService proxy = CreateStockServiceProxy(address, binding);StockServiceClient proxy = new StockServiceClient(stockContext, binding, new EndpointAddress(address));IAsyncResult arGetPrice;for (int i = 0; i < 3; i++){Console.WriteLine("{0} : Calling GetPrice", DateTime.Now);arGetPrice = proxy.BeginGetPrice("msft", GetPriceCallback, proxy);Thread.Sleep(100);//為了讓輸出更清晰Interlocked.Increment(ref c);}while (c > 0){Thread.Sleep(1000);}stockProxy.Close();}static void GetPriceCallback(IAsyncResult ar){double price = ((StockServiceClient)ar.AsyncState).EndGetPrice(ar);Console.WriteLine("{0}: GetPrice result:{1}", DateTime.Now, price);Interlocked.Decrement(ref c);}執行結果
結果分析:
1. 對每個客戶端的請求,服務端僅生成了一個服務實例
2. 每個請求都在各自的線程中被執行。
以上代碼采用net.tcp方式進行綁定,net.tcp支持會話,因此InstanceContextMode取值為PerSession;
ConcurrencyMode.Single 設置使得每個WCF對于每個服務實例只允許一個線程。
多實例 - 單線程 - 示例
服務類代碼:
[ServiceBehavior(InstanceContextMode = InstanceContextMode.PerCall, ConcurrencyMode = ConcurrencyMode.Multiple)]public class StockService : IStockService執行結果
結果分析:
1. 為每個請求創建了一個實例;
2. 每個請求在各自的線程中處理請求。
InstanceContextMode.PerSession 在綁定不支持會話的情況下會演變為 InstanceContextMode.PerCall ,故如果采用BasicHttpBinding方式,則無須進行設置。
單實例-多線程-示例
適用情況:
服務初始化代價高昂,如:構造方法需要從數據庫中加載大量數據,或者構建一個大的數據結構;
服務代碼中存在鎖機制,可以保護線程局部安全,提高伸縮性;
服務類代碼:
[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Multiple)]public class StockService : IStockService執行結果:
結果分析:
1. 服務端僅創建了一次實例;
2. 每次請求是在不同的線程中執行的;
單實例 - 單線程 - 單例模式
適用情況:沒有鎖機制,要求先進先出處理方式,調用者存在共享情況
服務端代碼:
[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Single)]public class StockService : IStockService執行結果:
結果分析:
1. 與 會話實例 - 單線程 - 示例中不同的是,顯式聲明 InstanceContextMode = InstanceContextMode.Single 后,一旦host成功,自動會創建服務實例;
2. 多個請求重用一個線程,
ConcurrencyMode.Single 設置使得WCF在同一時刻只允許運行一個服務類的一個實例,并不控制創建線程的總量
?
會話級實例
要實現基于會話的服務實例,必須要實現兩點:
1. 在契約級打開會話功能:SessionMode : Allowed|NotAllowed|Requied;
2. 在服務級設置按會話創建服務實例;
雖然會話是在契約級別設置是否允許,但其真正實現是在綁定元素指定的信道,因此服務第一次啟動時會校驗契約行為與信道的兼容性,如果信道需要會話,而綁定不支持會話(如:basicHttpBinding),則會拋出異常
會話實例 - 多線程 - 示例
代碼:
[DataContract]public class StockPrice{[DataMember]public double Price;[DataMember]public int CallsCounter;}[ServiceBehavior(InstanceContextMode = InstanceContextMode.PerSession, ConcurrencyMode = ConcurrencyMode.Multiple)]public class StockService : IStockService{ public StockService(){Console.WriteLine("{0}:Created new instance of StockService on thread", DateTime.Now);}public StockPrice GetStockPrice(string ticker){StockPrice p = new StockPrice();Console.WriteLine("{0}: GetPrice called on thread {1}", DateTime.Now, Thread.CurrentThread.ManagedThreadId);p.Price = 94.85;lock (locker){p.CallsCounter = ++callsCounter;}Thread.Sleep(1000);return p;}}執行結果:啟動兩個客戶端,同時調用
結果分析:
1. 創建了兩個實例,分別針對兩個客戶端;
2. 計數器針對兩個客戶端是獨立的,分別計數;
3. 服務端處理請求在3個線程中進行,屬于多線程。
如果將InstanceContextMode改為Single,則計數器將從1增長到6
使用配置 控制 實例、線程
通過配置對程序中 的多實例、多線程、會話數進行控制
maxConcurrentInstances : 最大并發實例數,當InstanceContextMode取值為 PerSession或PerCall 時此配置會起作用,Single表示只存在一個實例;
maxConcurrentCalls:最大并發調用數量,當 ConcurrencyMode 為 Mutiple時起作用;
maxConcurrentSeesions:最大會話數量,當InstanceContextMode取值為PerSession時起作用,當達到最大數量時,會等待其他會話關閉。
轉載于:https://www.cnblogs.com/jerryshi/archive/2011/09/27/2192288.html
總結
以上是生活随笔為你收集整理的服务行为 之 并发与实例化的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 链表应用——多项式相加
- 下一篇: 软件开发过程(CMMI/RUP/XP/M