如何在依赖注入中使用异步方法

Question

我正在开发一个 .net core (2.2) web 应用程序，并且有一个控制器负责按需数据同步处理。同样，我保留了一个单击按钮，单击该按钮会触发对服务的异步方法的调用。

在内部，此服务调用在操作下方处理

1. 从数据库中获取数据以进行数据同步处理
2. 将数据分批进行数据同步处理的批处理模式
3. 为相关批次数据准备数据模型
4. 将准备好的数据批次发送到目标消息队列

为了从服务内部与数据库交互，使用 IOC / 依赖注入（即通过构造函数）提供了 Db-context 对象。

为了确定问题原因，我使用多种方式进行服务方法调用：

• 使用 Task.Run() 调用异步方法
• 在没有 Task.Run() 的情况下调用异步方法
• 使用 Task.Run() 调用同步方法
• 使用 ConfigWait(true) 调用异步方法

在所有情况下，结果都没有改变，仍然得到 ObjectDisposedException for DbContext 对象。

在更多地了解 IOC 的范围系统时，在我看来， 响应后，范围正在为 db-context 对象处置 提供给用户。

代码 sn-p 用最少的行表示如下：

AzureSearchIndexController.cs

public class AzureSearchIndexController : Controller
{
   [HttpGet]
   public IActionResult StartIndex()
   {
      _azureSearchDataSyncService.StartIndexingAsync(_siteId, _siteName);
   }
}

AzureSearchDataSyncService.cs

public class AzureSearchDataSyncService : IAzureSearchDataSyncService
{
   public AzureSearchDataSyncService(JobContext context,
            ICacheHandler<AzureSearchDataSyncModel> cacheHandler,
            AzureJobsTopicBus azureJobsTopicBus)
   {
      _context = context;
      _cacheHandler = cacheHandler;
      _azureJobsTopicBus = azureJobsTopicBus;
      azureSearchDataSyncModel = new AzureSearchDataSyncModel();
   }

   public async Task StartIndexingAsync(int siteId, string siteName)
   {
      try
      {
         int fetchedData = 0;
         int _batchSize = 10;
         List<AzureJobMessageModel> azureJobMessages = new List<AzureJobMessageModel>();

         var jobsToAdd_Update= GetData(siteId);
         while (dataSyncModel.SyncStatus && 
            fetchedData < jobsToAdd_Update.Count)
         {
            var batchData = jobsToAdd_Update.Skip(fetchedData)
                          .Take(_batchSize - azureJobMessages.Count)
                          .ToList();
            if (batchData.Count <= 0)
               continue;

            azureJobMessages.AddRange( 
               PrepareAzureJobMessageModel( 
                      PrepareAzureSearchIndexerModel(batchData), 
                  EntityActionEnum.updated)
            );

            fetchedData += batchData.Count();

            if (azureJobMessages.Count >= _batchSize)
            {
               //Method sending batch data
               await _azureJobsTopicBus.SendMessageAsync(azureJobMessages);
               dataSyncModel.ProcessedData += azureJobMessages.Count();
               dataSyncModel.ProcessedBatches += 1;
               azureJobMessages = new List<AzureJobMessageModel>();
            }
         }
      }
      catch(Exception ex)
      {
          throw ex;
      }
   }
}

期望的结果：希望在按钮单击时具有数据同步过程的异步模式。

实际结果：

出现错误“ObjectDisposedException - 无法访问 Disposed Object （数据库上下文）”

。有人对此有任何想法吗？

注意：-我不想让操作方法异步。我将在服务方法或包含 CRUD 操作逻辑的 CRUD 操作中使用此方法调用。我希望数据同步逻辑在后台运行而不影响 CRUD 操作的响应时间。

Answer 1

因为没有等待服务调用，所以响应在服务之前完成，这将处理上下文。当服务尝试访问上下文时导致错误。

使操作异步，然后等待服务

public class AzureSearchIndexController : Controller {

    //...

   [HttpGet]
   public async Task<IActionResult> StartIndex() {

        //...

        await _azureSearchDataSyncService.StartIndexingAsync(_siteId, _siteName);

        //...
    }
}