2
我试图解析XML消息使用阿尔托的XML无法使用阿尔托
https://github.com/FasterXML/aalto-xml
这是我试图解析XML现身TCP套接字来解析异步多个XML文档:
<?xml version=\"1.0\" encoding=\"UTF-8\"?>
<employee>
<id>1</id>
<name>Alba</name>
<salary>100</salary>
</employee>
第一个xml消息被成功解析,但在第二个消息中引发异常。 这里是我的解析方法
在我的课,我定义一个类成员:
private AsyncXMLStreamReader<AsyncByteArrayFeeder> parser = new InputFactoryImpl().createAsyncForByteArray();
Parse方法:
try {
parser.getInputFeeder().feedInput(buffer, 0, buffer.length);
int type = 0;
//keep looping till event is complete
while(!parser.getInputFeeder().needMoreInput()) {
type = parser.next();
//handle parser event and extract parsed data
switch (type) {
case XMLEvent.START_DOCUMENT:
System.out.println("start document");
break;
case XMLEvent.START_ELEMENT: {
System.out.println("start element: " + parser.getName());
} break;
case XMLEvent.END_ELEMENT: {
System.out.println("end element: " + parser.getName());
} break;
case XMLEvent.END_DOCUMENT: {
System.out.println("end document");
}break;
default:
break;
}
}
if(type == AsyncXMLStreamReader.EVENT_INCOMPLETE) {
System.out.println(results);
}
} catch (XMLStreamException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
例外:
com.fasterxml.aalto.WFCException: Illegal processing instruction target: 'xml' (case insensitive) is reserved by the xml specification
at [row,col {unknown-source}]: [1,112]
任何帮助,将不胜感激!
是的,可能是这种情况。 – Shvalb
问题:对于每个xml - 我需要重新初始化:xmlInputFactory.createAsyncForByteArray()? – Shvalb
看来,当直接从套接字流xml时,我需要为每个新消息创建新的Async ByteArray,否则它会抛出异常,如缓冲区未清理,尝试解析下一个xml元素类型时失败。 – Shvalb