Tek bir TCP akışından birden çok XML iletisini ayrıştırmak için SAX (Java) kullanma

Question

Bir TCP bağlantı noktasına bağlanmak için Java'yı kullandığım bir konumdayım ve XML belgelerini birbiri ardına sıralıyorum, her biri <?xml ile sınırlandırıldı belge etiketinin formatını gösteren bir örnek:

<?xml version="1.0"?> 
<person> 
    <name>Fred Bloggs</name> 
</person> 
<?xml version="1.0"?> 
<person> 
    <name>Peter Jones</name> 
</person> 

Ben org.xml.sax.* API kullanıyorum.

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())); 
    } 
} 

: Aşağıdaki iskelet sınıf kullanıyorum kurulum gösteren

Exception in thread "main" org.xml.sax.SAXParseException: The processing instruction 
target matching "[xX][mM][lL]" is not allowed. 

: ikinci belgenin başında genelinde geldiğinde SAX ayrıştırma ilk belge için mükemmel çalışıyor ancak bir istisna atar Xml'nin formatı üzerinde herhangi bir kontrolüm yok (bu bir finansal veri feed'i), ancak verimli bir şekilde ayrıştırmak ve tüm belgeleri ayrıştırmak zorundayım. Öğleden sonraları/akşamları farklı şeyler denedim ama hiçbiri sonuç vermedi. Herhangi bir yardım büyük takdir edilecektir.

Answer 1

Akışı her <?xml version="1.0"?> üzerinde bölmek ve hepsini ayrı ayrı çözümlemek istersiniz. BufferedReader bu konuda yardımcı olabilir. Açılış örneği:

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); 
}