Question

WCF为什么不能并发访问

Answer 1

并发是对同时执行的任务数量的度量，单位为任务（如请求、作业、事务等）。执行时间是对完成任务所用时间的度量，单位为时间（如毫秒、秒等）。吞吐量是在固定的时间内完成的任务数量的度量，单位为任务/时间（如请求/秒、事务/秒等）。可以通过减少执行时间或提高并发来提高吞吐量。在WCF中可以通过InstanceContextMode和ConcurrencyMode来控制并发行为。
InstanceContextMode用于控制服务类实例化，可以有以下几种取值：
Single：一个服务类实例处理所有客户端的所有请求。
PerCall：为每一个客户端的每一个请求创建一个服务类实例。
PerSession：为每一个客户端会话创建一个服务类实例（也就是每一个客户端会话的所有请求共用一个服务类实例）。
ConcurrencyMode用来控制服务类实例内的线程并发。有以下取值：
Single：在同一时刻只有一个线程可以访问服务类实例。
Reentrant：在同一时刻只有一个线程访问服务类实例，但是线程能暂时离开服务类实例，稍后回来并继续访问。
Mutiple：多线程能并发访问服务类实例。
下面用简单的代码来展示InstanceContextMode和ConcurrencyMode不同的设置组合对服务类实例化和并发的影响。这次用NetTcpBinding绑定，它支持会话。
服务契约：
using System;
using System.ServiceModel;

namespace IFruitSvc
{
[ServiceContract(Namespace="http://www.cnblogs.com/qiuwuyu")]
publicinterface IFruitService
{
[OperationContract]
string GetFruitName();
}
}
服务类：
using System;
using System.ServiceModel;
using IFruitSvc;
using System.Threading;
using System.ServiceModel.Description;

namespace FruitSvc
{
publicclass FruitService:IFruitService
{
FruitService()
{
Console.WriteLine("{0} : Created new instance of FruitService on thread", DateTime.Now.Ticks);
}
publicstring GetFruitName()
{
Console.WriteLine("{0} : GetFruitName called on thread {1} ", DateTime.Now.Ticks,
Thread.CurrentThread.ManagedThreadId);
return"banana";
}
}
}
服务端寄存：
using System;
using System.ServiceModel;
using System.ServiceModel.Description;
using IFruitSvc;
using FruitSvc;

namespace WcfInstanceHost
{
class Program
{
staticvoid Main(string[] args)
{
using (ServiceHost host =new ServiceHost(typeof(FruitService),
new Uri("net.tcp://localhost:8000")))
{
ServiceEndpoint sed= host.AddServiceEndpoint(typeof(IFruitService), new NetTcpBinding(), "FruitService");
//设置IFruitService的ServiceContract特性的SessionMode
sed.Contract.SessionMode = SessionMode.Allowed;

ServiceMetadataBehavior behavior =new ServiceMetadataBehavior();
host.Description.Behaviors.Add(behavior);

ServiceBehaviorAttribute behaviorAttr = host.Description.Behaviors.Find<ServiceBehaviorAttribute>();
if (behaviorAttr ==null)
{
behaviorAttr =new ServiceBehaviorAttribute();
}
//设置服务类FruitService的ServiceBehavior特性的ConcurrencyMode和InstanceContextMode
behaviorAttr.ConcurrencyMode = ConcurrencyMode.Single;
behaviorAttr.InstanceContextMode = InstanceContextMode.PerCall;

host.AddServiceEndpoint(typeof(IMetadataExchange),
MetadataExchangeBindings.CreateMexTcpBinding(), "mex");

host.Open();
Console.WriteLine("Fruit Service Is Running...");
Console.ReadLine();
}
}
}
}
运行此控制台程序，用如下命令生成代理和配置文件

“/a”是为了生存异步调用方法。而后把生存的两个文件添加到客户端项目内。
客户端调用代码：
using System;
using System.Threading;

namespace WcfInstanceClient
{
class Program
{
staticvoid Main(string[] args)
{
FruitServiceClient proxy =new FruitServiceClient();
for (int i =0; i <4; i++)
{
Console.WriteLine("{0}: Begin Calling GetFruitName", DateTime.Now.Ticks);
proxy.BeginGetFruitName(GetFruitNameCallBack, proxy);
}

Console.ReadLine();
}
staticvoid GetFruitNameCallBack(IAsyncResult ar)
{
string name = ((FruitServiceClient)ar.AsyncState).EndGetFruitName(ar);
Console.WriteLine("{0}: End FruitName:{1} ", DateTime.Now.Ticks, name);
}
}
}
首先设置ConcurrencyMode.Single和InstanceContextMode.PerCall 这种组合设置会为每次调用生成一个服务类实例。
运行结果：

下面用ConcurrencyMode.Single和InstanceContextMode.PerSession测试下，结果应该是每个客户会话一个服务类实例，这次启动两个客户端，应该只有两个服务类实例。
执行结果，服务端：

客户端：

下面我们用ConcurrencyMode.Multiple和InstanceContextMode.PerSession进行测试，因为同一会话中允许多个线程并发访问，所以需要手工控制访问的安全性。
修改服务类代码如下：
publicclass FruitService:IFruitService
{
//添加一对象，对此对象访问加锁
object lockObj =newobject();
privateint n =0;
FruitService()
{
Console.WriteLine("{0} : Created new instance of FruitService on thread", DateTime.Now.Ticks);
}
publicstring GetFruitName()
{
string name ="banana";
Console.WriteLine("{0} : GetFruitName called on thread {1} ", DateTime.Now.Ticks,
Thread.CurrentThread.ManagedThreadId);
lock (lockObj)
{
name=name +"_"+ (++n).ToString();
}
return name;
}
}
程序的执行结果（还是运行两个客户端）服务端：

客户端：

假如把InstanceContextMode设置为PerCall那将都会是1。还有几种组合就不一一测试。