使用 Web Api 服务进行多次调用

Question

我正在使用Web Api 服务将数据传递到我的移动设备。

这可能有两种情况。

1. 单个设备多次请求
2. 多个设备多次请求

在这两种情况下我都无法处理多个请求，我不知道实际问题是什么，但它一直给我403 Response 和500 Response。

我需要在 秒 内处理 多个请求，因为我要同时并排处理 1000 多个设备，我还需要在几秒内响应它们因为我们不希望我们的设备等待响应超过几秒钟。

目前我正在使用 Azure 平台提供 Web Api 服务，并使用 LINQ 使用 MVC 4.0。如果您想要我的代码，那么我将为您提供代码（我在我的项目中使用存储库模式）

代码

控制器：

[HttpPost]
public JObject GetData(dynamic data)
{
   JObject p = new JObject();

   try
    {
      MyModelWithObjectInData transactionbatchData = JsonConvert.DeserializeObject<MyModelWithObjectInData>(data.ToString());
      return _batchDataService.batchAllDataResponse(transactionbatchData);//Call Repository 
    }
}

存储库：

public JObject batchAllDataResponse(MyModelWithObjectInData oData)
{
   JObject p = new JObject();
   var serviceResponseModel = new MyModelWithObjectInData();
   using (var transaction = new TransactionScope())
   {
     //Insert in Tables
   }

//Select Inserted Records
var batchData = (from p in datacontext.Table1
                 where p.PK == oData.ID select p).FirstOrDefault();

 if (batchData != null)
    {
      serviceResponseModel.GetBatchDataModel.Add(new BatchDataModel //List Residing in MyModelWithObjectInData Class File
       {
            //add values to list
       });       
    }

//Performing 3 Operations to Add Data in Different List (All 3 are Selecting the Values from Different Tables) as i need to Give Response with 3 Different List.

 return p = JObject.FromObject(new
        {
            batchData = serviceResponseModel.GetBatchDataModel,
            otherdata1 = serviceResponseModel.otherdata1, //list Residing in my MyModelWithObjectInData Model 
            otherdata2 = serviceResponseModel.otherdata2 //list Residing in my MyModelWithObjectInData Model
        });

我使用下面的代码来跟踪通过服务发出的所有请求，但我在其中遇到了错误。

//here i am getting error
protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
{
   //var content = request.Content.ReadAsStringAsync().Result;
   ServiceTypes myObjs = JsonConvert.DeserializeObject<ServiceTypes>(request.Content.ReadAsStringAsync().Result);

    bool result = _serviceLogService.InsertLogs(request, myObjs); //Getting Error while inserting data here on multiple request
    return base.SendAsync(request, cancellationToken).ContinueWith((task) =>
      {
        HttpResponseMessage response = task.Result;
        return response;
      });
}

对此的任何帮助将不胜感激。

Answer 1

我找到了使用Async 方法处理重复服务请求的解决方案

protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
{
  //Logic to Track all the Request
  var response = await base.SendAsync(request, cancellationToken);
  return response;
}

我的控制器无法将上下文文件作为已启动的请求启动，并且 “并发请求” 将我的对象锁定为死锁，因为我从设备收到多个请求，因此我修改了他在SendAsync 方法中记录所有服务的代码并等待帮助我等到任务完成。

Answer 2

从您的 api 服务提供数据调用的代码 sn-p 将是最方便的。它们是处理并发查询的几种方法；如果您还没有探索过它，async and await 方法最好在这种情况下加以利用。但这是从模糊的角度来看，我需要查看您的代码才能为您提供明确的答案。

附加信息“如果您是异步编程的新手，或者不了解异步方法如何使用 await 关键字来执行可能长时间运行的工作而不阻塞调用者的线程，您应该阅读 Asynchronous Programming with Async and Await (C# and Visual Basic) 中的介绍。”

希望这些信息能让您走上正轨。

最好的。