c# – 对相同的WCF请求进行分组

这样的事怎么样？你显然需要在字典本身上做一些同步,但至少它是一个开始.

private IDictionary<string,RequestToken> RequestTokens = 
   new Dictionary<string,RequestToken>();

public MyResponse MyMethod(MyRequest request)
{
   // get the MD5 for the request
   var md5 = GetMD5Hash(request);

   // check if another thread is processing/has processed an identical request
   RequestToken token;
   if (RequestTokens.TryGetValue(md5,out token))
   {
      // if the token exists already then wait till we can acquire the lock
      // which indicates the processing has finished and a response is ready
      // for us to reuse
      lock (token.Sync)
      {
         return token.Response;
      }
   }
   else
   {
      var token = new Token(md5);
      lock (token.Sync)
      {
         RequestTokens.Add(md5,token);

         // do processing here..
         var response = ....

         token.Response = response;

         return response;
      }
   }
}

private class RequestToken
{
   private readonly object _sync = new object();

   public RequestToken(string md5)
   {
      MD5 = md5;
   }

   public string MD5 { get; private set; }

   public object Sync { get { return _sync; } }

   public MyResponse Response { get; set; }
}

对我来说,这是我想要从业务逻辑中抽象出来的东西,我个人会使用PostSharp并写一个小属性来处理所有这些.

我写了一个Memoizer属性,根据请求在没有同步步骤的缓存响应行中做了类似的事情,所以你可以看看我做了什么并相应地修改它以实现你所追求的目标.