c# - C# 8 异步流与 REST/RPC
问题描述
我确信这个问题将证明我的无知,但我很难理解这一点。我愿意问一个愚蠢的问题以获得一个好的答案。
我读过的所有关于异步流的帖子都很好地展示了该功能,但它们没有解释为什么它比替代方案有所改进。
或者,也许,什么时候应该使用异步流而不是旧的客户端-服务器通信?
我可以看到流式传输大文件的内容可能适合异步流,但我见过的许多示例都使用异步流来传输少量传感器数据(例如温度)。似乎带有温度传感器的物联网设备只需将数据 HTTP POST 到服务器,服务器就可以响应。在这种情况下,服务器为什么要实现异步流?
当你难以理解这些话时,我已经能感觉到你的痛苦,但请怜悯我。:)
根据要求,这里有一些我遇到的让我感到困惑的例子。当我找到它们时,我会发布更多信息,但我想继续让你开始:
- .NET Conf 主题演讲的前半部分是一个大规模的异步流演示......我不明白他们为什么在这里使用异步流:https ://www.youtube.com/watch?v=1xQE2bWkwjo&list=PLReL099Y5nRd04p81Q7p5TtyjCrj9tz1t&index=4&t =
- 这是另一个让我感到困惑的例子
解决方案
我想写一个专业的回复,但可能也需要粗略的回复:
忘记你听说过async streams
。他们在想什么?
叫它await foreach
,或async enumerables
或async iterators
。它与 IO 和流无关。
使用该术语是因为它存在于其他语言中,而不是因为它与 IO 有任何关系。例如,在 Java 中,流是 Java 对 C# 的 IEnumerable 的实现。因此,为了便于未来的 Android 开发人员采用,C# 采用了 Java 的坏主意。
我们可以查看语言设计会议,了解我猜这个术语的实际理由。
严肃的原始答案
没有vs
。这就像对比自动变速箱和汽车。汽车可以有自动变速箱,它们不能代替变速箱。
异步流纯粹是一个允许创建异步迭代的编程概念。它是允许我们编写此代码以循环进行 HTTP 调用并在结果到达时对其进行处理的功能:
await foreach(var someValue from someAsyncIterator(5))
{
...
}
IAsyncEnumerable<string> someAsyncIterator(int max)
{
for(int i=0;i<max;i++)
{
var response=await httpClient.GetStringAsync($"{baseUrl}/{i}");
yield return response;
}
}
当它们显示为操作结果时,仅允许 ASP.NET Core 中间件在生成结果时开始处理结果,它们不会影响 HTTP 响应本身的内容。
另一方面, gRPC 的流允许服务器异步向客户端发送单独的响应。gRPC 和 C# 8 异步流中的 Laurent Kempe和使用 GRPC 和 .NET Core的服务器流中的 Steve Gordon展示了如何将它们一起使用
复制 Steve Gordon 的示例,假设我们有一个天气服务,可以向客户端发送预报,其 proto 文件包含:
service WeatherForecasts {
rpc GetWeather (google.protobuf.Empty) returns (WeatherReply);
rpc GetWeatherStream (google.protobuf.Empty) returns (stream WeatherData);
rpc GetTownWeatherStream (stream TownWeatherRequest) returns (stream TownWeatherForecast);
}
在 C# 8 之前,客户端必须阻塞,直到收到所有响应才能处理它们:
using var channel = GrpcChannel.ForAddress("https://localhost:5005");
var client = new WeatherForecastsClient(channel);
var reply = await client.GetWeatherAsync(new Empty());
foreach (var forecast in reply.WeatherData)
{
//Do something with the data
}
但是在 C# 8 中,可以在响应到达时接收和处理响应:
using var replies = client.GetWeatherStream(new Empty(), cancellationToken: cts.Token);
await foreach (var weatherData in replies.ResponseStream.ReadAllAsync(cancellationToken: cts.Token))
{
//Do something with the data
}
**
推荐阅读
- c# - blazor 可以使用自定义属性更改回调事件吗?
- c# - 如果对象成员没有值,如何为对象分配 null - automapper c#
- javascript - 与命名导出相比,默认导出有什么优势吗?
- python - 在 Python 中使用 Tor 隐藏服务
- ios - 访问 swift 数组时 swift_isUniquelyReferenced_nonNull_native 中的 EXC_BAD_ACCESS
- php - PHP Array - 如何用特定文本替换相同值的值?
- ios - 是否有命令从 Firebase App Distribution 获取最新版本号,就像 TestFlight latest_testflight_build_number 一样?
- python - 如何读取 _io.TextIOWrapper 数据?
- c# - 如何在 C# 代码中运行 NUnit 测试
- git - Git合并提交不包含删除但实际上删除?