.NET 中的异步 XmlReader？

Question

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

我追求的是能够使用类似 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

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

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

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

Answer 2

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

Answer 3

.NET 4.5 中的

XmlReader 具有大多数涉及 IO 的方法的 async 版本。

查看示例代码here。

Answer 4

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

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

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

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

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

（旁注：您可以尝试使用F# asynchronous workflows 来编写此代码，因为它们使异步代码更简单。我描述的技术即使在 F# 中也会很棘手）

Answer 5

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

Answer 6

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

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