本章節(jié)介紹 服務(wù)行為中的 并發(fā)與實(shí)例化行為，服務(wù)行為的介紹可以參考 《 WCF Behaviors（行為）》

并發(fā)與實(shí)例化的引入，相關(guān)的名詞解釋

并發(fā)（Concurrency）：對(duì)同時(shí)執(zhí)行的任務(wù)數(shù)量，度量單位為任務(wù)（如請求、作業(yè)、事務(wù)等）；

執(zhí)行時(shí)間（Execution Time）：完成任務(wù)所用的時(shí)間，度量單位為時(shí)間（如秒、毫秒等）；

吞吐量（Throughput）：固定時(shí)間內(nèi)完成的任務(wù)數(shù)量，度量單位為 任務(wù)/時(shí)間 如：請求/秒、事務(wù)/分鐘；

提高吞吐量的辦法：

減少執(zhí)行時(shí)間

????? 通過修改任務(wù)內(nèi)部算法或增加硬件資源來完成，WCF在此方面作用有限。

提高并發(fā)

?????? 通過提高單位時(shí)間內(nèi)的并發(fā)數(shù)量， WCF中控制另發(fā)的兩個(gè)行為：InstanceContextMode 和 ConcurrencyMode

?

ServiceBehavior 屬性不定義在接口上，而是服務(wù)類上，因?yàn)镾erviceBehavior屬性針對(duì)的是服務(wù)的行為，而不是服務(wù)的契約。

InstanceContextMode 服務(wù)行為用于控制實(shí)例化，取值說明：

Single ： 所有入站請求均共用同一個(gè)服務(wù)類的實(shí)例；

PerCall ：為每一個(gè)入站請求創(chuàng)建一個(gè)服務(wù)類的實(shí)例；

PerSession：為每一個(gè)會(huì)話創(chuàng)建一個(gè)服務(wù)類的實(shí)例，默認(rèn)值；

InstanceContextMode 的默認(rèn)值為PerSession，但當(dāng)使用無會(huì)話的信道（通道）或者無會(huì)話綁定時(shí)，會(huì)變化為PerCall行為。

ConcurrencyMode 服務(wù)行為用于控制服務(wù)實(shí)例內(nèi)的線程并發(fā)，取值說明：

Single：同一時(shí)刻僅能有一個(gè)線程訪問服務(wù)類，默認(rèn)值；

Reentrant：同一個(gè)是僅能有一個(gè)線程訪問服務(wù)類，但該線程可以暫時(shí)離開服務(wù)類進(jìn)入等待狀態(tài)，而后又激活繼續(xù)訪問；

Multiple：多線程并發(fā)訪問服務(wù)類。

Single 是最安全的設(shè)置，服務(wù)操作不需要擔(dān)心線程安全問題，Multiple 需要類具有內(nèi)置的線程安全能力。

同時(shí)使用 InstanceContextMode 與 ConcurrencyMode 這兩個(gè)設(shè)置，可以配置服務(wù)的實(shí)例化和并發(fā)來滿足特定的性能需求。

會(huì)話實(shí)例 - 單線程 - 默認(rèn)-示例

定義服務(wù)接口

[ServiceContract]public interface IStockService{ [OperationContract]double GetPrice(string ticker);}

實(shí)現(xiàn)服務(wù)，輸出線程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}

客戶端異步調(diào)用代碼

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);}

執(zhí)行結(jié)果

結(jié)果分析：

1. 對(duì)每個(gè)客戶端的請求，服務(wù)端僅生成了一個(gè)服務(wù)實(shí)例

2. 每個(gè)請求都在各自的線程中被執(zhí)行。

以上代碼采用net.tcp方式進(jìn)行綁定，net.tcp支持會(huì)話，因此InstanceContextMode取值為PerSession；

ConcurrencyMode.Single 設(shè)置使得每個(gè)WCF對(duì)于每個(gè)服務(wù)實(shí)例只允許一個(gè)線程。

多實(shí)例 - 單線程 - 示例

服務(wù)類代碼：

[ServiceBehavior(InstanceContextMode = InstanceContextMode.PerCall, ConcurrencyMode = ConcurrencyMode.Multiple)]public class StockService : IStockService

執(zhí)行結(jié)果

結(jié)果分析：

1. 為每個(gè)請求創(chuàng)建了一個(gè)實(shí)例；

2. 每個(gè)請求在各自的線程中處理請求。

InstanceContextMode.PerSession 在綁定不支持會(huì)話的情況下會(huì)演變?yōu)?InstanceContextMode.PerCall ，故如果采用BasicHttpBinding方式，則無須進(jìn)行設(shè)置。

單實(shí)例-多線程-示例

適用情況：

服務(wù)初始化代價(jià)高昂，如：構(gòu)造方法需要從數(shù)據(jù)庫中加載大量數(shù)據(jù)，或者構(gòu)建一個(gè)大的數(shù)據(jù)結(jié)構(gòu)；

服務(wù)代碼中存在鎖機(jī)制，可以保護(hù)線程局部安全，提高伸縮性；

服務(wù)類代碼：

[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Multiple)]public class StockService : IStockService

執(zhí)行結(jié)果：

結(jié)果分析：

1. 服務(wù)端僅創(chuàng)建了一次實(shí)例；

2. 每次請求是在不同的線程中執(zhí)行的；

單實(shí)例 - 單線程 - 單例模式

適用情況：沒有鎖機(jī)制，要求先進(jìn)先出處理方式，調(diào)用者存在共享情況

服務(wù)端代碼：

[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Single)]public class StockService : IStockService

執(zhí)行結(jié)果：

結(jié)果分析：

1. 與 會(huì)話實(shí)例 - 單線程 - 示例中不同的是，顯式聲明 InstanceContextMode = InstanceContextMode.Single 后，一旦host成功，自動(dòng)會(huì)創(chuàng)建服務(wù)實(shí)例;

2. 多個(gè)請求重用一個(gè)線程，

ConcurrencyMode.Single 設(shè)置使得WCF在同一時(shí)刻只允許運(yùn)行一個(gè)服務(wù)類的一個(gè)實(shí)例，并不控制創(chuàng)建線程的總量

?

會(huì)話級(jí)實(shí)例

要實(shí)現(xiàn)基于會(huì)話的服務(wù)實(shí)例，必須要實(shí)現(xiàn)兩點(diǎn)：

1. 在契約級(jí)打開會(huì)話功能：SessionMode ： Allowed|NotAllowed|Requied；

2. 在服務(wù)級(jí)設(shè)置按會(huì)話創(chuàng)建服務(wù)實(shí)例；

雖然會(huì)話是在契約級(jí)別設(shè)置是否允許，但其真正實(shí)現(xiàn)是在綁定元素指定的信道，因此服務(wù)第一次啟動(dòng)時(shí)會(huì)校驗(yàn)契約行為與信道的兼容性，如果信道需要會(huì)話，而綁定不支持會(huì)話(如：basicHttpBinding)，則會(huì)拋出異常

會(huì)話實(shí)例 - 多線程 - 示例

代碼：

[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;}}

執(zhí)行結(jié)果：啟動(dòng)兩個(gè)客戶端，同時(shí)調(diào)用

結(jié)果分析：

1. 創(chuàng)建了兩個(gè)實(shí)例，分別針對(duì)兩個(gè)客戶端；

2. 計(jì)數(shù)器針對(duì)兩個(gè)客戶端是獨(dú)立的，分別計(jì)數(shù)；

3. 服務(wù)端處理請求在3個(gè)線程中進(jìn)行，屬于多線程。

如果將InstanceContextMode改為Single，則計(jì)數(shù)器將從1增長到6

使用配置 控制 實(shí)例、線程

通過配置對(duì)程序中 的多實(shí)例、多線程、會(huì)話數(shù)進(jìn)行控制

maxConcurrentInstances ： 最大并發(fā)實(shí)例數(shù)，當(dāng)InstanceContextMode取值為 PerSession或PerCall 時(shí)此配置會(huì)起作用，Single表示只存在一個(gè)實(shí)例；

maxConcurrentCalls：最大并發(fā)調(diào)用數(shù)量，當(dāng) ConcurrencyMode 為 Mutiple時(shí)起作用；

maxConcurrentSeesions：最大會(huì)話數(shù)量，當(dāng)InstanceContextMode取值為PerSession時(shí)起作用，當(dāng)達(dá)到最大數(shù)量時(shí)，會(huì)等待其他會(huì)話關(guān)閉。

轉(zhuǎn)載于:https://www.cnblogs.com/jerryshi/archive/2011/09/27/2192288.html

總結(jié)

以上是生活随笔為你收集整理的服务行为 之 并发与实例化的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。