C# WebClient 并行调用 API 与 Async/Await

Question

我是Async/Await的新手。我必须将 api 和 sace 结果调用到 txt 文件中。我使用了网络客户端。打开阅读并能够保存文件。我想使用API的多个输入运行我的代码，我想并行运行它。

对于顺序操作，我使用WebClient.OpenRead((作为代码工作。

class Program
{
static void Main(string[] args)
{
var name = "test1";
var filename = $"c:\temp\{name}.txt";
var url = $"https://testapi?name eq '{name}')";
using (var client = new WebClient())
{
using (Stream stream = client.OpenRead(url))
using (StreamReader streamReader = new StreamReader(stream))
using (JsonTextReader reader = new JsonTextReader(streamReader))
{
reader.SupportMultipleContent = true;
var serializer = new JsonSerializer();
var parsedData = serializer.Deserialize(reader).ToString();
File.WriteAllText(filename, parsedData);
Console.WriteLine($"Result save at {filename}");
}
}
}
}

对于并行操作，我尝试使用WebClient.OpenReadAsync((，但我的代码没有将文件保存在c：\temp\

static void Main(string[] args)
{
var names = new string[] { "test1", "test2" };
foreach (var name in names)
{
var filename = $"c:\temp\{name}.txt";
var url = $"https://testapi?name eq '{name}') ";
var client = new WebClient();
client.OpenReadCompleted += (sender, e) =>
{
Stream reply = (Stream)e.Result;
StreamReader s;
s = new StreamReader(reply);
using (JsonTextReader reader = new JsonTextReader(s))
{
reader.SupportMultipleContent = true;
var serializer = new JsonSerializer();
var parsedData = serializer.Deserialize(reader).ToString();
File.WriteAllText(filename, parsedData);
Console.WriteLine($"Result save at {filename}");
}
};
client.OpenReadAsync(new Uri(url));
}
}

我的代码有什么问题？有什么指示吗？

Answer 1

下面是将并行执行任务的代码。请注意，我不使用 foreach 循环，在您的情况下，这意味着顺序任务执行。重要的部分是，首先我创建一个应该执行的任务列表，然后我使用 Task.WhenAll 通过包装任务列表来创建单个任务，然后我等待任务结束。等待((;

另外，请阅读有关 .等待((。以及它的行为方式。它有效地阻止了应用程序的线程，这在更复杂的应用程序中是不需要的。

static void Main(string[] args)
{
var tasks = new[] {"test1", "test2"}.Select(SaveData);
Task.WhenAll(tasks).Wait();
}
private static async Task SaveData(string fileName)
{
var filename = $"c:\temp\{fileName}.txt";
var url = $"https://testapi?name eq '{fileName}') ";
var client = new WebClient();
client.OpenReadCompleted += (sender, e) =>
{
var reply = e.Result;
StreamReader s;
s = new StreamReader(reply);
using (var reader = new JsonTextReader(s))
{
reader.SupportMultipleContent = true;
var serializer = new JsonSerializer();
var parsedData = serializer.Deserialize(reader).ToString();
File.WriteAllText(filename, parsedData);
Console.WriteLine($"Result save at {fileName}");
}
};
await client.OpenReadTaskAsync(new Uri(url));
}