Web Api 2 OWIN Selfhost 处理多个并发请求
Web Api 2 OWIN Selfhost handle multiple concurrent requests
我有一个使用 OWIN 的自托管网站 api,我似乎很难处理并发连接。当我 运行 使用 50 个并发获取事件进行压力测试时,响应时间增加了很多,即使操作非常简单,return 200 OK,在 uri 中输入 id。
我的网络 api OWIN 和 api 控制器如何根据请求同时 运行?
这是我的项目示例:
启动class
public class Startup
{
public void Configuration(IAppBuilder appBuilder)
{
try
{
appBuilder.UseWelcomePage("/welcome.html");
appBuilder.UseErrorPage(new ErrorPageOptions
{
ShowExceptionDetails =
#if DEBUG
true
#else
false
#endif
});
Debug.WriteLine($"Setting Web Api Configuration up...");
var apiConfig = ConfigureWebApi();
appBuilder.UseWebApi(new HttpServer(apiConfig));
appBuilder.UseCors(CorsOptions.AllowAll);
Debug.WriteLine($"Completed Web Api configuration.");
}
catch (Exception ex)
{
Debug.WriteLine($"Failed to complete Web Api setup.", ex);
throw;
}
}
}
控制器
public class TestController : ApiController
{
public async Task<IHttpActionResult> Get(int id)
{
return Task<IHttpActionResult>.Factory.StartNew(() => {
try
{
return Ok(id);
}
catch (Exception ex)
{
Debug.WriteLine(ex.Message, nameof(Get));
return InternalServerError();
}
});
}
}
我的 Web 控制台启动 api:
public static void Open()
{
_webApp = WebApp.Start<Startup>(HostAddress);
Console.WriteLine($"Host open -> {HostAddress}");
}
您的所有 api 控制器方法将同时 运行,显然受到托管 api 的服务器功能的限制。这是 Web 服务器的功能,无论是 IIS 还是自托管。但是,您可以做一些事情来帮助实现这一目标。
如果您始终保持所有异步,您将看到最佳性能。例如,如果您的控制器方法如下所示:
public async Task<IHttpActionResult> Get(int id)
{
var testObject = await _repository.GetAsync(id);
return Ok(testObject);
}
并且您有一个如下所示的存储库方法:
public async Task<TestObject> GetAsync(int id)
{
using(var connection = new SqlConnection(_connectionString)
{
// using Dapper
return await connection.QuerySingleAsync<TestObject>("sp_GetTestObject", new {Id = id}, commandType = CommandType.StoredProcedure);
}
}
这样做允许计算机使用数据库的工作线程 I/O,释放处理能力来处理其他任务,例如接受对 API 端点的其他请求。像@StephenCleary 这样的人可能会解释我所说的 and/or 更正它。 @StephenCleary 的 blog 和书绝对值得一读以了解异步编程。
希望对您有所帮助。
我有一个使用 OWIN 的自托管网站 api,我似乎很难处理并发连接。当我 运行 使用 50 个并发获取事件进行压力测试时,响应时间增加了很多,即使操作非常简单,return 200 OK,在 uri 中输入 id。
我的网络 api OWIN 和 api 控制器如何根据请求同时 运行?
这是我的项目示例:
启动class
public class Startup
{
public void Configuration(IAppBuilder appBuilder)
{
try
{
appBuilder.UseWelcomePage("/welcome.html");
appBuilder.UseErrorPage(new ErrorPageOptions
{
ShowExceptionDetails =
#if DEBUG
true
#else
false
#endif
});
Debug.WriteLine($"Setting Web Api Configuration up...");
var apiConfig = ConfigureWebApi();
appBuilder.UseWebApi(new HttpServer(apiConfig));
appBuilder.UseCors(CorsOptions.AllowAll);
Debug.WriteLine($"Completed Web Api configuration.");
}
catch (Exception ex)
{
Debug.WriteLine($"Failed to complete Web Api setup.", ex);
throw;
}
}
}
控制器
public class TestController : ApiController
{
public async Task<IHttpActionResult> Get(int id)
{
return Task<IHttpActionResult>.Factory.StartNew(() => {
try
{
return Ok(id);
}
catch (Exception ex)
{
Debug.WriteLine(ex.Message, nameof(Get));
return InternalServerError();
}
});
}
}
我的 Web 控制台启动 api:
public static void Open()
{
_webApp = WebApp.Start<Startup>(HostAddress);
Console.WriteLine($"Host open -> {HostAddress}");
}
您的所有 api 控制器方法将同时 运行,显然受到托管 api 的服务器功能的限制。这是 Web 服务器的功能,无论是 IIS 还是自托管。但是,您可以做一些事情来帮助实现这一目标。
如果您始终保持所有异步,您将看到最佳性能。例如,如果您的控制器方法如下所示:
public async Task<IHttpActionResult> Get(int id)
{
var testObject = await _repository.GetAsync(id);
return Ok(testObject);
}
并且您有一个如下所示的存储库方法:
public async Task<TestObject> GetAsync(int id)
{
using(var connection = new SqlConnection(_connectionString)
{
// using Dapper
return await connection.QuerySingleAsync<TestObject>("sp_GetTestObject", new {Id = id}, commandType = CommandType.StoredProcedure);
}
}
这样做允许计算机使用数据库的工作线程 I/O,释放处理能力来处理其他任务,例如接受对 API 端点的其他请求。像@StephenCleary 这样的人可能会解释我所说的 and/or 更正它。 @StephenCleary 的 blog 和书绝对值得一读以了解异步编程。
希望对您有所帮助。