我试图为防止重复请求的DelegatingHandler编写集成测试。处理程序检查数据库以查看请求是否已被处理,并返回407冲突,如果在前一个请求仍在运行时发出重复请求,则返回407冲突。
我的测试中有以下代码:
HttpClient client = new HttpClient();
var responseTask1 = client.PostAsJsonAsync(RequestUriWithDuplicatePrevention, ReadRequestContent("DuplicateRequestJsonContent.json"));
var responseTask2 = client.PostAsJsonAsync(RequestUriWithDuplicatePrevention, ReadRequestContent("DuplicateRequestJsonContent.json"));
var response1 = responseTask1.Result;
var response2 = responseTask2.Result;
这两个请求都同时登录到数据库中。怎样才能将第二次请求推迟一段时间?
我尝试过添加一个Thread.Sleep(500),但它似乎没有什么区别。
修订代码
这段代码在大多数情况下似乎都能工作,但它并不100%可靠。
[TestMethod]
public void ShouldReturn407ConflictWhenDuplicateRequestSubmitted()
{
var results = ExecutePostRequests().Result;
Assert.AreEqual(HttpStatusCode.OK, results[0].StatusCode);
Assert.AreEqual(HttpStatusCode.Conflict, results[1].StatusCode);
}
private async Task<HttpResponseMessage[]> ExecutePostRequests()
{
HttpClient client = new HttpClient();
var task1 = ExecutePost(client, 0);
var task2 = ExecutePost(client, 4000);
var response1 = await task1;
var response2 = await task2;
return new[] {response1, response2};
}
private async Task<HttpResponseMessage> ExecutePost(HttpClient client, int delay)
{
await Task.Delay(delay);
return await client.PostAsync(RequestUriWithDuplicatePrevention,
ReadRequestContent("DuplicateRequestJsonContent.json"));
}
正在执行的web服务具有一个Thread.Sleep(5000)。
发布于 2013-11-06 05:02:24
原始代码中的具体问题是,它在获得结果之间处于休眠状态,而在启动异步操作之间应该处于休眠状态。
它可以这样加以纠正:
var responseTask1 = client.PostAsJsonAsync(...);
Thread.Sleep(2000);
var responseTask2 = client.PostAsJsonAsync(...);
var response1 = responseTask1.Result;
var response2 = responseTask2.Result;
您修改过的代码不存在此问题,应该可以工作。不过,我会改变这一点:
var response1 = await task1;
var response2 = await task2;
return new[] {response1, response2};
为了更有效率:
return await Task.WhenAll(task1, task2);
https://stackoverflow.com/questions/19802667
复制相似问题