ByteArray über Socket

[a_l_e_x]

Hej,

ich versuche ein Object zu verschlüsseln und dann über einen Socket von einer Anwendung an eine andere zu senden.

das senden sieht so aus

ByteArrayOutputStream baos = new ByteArrayOutputStream();
ObjectOutputStream oos;

oos = new ObjectOutputStream(baos);
oos.writeObject(myarraylist);

byte[] byteObjects = baos.toByteArray();

encryptedObject = cipher.doFinal(byteObjects);



OutputStream os = socket.getOutputStream();            
bufferedOutputStream bos = new BufferedOutputStream (os);
bos.write(encryptedObject);
bos.flush();

und das empfangen so

Socket socket = new Socket(host, port);   
InputStream is = socket.getInputStream();

byte[] buffer = new byte[8192];
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
int bytesRead;
          
while ((bytesRead = is.read(buffer)) != -1)
{               
    byteArrayOutputStream.write(buffer, 0, bytesRead);
                
    if (bytesRead < 8192)
    {
         break;
    }
}

byte[] data = byteArrayOutputStream.toByteArray();     


byte[] decryptedObject = cipher.doFinal(data);

ByteArrayInputStream bais = new ByteArrayInputStream (decryptedObjects);
ObjectInputStream ois = new ObjectInputStream(bais);

ArrayList<Item> myarraylist = (ArrayList<Item>) ois.readObject();

Solange beide Anwendungen auf dem selben PC laufen klappt das soweit auch.
aber wenn die Anwendungen auf verschiedenen Rechnern laufen bekomme ich immer eine IllegalBlockSizeException

wenn ich die Daten statt in den Stream in eine Datei speichere (Netzlaufwerk) dann funktioniert das ganze.

Steh ein wenig auf dem schlauch, was mach ich falsch ?

Danke schon mal

 

[indamix]

Encoding

 

[mihe7]

Ich würde sagen, Du gehst fälschlicherweise davon aus, dass Du im Netzwerk die gleichen "Datenblöcke" empfängst, die Du versendest. Das ist aber nicht unbedingt der Fall. Die Daten werden in TCP/UDP+IP+IEEE 802-Pakete verpackt und da kann es beim Empfang durchaus vorkommen, dass Du mehrfach lesen musst, bis Du die Daten vollständig erhalten hast. Entferne doch mal die Zeilen 12 bis 15 beim Empfang und überprüfe, ob die Längen der Arrays übereinstimmen.

 

[KonradN]

@mihe7 dürfte das Problem erkannt haben. Das Byte-Array wird in mehrere Pakete aufgeteilt und versendet. Und diese kleineren Pakete werden dann empfangen. Und Du hast keine Chance zu ermitteln, wann ein ursprünglicher Block empfangen wurde.

Typische Lösngen:
Wenn Du die Object Streams verwendest, dann kannst Du diese direkt auf den Streams verwenden. Die Object Streams synchronisieren sich bereits korrekt. Dabei nur darauf achten, dass die Synchronisation ermöglichst wird, d.h. beim öffnen des ObjectInputStreams will dieser bereits paar Bytes lesen und beim Öffnen des ObjectOutputStreams schreibt er paar Bytes. Daher immer erst den Output und dann den Input öffnen sonst hast Du den Effekt, dass beide Seiten auf diese ersten Bytes warten.

Eine andere Lösung ist, dass Du einen Buffer implementierst. Dann schreibst Du z.B. erst die Anzahl der Bytes in den Stream und dann das Byte Array. Beim lesen liest du dann erst die Anzahl der Bytes, die du brauchst und dann wartest Du, bis die Anzahl der Bytes eingetroffen ist um diese dann zu bearbeiten. Aber Aufpasen: Du kannst dann auch schon Pakete vom nächsten Block empfangen haben. Das kann also so aussehen:

Sender: 3AAA4BBBB
Empfangen wird dann z.B.
3A
A
A4B
BB
B
B

Das heisst: Du empfängst erst 3A, die 3 kannst Du dann Auswerten und hast die Länge (Hier 3 "Zeichen".) Das erste Zeichen bleibt im Puffer. (A)
Das nächste A kommt, es kommt in den Buffer (AA), notwendige Länge noch nicht erreicht.
A4B kommt, also kommen die in den Buffer (AAA4B), die Länge ist vorhanden, du kannst also jetzt die 3 Zeichen rausnehmen.
Damit hast Du AAA zur Auswertung und Du hast dann im Buffer 4B.