我正在寻找一个XML解析器，它可以接收文本块而不是从InputStream或InputSource中解析。 例如，我想要类似以下的东西：
public class DataReceiver {
private SAXParser parser = //...
private DefaultHandler handler = //...
/**
* Called each time some data is received.
*/
public void onDataReceived(byte[] data) {
parser.push(data, handler);
}
}
我之所以想要这样做，是因为我希望使用NIO网络库而不必回到每个连接模型所需的阻塞InputStream。
编辑：现在我明白了。您会分块接收XML并希望将其提供给适当的XML解析器。因此，您需要一个对象，在一端是队列，在另一端是InputStream？
您可以将接收到的字节数组聚合到ByteArrayOutputStream中，将其转换为ByteArrayInputStream并将其提供给SAXParser。
或者，您可以查看PipedInputStream/PipedOutputStream对。在这种情况下，您需要在另一个线程中执行解析，因为SAX解析器使用当前线程来发出事件，从而阻塞了您的receive()。
编辑：根据评论，我建议采用聚合路线。您将块收集到ByteArrayOutputStream中。要知道是否接收了XML的所有块，请检查当前块或ByteArrayOutputStream的内容是否包含XML根节点的结束标记。然后，您只需将数据传递给SAXParser，它现在可以在当前线程中运行而没有问题。为避免不必要的数组重新创建，您可以实现自己的非同步简单字节数组包装器或寻找这样的实现。
这是来自Xerces J-Users邮件列表的一篇（2009年4月）帖子，原帖作者遇到了完全相同的问题。 "Jeff"提供了一个可能非常好的回应，但没有对原帖作者的回应进行跟进：
http://www.nabble.com/parsing-an-xml-document-chunk-by-chunk-td22945319.html
这可能是新的足以在列表中引起注意，或至少对搜索有所帮助。
编辑
发现另一个有用的链接，提到了一个名为Woodstox的库，描述了基于流和NIO的解析器的状态，以及一些模拟流的可能方法:
由于这个问题在相关的谷歌搜索中仍然很高，因此添加另一个答案 - aalto-xml 0.9.7（2011年3月）具有异步XML解析。这允许您传递文档的任意大小块以继续解析，并引入了一个新的StaX事件类型EVENT_INCOMPLETE，以指示输入缓冲区已耗尽且文档仍不完整。
这是Tatu Salorant（作者）的示例：
byte[] msg = "<html>Very <b>simple</b> input document!</html>".getBytes();
AsyncXMLStreamReader asyncReader = new InputFactoryImpl().createAsyncXMLStreamReader();
final AsyncInputFeeder feeder = asyncReader.getInputFeeder();
int inputPtr = 0; // as we feed byte at a time
int type = 0;
do {
// May need to feed multiple "segments"
while ((type = asyncReader.next()) == AsyncXMLStreamReader.EVENT_INCOMPLETE) {
feeder.feedInput(msg, inputPtr++, 1);
if (inputPtr >= msg.length) { // to indicate end-of-content (important for error handling)
feeder.endOfInput();
}
}
// and once we have full event, we just dump out event type (for now)
System.out.println("Got event of type: "+type);
// could also just copy event as is, using Stax, or do any other normal non-blocking handling:
// xmlStreamWriter.copyEventFromReader(asyncReader, false);
} while (type != AsyncXMLStreamReader.END_DOCUMENT);
NioSax 使用 ByteBuffers。
http://blog.retep.org/2010/06/25/niosax-sax-style-xml-parser-for-java-nio/
我能找到的最新版本源代码（来自2010年的10.6版本）在Sonatype Maven存储库中：
https://oss.sonatype.org/content/repositories/releases/uk/org/retep/
查看openfire的XMLLeightweightParser以及它如何通过NIO从单个块生成XML消息。整个项目是关于NIO和XMPP问题答案的绝佳资源。
call-cc。然后我们就可以通过实现InputStream来获得这个。 - Daniel Earwicker