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