使用SAX(Java)从单个TCP流中解析多个XML消息

jkt*_*jkt 6 java xml sax saxparseexception

我处于这样一个位置:我使用Java连接到TCP端口,并且一个接一个地流式传输XML文档,每个文档都以<?xml文档标记的开头分隔.演示格式的示例:

<?xml version="1.0"?>
<person>
    <name>Fred Bloggs</name>
</person>
<?xml version="1.0"?>
<person>
    <name>Peter Jones</name>
</person>
Run Code Online (Sandbox Code Playgroud)

我正在使用org.xml.sax.*api.SAX解析适用于第一个文档,但在遇到第二个文档的开头时抛出异常:

Exception in thread "main" org.xml.sax.SAXParseException: The processing instruction 
target matching "[xX][mM][lL]" is not allowed.
Run Code Online (Sandbox Code Playgroud)

以下框架类演示了我正在使用的设置:

import org.xml.sax.InputSource;
import org.xml.sax.XMLReader;
import org.xml.sax.helpers.DefaultHandler;
import org.xml.sax.helpers.XMLReaderFactory;

import java.io.FileReader;

public class XMLTest extends DefaultHandler {

  public XMLTest() {
     super();
  }

  public static void main(String[] args) throws Exception {
    XMLReader xr = XMLReaderFactory.createXMLReader();

    XMLTest handler = new XMLTest();
    xr.setContentHandler(handler);
    xr.setErrorHandler(handler);

    xr.parse(new InputSource(new Socket("127.0.0.1", 4555).getInputStream()));
  }
}
Run Code Online (Sandbox Code Playgroud)

我有过XML(这是一个财务数据饲料)的格式无法控制,但我需要能够有效地分析它,并解析所有的文件.我花了整个下午/晚上尝试不同的事情,但没有一个产生结果.任何帮助将不胜感激.

Bal*_*usC 6

您希望将流拆分为每个<?xml version="1.0"?>并分别解析它们.这BufferedReader可能对此有所帮助.开球示例:

reader = new BufferedReader(new InputStreamReader(input, "UTF-8"));
StringBuilder builder = null;
for (String line; (line = reader.readLine()) != null;) {
    if (line.startsWith("<?xml")) {
        if (builder != null) {
            xr.parse(new InputSource(builder.toString()));
        }
        builder = new StringBuilder();
    }
    builder.append(line);
}
Run Code Online (Sandbox Code Playgroud)