2016-07-25 6 views
2

Я пытаюсь разобрать XML сообщение, приходящее из сокета TCP с помощью Аалто-XMLНе удалось разобрать асинхронно несколько документов XML с использованием Аалто

https://github.com/FasterXML/aalto-xml

Это 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(); 

Анализировать метод:

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] 

Любая помощь будет оценена !

ответ

0

Похоже, что один и тот же контент передается несколько раз или что-то еще, так что объявление XML передается более одного раза. Это из-за смещения, упомянутого в исключении (столбец 122).

+0

Да, это может быть так. – Shvalb

+0

Вопрос: для каждого xml - Нужно ли повторно инициализировать: xmlInputFactory.createAsyncForByteArray() ?? – Shvalb

+0

Кажется, что при потоковой передаче xml непосредственно из сокета мне нужно создать новый Async ByteArray для каждого нового сообщения, в противном случае он выдает исключения, такие как буфер, который не очищается, и он не работает при попытке проанализировать следующий тип элемента xml. – Shvalb