为什么Console.WriteLine()在Stream.ReadAsync()的回调中阻塞
本文关键字:回调 Stream Console WriteLine 为什么 ReadAsync | 更新日期: 2023-09-27 18:28:58
我有一个回调函数,试图在其中写入在overriden ReadAsync()中读取的数据。
private void StreamCallback(byte[] bytes)
{
Console.WriteLine("--> " + Encoding.UTF8.GetString(bytes)); // the whole application is blocked here, why?
if (OnDataReceived != null)
{
string data = Encoding.UTF8.GetString(bytes);
OnDataReceived(data);
}
}
覆盖的ReadAsync()如下所示。
public override async Task<int> ReadAsync(byte[] buffer, int offset, int count, System.Threading.CancellationToken cancellationToken)
{
var read = await _originalStream.ReadAsync(buffer, offset, count, cancellationToken);
_readCallback(buffer);
return read;
}
我实际想要实现的是在XmlReader解析网络流之前对其进行监控。这与我的另一个问题有关>同时阅读同一SslStream<。我该怎么做?
更新:
实际上是Encoding.UTF8.GetString(bytes)
在阻止应用程序。为了使问题更加完整,我列出了读取XML流的代码。
using (XmlReader r = XmlReader.Create(sslStream, new XmlReaderSettings() { Async = true }))
{
while (await r.ReadAsync())
{
switch (r.NodeType)
{
case XmlNodeType.XmlDeclaration:
...
break;
case XmlNodeType.Element:
...
根据您发布的代码,StreamCallback()将阻塞,直到流结束。将字节指针传递给Encoding.UTF8.GetString(字节);因此,它需要不断地查询字节,直到它到达末尾。它永远不会到达结尾,因为字节来自一个流,直到该流关闭。
您需要一次处理一定数量的字节流,或者直到看到某个字符为止。