Discussion :

[pduplouy]

Bonjour à tous,

Je travaille actuellement sur un petit système multi-agents (en utilisant la plateforme JADE) et 2 agents doivent s'échanger un objet java (une HashMap classique).

Le seul type de données pouvant circuler entre les 2 est du texte, il faut donc sérialiser l'objet sous forme de texte, l'envoyer puis le reconstruire à partir de ce texte.

Après quelques recherches, je pense que je dois utiliser un ByteArrayOutputStream sur lequel je mappe l'ObjectOutputStream dans lequel je sérialise l'objet. J'utilise ensuite la méthode toString() de ByteArrayOutputStream afin d'obtenir une chaîne de caractère. Voici le code côté expéditeur:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
 
ByteArrayOutputStream baos = new ByteArrayOutputStream();
ObjectOutputStream out = new ObjectOutputStream(baos);
out.writeObject(conferenceTest); // l'HashMap à transmettre
reponse.setContent(baos.toString()); // contenu du message à envoyer

Une fois le message envoyé, il faut reconstruire l'objet en utilisant logiquement ByteArrayInputStream et ObjectInputStream. Voici le code côté destinataire:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
 
ByteArrayInputStream bais = new ByteArrayInputStream(content.getBytes()); //content étant le contenu du message reçu, donc en théorie l'objet sérialisé
ObjectInputStream in = new ObjectInputStream(bais); // ligne posant problème
conferenceTest = (HashMap<String,String>)in.readObject();

Lors de l'exécution de la 2ème ligne, je rencontre cette exception:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

java.io.StreamCorruptedException: invalid stream header: EFBFBDEF

Est-ce que quelqu'un voit d'où peut venir le problème?

Merci beaucoup

[pseudocode]

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
ByteArrayOutputStream baos = new ByteArrayOutputStream();
ObjectOutputStream out = new ObjectOutputStream(baos);
out.writeObject(conferenceTest); // l'HashMap à transmettre
reponse.setContent(baos.toString()); // contenu du message à envoyer

Je ne pense pas que le ByteArrayOutputStream contienne des caractères "ascii", et donc je doute que le "baos.toString()" soit une bonne idée.

Il faut soit envoyer les données en format byte[] par reponse.setByteSequenceContent(), ou alors encoder le contenu du baos en format texte (uuencode, base64, ...)

[pduplouy]

Bonjour et merci pour l'aide!

J'ai suivi votre conseil et j'encode désormais le flux de bytes avec Base64 (en utilisant la classe Base64 (org.apache.commons.codec.binary.Base64). J'obtiens malheureusement toujours la même exception:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

java.io.StreamCorruptedException: invalid stream header: 075F746B

Je pense que je dois mal faire la conversion donc voici le code que j'utilise:

(expéditeur)

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
 
baos = new ByteArrayOutputStream();
out = new ObjectOutputStream(baos);
out.writeObject(conferenceTest); //objet à sérialiser
 
Base64 encodeur = new Base64();
byte[] bitsEncodes = encodeur.encode(baos.toByteArray());		
reponse.setContent(bitsEncodes.toString());

(destinataire)

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
 
Base64 decodeur = new Base64();
//content est le contenu texte du message 
byte[] bitsDecodes = decodeur.decode(content.getBytes()); 
 
bais = new ByteArrayInputStream(bitsDecodes);
in = new ObjectInputStream(bais); // invalid stream header
hm = (HashMap<String,String>)in.readObject();

Est-ce que le problème vient de mon encodage/décodage en Base64?

[pseudocode]

Est-ce que le problème vient de mon encodage/décodage en Base64?

Non, je ne pense pas. On dirait que la stream est invalide. Regarde la taille des données envoyées/reçues pour voir si c'est la même.

PS: et pense a faire un close() sur les streams.

[pduplouy]

Résolu!

En effet le problème provenait du flux qui était foireux, je m'en suis rendu compte en comparant les tailles des objets à chaque étape.

En fait j'utilisais la méthode toString() de byte[], puis la méthode getBytes() de String dans l'espoir de récupérer mon tableau de bits original, alors qu'il fallait plutôt utiliser le constructeur String(byte[]) à la place de la méthode toString().

Encore merci pour l'aide