異步調用同步webservice方法

Question

我不得不每次在不同參數的循環中調用約100次web服務方法。 Web服務只有同步方法。目前我正在一個控制檯應用程序中測試它，並且在同步進行數據時需要十分鐘的時間才能獲取數據！

我想要的： 並行運行10個請求。完成後，執行接下來的十個呼叫。 這當然應該是異步的。

該功能將託管在IIS託管的wcf服務中。

概述： 客戶端調用使用參數一次WCF服務。 wcf服務方法應該異步調用另一個web服務一百次並將最終數據保存到Excel中。

我看過，那Task.Run在Web應用程序中使用時不是一個好主意。

那麼，如何在Web上下文中異步調用同步Web服務方法？

我使用的CRM Microsoft.Xrm.Sdk，版本= 7.0.0.0，文化=中性公鑰= 31bf3856ad364e35

var orders = _serviceProxy.RetrieveMultiple(new FetchExpression(strXmlFetch)); 

RetrieveMultiple得到其中查詢被定義並執行所請求的XML片段（strXmlFetch）。 方法駐留在這裏：

命名空間 Microsoft.Xrm.Sdk.Client
類 OrganizationServiceProxy

public EntityCollection RetrieveMultiple(QueryBase query); 

引擎蓋下的客戶端SDK確實主叫RetrieveMultiple時follwoing。

using (OrganizationServiceContextInitializer organizationServiceContextInitializer = new OrganizationServiceContextInitializer(this)) 
{ 
    entityCollection = base.ServiceChannel.Channel.RetrieveMultiple(query); 
    return entityCollection; 
} 

我還沒有實現任何東西，因爲我需要異步執行請求的起點。

Answer 1

這當然應該是異步的。

那麼，這將是理想的。但是，OrganizationServiceProxy does not have asynchronous methods（neither does IOrganizationService，所以直接使用ServiceChannel.Channel也無濟於事）。

因此，首先要做的就是要求微軟將異步API添加到該客戶端庫。

我看到，在Web應用程序中使用Task.Run並不是一個好主意。

通常情況是這樣;你想調用異步API。在這種情況下哪些不可用。

那麼，如何在Web上下文中異步調用同步Web服務方法？

這是不可能的。你的選擇是：

1. 只是保持同步，一次一個。是的，這會花費更長的時間。
2. 使它平行。

與服務器端的並行處理的問題是，你現在使用N線程一個請求，我們可以真的很快把你的網絡服務器癱瘓。我不建議在生產代碼中使用這種方法，尤其是在通過Internet公開的情況下。

但是，如果你肯定不會有太多調用WCF服務，您可以在並行執行。

，因爲你需要收集來自並行查詢結果，我推薦使用Parallel LINQ（AsParallel）指定WithDegreeOfParallelism(10)，是這樣的：

IEnumerable<EntityCollection> GetAll(OrganizationServiceProxy proxy, IEnumerable<QueryBase> queries) 
{ 
    return queries.AsParallel().WithDegreeOfParallelism(10) 
     .Select(query => proxy.RetrieveMultiple(query)); 
} 

Answer 2

的Web服務只同步方法

網絡默認服務產生有關BeginXX, EndXXAsynchronous方法，這是Asynchronous Programming Model一部分，但它們不是可以通過Async-Await消耗的一個，因爲他們不要返回Task。

我想要什麼：運行10個請求並行。完成後，執行接下來的十個呼叫。這當然應該是異步的。

在真正Async電話，因爲沒有threads被調用和它適用於IO完成端口，因此你就可以開始有更多的電話，不僅僅是10。否則，一次安排10個異步請求的邏輯必須是自定義的，即使在使用Threadpool時也沒有開箱即用的機制，但並不保證並行請求的數量，但您可以設置Max Degree of Parallelism，以獲得更高並行API的限制。

概述：客戶端用params調用wcf服務一次。 wcf服務方法應該異步調用另一個web服務一百次並將最終數據保存到Excel中。

您希望所有的調用都是異步的，這樣就不會阻止Ui線程，無論是對於wcf服務還是web服務。

我讀過Task.Run在Web應用程序中使用時不是一個好主意。

真，因爲ThreadPool線程調用得到，它不會做任何事情後分派IO調用Web Service

那麼，如何異步調用同步Web服務方法，在網絡語境？

需要使用Sync方法的異步包裝，這是反模式，但沒有其他選擇。這將需要一個ThreadPool線，是這樣的：

public class AsyncWrapper 
{ 
    public async Task CallWcfAsync(<Parameters>) 
    { 
     SynchronizationContext _synchronizationContext = 
     SynchronizationContext.Current; 

    try 
    { 
     SynchronizationContext.SetSynchronizationContext(null); 
     await Task.Run(() => CallWcfMethod(<Parameters>)); 
    } 
    finally 
    {    
     SynchronizationContext.SetSynchronizationContext 
     (_synchronizationContext); 
    } 
    } 
} 

要點：

1. CallWcfAsync是您需要的Async wrapper method。

2. 通知我已在同步上下文設置爲Null執行之前，然後重新設置，這是在Web應用程序中的行爲類似ConfigureAwait(false)，否則會導致僵局，爲Sychronization Context等待時被阻塞。