使用 IIS 和异步方法的 WCF 的最大并发会话数 - 释放资源

Question

我正在从表单调用 WCF 服务。服务托管在 IIS 中。该服务具有以下属性： InstanceContextMode.PerSession、ConcurrencyMode = ConcurrencyMode.Multiple

我已将所有并发调用、实例和会话的限制行为设置为最大 2000。

但是我似乎无法收到超过 200 个异步请求。此后，服务不再响应，会话最终超时。

我正在使用异步调用来调用服务中的方法，即 折叠 |语言：

IASyncResult res= Proxy.BeginMethod(endCall,null);

然后为了捕获响应，我有一个 endCall 函数，它接收 IASyncResult 并通过 EndMethod() 处理结果。

在负载模拟中，每秒调用 1 个方法，一切正常，直到大约 200 个调用，然后只需等待...（此时我从这 200 个调用中得到了 199 或 198 个响应）.. - 所以理论上是存在的不应该是 200 个并发会话，只有 2 个左右。

也许有一些我没有做的垃圾收集或关闭？ 有什么建议吗？

----更新---

我认为答案可能更多是代理的关闭不是以线程安全的方式处理的。正如 Radik 上面指出的，关闭代理很重要，但是由于许多 IASyncState 结果同时出现，您必须确保在正确的时间关闭正确的结果。

我确实尝试从线程中关闭关闭代理，让它单独处理它：

ThreadPool.QueueUserWorkItem(CloseProxy, ar.AsyncState);

但这似乎不起作用。对此有何建议？

Answer 1

当您在 VS 中创建服务引用时，生成的代理允许您通过回调或事件处理程序两种方式异步调用服务。还有两个不同的地方可以关闭代理。
小示例项目此处

//close proxy in callback function
private void ButtonCallbackClick(object sender, EventArgs e)
{
    var proxy = new ServiceClient("BasicHttpBinding_IService");
    proxy.BeginDoWork(DateTime.Now.ToShortDateString(), CallBack, proxy);
}

private void CallBack(IAsyncResult ar)
{
    var result = (ar.AsyncState as ServiceClient).EndDoWork(ar);
    if (ar.IsCompleted)
        UpdateView(result);
    CloseProxy(ar.AsyncState);
}
//close proxy in event handler
private void ButtonCompletedClick(object sender, EventArgs e)
{
    var proxy = new ServiceClient("BasicHttpBinding_IService");
    proxy.DoWorkAsync(DateTime.Now.ToShortDateString());
    proxy.DoWorkCompleted += DoWorkCompleted;
}

private void DoWorkCompleted(object sender, DoWorkCompletedEventArgs e)
{
    if (e.Error == null)
        UpdateView(e.Result);
    CloseProxy(sender);
}

private static void CloseProxy(object sender)
{
    var proxy = sender as ServiceClient;
    if (proxy == null) return;
    try
    {
        proxy.Close();
    }
    catch (CommunicationException e)
    {
        proxy.Abort();
    }
    catch (TimeoutException e)
    {
        proxy.Abort();
    }
    catch (Exception e)
    {
        proxy.Abort();
    }
}

private static bool _run = false;
//run async query in infinite cycle
private void ButtonCycleClick(object sender, EventArgs e)
{
    _run = !_run;
    if (!_run) return;
    Action<object> action = WaitEvent;
    ThreadPool.QueueUserWorkItem(a => action(action));
}

private void WaitEvent(object action)
{
    var proxy = new ServiceClient("BasicHttpBinding_IService");
    proxy.DoWorkAsync(DateTime.Now.ToShortDateString());
    proxy.DoWorkCompleted += (x, y) => DoWorkCompleted(x, y, action as Action<object>);
}

private void DoWorkCompleted(object sender, DoWorkCompletedEventArgs e, Action<object> action)
{
    if (!_run)
        return;

    if (e.Error == null)
        UpdateView(e.Result);
    CloseProxy(sender);
    action(action);
}