Tokenizzazione di dati binari in java

Question

Sto scrivendo del codice per gestire un flusso di dati binari. Viene ricevuto in blocchi rappresentati da array di byte. Combinati, gli array di byte rappresentano un flusso sequenziale di messaggi, ognuno dei quali termina con lo stesso valore di terminatore costante (0xff nel mio caso). Tuttavia, il valore del terminatore può apparire in qualsiasi punto in qualsiasi dato blocco di dati. Un singolo blocco può contenere parte di un messaggio, più messaggi e qualsiasi cosa nel mezzo.

Ecco un piccolo assaggio di ciò che i dati trattati da questo potrebbe essere simile:

[0x00, 0x0a, 0xff, 0x01] 
[0x01, 0x01] 
[0xff, 0x01, 0xff] 

Questi dati devono essere convertiti in questi messaggi:

[0x00, 0x0a, 0xff] 
[0x01, 0x01, 0x01, 0xff] 
[0x01, 0xff] 

ho scritto una piccola classe per gestire Questo. Ha un metodo per aggiungere alcuni dati nel formato array di byte, che viene quindi inserito in un array di buffer. Quando viene rilevato il carattere di terminatore, l'array di byte viene cancellato e il messaggio completo viene inserito in una coda di messaggi, a cui è possibile accedere utilizzando i metodi hasNext() e next() (simile a un iteratore).

Questa soluzione funziona bene, ma come ho finito, ho capito che potrebbe esistere già un codice stabile, performante e testato in una libreria stabilita che potrei utilizzare al suo posto.

Quindi la mia domanda è: sai di una libreria di utilità che avrebbe una tale classe, o forse c'è qualcosa nella libreria Java 6 standard che può farlo già?

Answer 1

Non penso che sia necessario un framework poiché un parser personalizzato è abbastanza semplice.

InputStream in = new ByteArrayInputStream(new byte[]{ 
     0x00, 0x0a, (byte) 0xff, 
     0x01, 0x01, 0x01, (byte) 0xff, 
     0x01, (byte) 0xff}); 

ByteArrayOutputStream baos = new ByteArrayOutputStream(); 
for (int b; (b = in.read()) >= 0;) { 
    baos.write(b); 
    if (b == 0xff) { 
     byte[] bytes = baos.toByteArray(); 
     System.out.println(Arrays.toString(bytes)); 
     baos = new ByteArrayOutputStream(); 
    } 
} 

stampe come (byte) 0xFF == -1

[0, 10, -1] 
[1, 1, 1, -1] 
[1, -1]