拨打许多网络服务的最佳方式？

我有30家子公司,每家公司都实施了他们的网络服务(使用不同的技术).

我需要实现一个Web服务来聚合它们,例如,所有子公司Web服务都有一个带有名称的Web方法,GetUserPoint(int nationalCode)我需要实现我的Web服务,它将调用所有这些并收集所有响应(例如总和)分数).

这是我的基类:

public abstract class BaseClass
{ // all same attributes and methods
  public long GetPoint(int nationalCode);
}

对于每个子公司Web服务,我实现了一个继承此基类并定义自己的GetPoint方法的类.

public class Company1
{
  //implement own GetPoint method (call a web service).
}

至

public class CompanyN
{
  //implement own GetPoint method (call a web service).
}

所以,这是我的网络方法:

        [WebMethod]
        public long MyCollector(string nationalCode)
        {

           BaseClass[] Clients = new BaseClass[]  { new Company1(),//... ,new Company1()}

           long Result = 0;
           foreach (var item in Clients)
           {
                long ResultTemp = item.GetPoint(nationalCode);
                Result += ResultTemp;
           }
       return Result;
       }

好的,它可以工作,但速度很慢,因为每个子公司的Web服务都托管在不同的服务器上(在互联网上).

我可以使用这样的并行编程:(这称为并行编程!？)

    foreach (var item in Clients)
    {
                    Tasks.Add(Task.Run(() =>
                        {
                        Result.AddRange(item.GetPoint(MasterLogId, mobileNumber));                  
                    }
      }

我认为并行编程(和线程)对这个解决方案并不好,因为我的解决方案是IO绑定(不是CPU密集型)!

调用每个外部Web服务都很慢,对不对？许多线程正在等待获得响应!

我认为异步编程是最好的方法,但我是异步编程和并行编程的新手.

什么是最好的方法？(parallel.foreach - async TAP - async APM - async EAP -threading)

请给我写一个例子.

看到有人完成了他们的功课,这令人耳目一新.

首先,从.NET 4开始(今天仍然如此)TAP是.NET中异步工作流的首选技术.任务很容易组合,如果它们提供真实的Task返回API ,您可以轻松地并行化Web服务调用.现在你已经"假装"了它Task.Run,而且暂时这对你的目的来说已经足够了.当然,您的线程池线程将花费大量时间阻塞,但如果服务器负载不是很高,即使不是理想的事情,您也可以很好地解决它.

您只需要在代码中修复潜在的竞争条件(更多关于此结果).

如果您想遵循最佳实践,那么您可以选择真正的TAP.如果您的API提供Task了开箱即用的退回方法,那很容易.如果没有,它不会游戏结束,因为APM和EAP可以很容易地转换为TAP.MSDN参考:https://msdn.microsoft.com/en-us/library/hh873178(v = vs.110).aspx

我还会在这里添加一些转换示例.

APM(取自另一个SO问题):

MessageQueue不提供ReceiveAsync方法,但我们可以通过Task.Factory.FromAsync以下方式来玩球:

public static Task ReceiveAsync(this MessageQueue messageQueue)
{
    return Task.Factory.FromAsync(messageQueue.BeginReceive(), messageQueue.EndPeek);
}

...

Message message = await messageQueue.ReceiveAsync().ConfigureAwait(false);

如果您的Web服务代理有BeginXXX/ EndXXX方法,那么这就是要走的路.

EAP

假设您有一个旧的Web服务代理SoapHttpClientProtocol,只使用基于事件的异步方法.您可以将它们转换为TAP,如下所示:

public Task GetPointAsyncTask(this PointWebService webService, int nationalCode)
{
    TaskCompletionSource tcs = new TaskCompletionSource();

    webService.GetPointAsyncCompleted += (s, e) =>
    {
        if (e.Cancelled)
        {
            tcs.SetCanceled();
        }
        else if (e.Error != null)
        {
            tcs.SetException(e.Error);
        }
        else
        {
            tcs.SetResult(e.Result);
        }
    };

    webService.GetPointAsync(nationalCode);

    return tcs.Task;
}

...

using (PointWebService service = new PointWebService())
{
    long point = await service.GetPointAsyncTask(123).ConfigureAwait(false);
}

在汇总结果时避免竞争

关于聚合并行结果,您的TAP循环代码几乎是正确的,但您需要避免在您的实体内部改变共享状态,Task因为它们可能会并行执行.Result在您的情况下共享状态- 这是某种集合.如果这个集合不是线程安全的(即如果它是一个简单的List),那么你有一个竞争条件,你可能会得到异常和/或丢弃结果Add(我假设AddRange在你的代码中是一个错字,但如果没有 -以上仍然适用).

一个简单的异步友好重写可以修复你的种族,如下所示:

List> tasks = new List>();

foreach (BaseClass item in Clients) {
    tasks.Add(item.GetPointAsync(MasterLogId, mobileNumber));                  
}

long[] results = await Task.WhenAll(tasks).ConfigureAwait(false);

如果您现在决定懒惰并坚持使用该Task.Run解决方案,更正后的版本将如下所示:

List> tasks = new List>();

foreach (BaseClass item in Clients)
{
    Task dodgyThreadPoolTask = Task.Run(
        () => item.GetPoint(MasterLogId, mobileNumber)
    );

    tasks.Add(dodgyThreadPoolTask);                  
}

long[] results = await Task.WhenAll(tasks).ConfigureAwait(false);