.NET 中的异步 XmlReader？

Question

有没有办法异步访问 XmlReader？ xml 从许多不同的客户端（如 XMPP）从网络中传入；它是...> 的持续流。标签。

我所追求的是能够使用类似 BeginRead/EndRead 的界面。我设法想出的最佳解决方案是在底层网络流上执行 0 字节的异步读取，然后当一些数据到达时，调用 XmlReader 上的 Read - 然而，这将阻塞，直到来自节点的所有数据为止变得可用。该解决方案看起来大致如下

private Stream syncstream;
private NetworkStream ns;
private XmlReader reader;

//this code runs first
public void Init()
{
    syncstream = Stream.Synchronized(ns);
    reader = XmlReader.Create(syncstream);
    byte[] x = new byte[1];
    syncstream.BeginRead(x, 0, 0, new AsynchronousCallback(ReadCallback), null);
}

private void ReadCallback(IAsyncResult ar)
{
    syncstream.EndRead(ar);
    reader.Read(); //this will block for a while, until the entire node is available
    //do soemthing to the xml node
    byte[] x = new byte[1];
    syncstream.BeginRead(x, 0, 0, new AsynchronousCallback(ReadCallback), null);
}

编辑：这是计算字符串是否包含完整 xml 节点的可能算法？

Func<string, bool> nodeChecker = currentBuffer =>
                {
                    //if there is nothing, definetly no tag
                    if (currentBuffer == "") return false;
                    //if we have <![CDATA[ and not ]]>, hold on, else pass it on
                    if (currentBuffer.Contains("<![CDATA[") && !currentBuffer.Contains("]]>")) return false;
                    if (currentBuffer.Contains("<![CDATA[") && currentBuffer.Contains("]]>")) return true;
                    //these tag-related things will also catch <? ?> processing instructions
                    //if there is a < but no >, we still have an open tag
                    if (currentBuffer.Contains("<") && !currentBuffer.Contains(">")) return false;
                //if there is a <...>, we have a complete element.
                //>...< will never happen because we will pass it on to the parser when we get to >
                if (currentBuffer.Contains("<") && currentBuffer.Contains(">")) return true;
                //if there is no < >, we have a complete text node
                if (!currentBuffer.Contains("<") && !currentBuffer.Contains(">")) return true;
                //> and no < will never happen, we will pass it on to the parser when we get to >
                //by default, don't block
                return false;
            };

Answer 1

.NET 4.5 中的 XmlReader 具有大多数涉及 IO 的方法的异步版本。

请在此处查看示例代码。

Answer 2

XmlReader 以 4kB 块的形式进行缓冲，如果我还记得几年前我研究这个问题的话。您可以将入站数据填充到 4kB（恶心！），或者使用更好的解析器。我通过将 James Clark 的 XP (Java) 移植到 C# 作为 Jabber-Net 的一部分来修复此问题，此处：

http://code.google.com/p/jabber-net/source/browse/#svn/trunk/xpnet

它是 LGPL，仅处理 UTF8，不是没有打包使用，并且几乎没有文档，所以我不建议使用它。 :)

Answer 3

最简单的方法就是将其放在另一个线程上，也许是一个线程池，具体取决于它保持活动状态的时间。 （不要将线程池线程用于真正长时间运行的任务）。

Answer 4

看起来 DOT NET 4.5 在 XmlReader 上有一个 bool Async 属性，而 3.5 中没有该属性。也许这对你有用？

Answer 5

这确实很棘手，因为 XmlReader 不提供任何异步接口。

我不太确定当您要求 BeginRead 读取 0 字节时，它的异步行为有多少 - 它可能会立即调用回调，然后在您调用 Read 时阻塞>。这可能与直接调用 Read 然后在线程池中调度下一个 Read 是一样的，例如使用 QueueWorkItem。

最好在网络流上使用 BeginRead 来读取数据，例如以 10kB 块的形式读取数据（当系统等待数据时，您不会阻塞任何线程）。当您收到一个块时，您会将其复制到某个本地 MemoryStream 中，并且您的 XmlReader 将从该 MemoryStream 中读取数据。

但这仍然存在一个问题 - 在复制 10kB 数据并多次调用 Read 后，最后一次调用将被阻塞。然后，您可能需要复制较小的数据块来解锁对 Read 的挂起调用。完成后，您可以再次启动新的 BeginRead 调用来异步读取大部分数据。

老实说，这听起来相当复杂，所以我很感兴趣是否有人能提出更好的答案。但是，它至少为您提供了一些有保证的异步操作，这些操作需要一些时间并且同时不会阻塞任何线程（这是异步编程的基本目标）。

（旁注：您可以尝试使用F# 异步工作流程 来编写这个，因为它们使异步代码变得更加简单，但即使在 F# 中，我描述的技术也会很棘手）。

Answer 6

您是否正在寻找类似 XamlReader.LoadAsync 方法的方法？

异步 ​​XAML 加载操作
最初会返回一个对象
纯粹是根对象。
异步，然后XAML解析
继续，并且任何子对象都是
填写在根下。