Discussion :

[MagicTux]

Bonsoir,

Je vous présente la solution que j'essaie d'implémenter:

Celle ci requiert 3 applications que je vais nommer A, B et C.

L'application A qui construit un objet et le sérialise sous forme de fichier (nommons le "obj.ser").

On copie alors ce fichier obj.ser vers un dossier de l'application B. Celle ci, est un serveur (codé en C) qui doit permettre l'envoi par le réseau du fichier obj.ser.

L'application C reçoit le fichier obj.ser, et reconstitue l'objet depuis le fichier.

Cependant, l'erreur suivante survient lorsque je veux reconstituer mon objet depuis le fichier (dans l'application C, après avoir reçu le fichier depuis le réseau) :

Une StreamCorruptedException est levée (invalid type code: 00) lors de l'appel à la méthode readObject() de l'objet ObjectInputStream.

Voici le code des méthodes de sérialisation/déserialisation :

Sérialisation
(Utilisée par l'application A)

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
 
static public void SERDataModel(String filename, PCADataModel m) throws SerializationException {
        try {
            FileOutputStream fOS = new FileOutputStream(filename);
            ObjectOutputStream oOS = new ObjectOutputStream(fOS);
            oOS.writeObject(m);
            oOS.close();
            fOS.close();
        } catch (FileNotFoundException ex) {
            throw new SerializationException(ex.getMessage());
        } catch (IOException ex) {
            throw new SerializationException(ex.getMessage());
        }
    }

Déserialisation
(Utilisée par l'application C)

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
 
static public PCADataModel unSERDataModel(String filename) throws SerializationException {
        PCADataModel model = null;
        try {
            FileInputStream fIS = new FileInputStream(filename);
            ObjectInputStream oIS = new ObjectInputStream(fIS);
            model = (PCADataModel) oIS.readObject();
            oIS.close();
            fIS.close();
            return (model);
        } catch (StreamCorruptedException ex) {
           //L'exception est levée ici
            throw new SerializationException(ex.getMessage());
        } catch (FileNotFoundException ex) {
            throw new SerializationException(ex);
        } catch (IOException ex) {
            throw new SerializationException(ex);
        } catch (ClassNotFoundException ex) {
            throw new SerializationException(ex);
        }
    }

Et enfin la méthode de réception par le réseau (utilisée par l'application C)

Network

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
 
    private void createPCAMonitor(int dataSize) {
        byte[] buf = new byte[dataSize];
        try {
            //dis est un DataInputStream relié à la socket
            dis.readFully(buf);
            FileOutputStream fos = new FileOutputStream("obj.ser");
            fos.write(buf);
            PCADataModel dataModel = IHMBuilder.unSERDataModel("obj.ser");
            SwingUtilities.invokeLater(new IHMBuildRunnable(dataModel));
        } catch (IOException ex) {
            LogManager.write(LogManager.LogType.NETWORK, ex.getMessage());
        } catch (SerializationException ex) {
            LogManager.write(LogManager.LogType.NETWORK, ex.getMessage());
        }
    }

Je ne comprends pas le problème, j'arrive à reconstituer l'objet parfaitement sans passer par le réseau, en copiant le fichier obj.ser à la racine de l'application C et en déserialisant directement l'objet sur disque.

Si quelqu'un à une solution à mon problème, je suis preneur.

[jakcam]

Bonjour,

Bon je sais d'avance que je ne vais pas répondre vraiment à ton post. Mais pourquoi tu n'utilises pas RMI qui fait en fait ce que tu souhaites sans les préoccupation que tu te poses ?

Bonne journée et bon courage

[MagicTux]

Ah j'ai oublié de préciser que le serveur (application B) est codé en C.

Donc je ne peux pas utiliser RMI.

[tchize_]

il faudrait qu'on en sache un peu plus sur le protocole que vous utilisez avec l'application B pour la lecture et l'ecriture? Avez vous pensé à commencer par valider votre protocole en envoyant par exemple une image pour ensuite la réceptionner? Vous verrez tout de suite si vous corrompez le fichier pendant le transfert.

[adiGuba]

Salut,

• Il manque les try/finally pour la libération des ressources. Pire il manque carrément des close() !!!
• Tes SerializationException devraient englobé l'exception original, afin d'avoir un stacktrace complet.
  En clair au lieu de lui passer le message tu lui passes directement l'exception source :
  

  Code :

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

  throw new SerializationException(ex);

• Tu veux faire une copie par le réseau... Pourquoi ne pas directement lire le flux réseau via un ObjectInputStream plutôt que de faire une recopie dans un fichier en local ?
• Dans la méthode createPCAMonitor() tu sembles utiliser un flux défini en attribut d'instance...
  Ce n'est pas très évident à gérer et cela aboutit souvent à une mauvaise gestion des ressources.
• Comment se fait a lecture entre l'application C et Java ?

a++

[tchize_]

Pire il manque carrément des close() !!!

Tu fais bien de le signaler, en effet, a tous les coups, le deserializer désérialize un fichier dont le contenu n'a pas entèrement été écrit (FileOutputStream pas fermé donc pas flushé)

[MagicTux]

il faudrait qu'on en sache un peu plus sur le protocole que vous utilisez avec l'application B pour la lecture et l'ecriture? Avez vous pensé à commencer par valider votre protocole en envoyant par exemple une image pour ensuite la réceptionner? Vous verrez tout de suite si vous corrompez le fichier pendant le transfert.

Je viens de tester avec l'envoi/réception d'un fichier XML et celui-ci semble être corrompu à l'arrivée, j'ai parlé au responsable du développement du serveur et en effet le problème semble venir de là.

Dans la méthode createPCAMonitor() tu sembles utiliser un flux défini en attribut d'instance...
Ce n'est pas très évident à gérer et cela aboutit souvent à une mauvaise gestion des ressources.

J'ai corrig ça en intégrant le flux dans ma méthode de boucle d'écoute.

Tu veux faire une copie par le réseau... Pourquoi ne pas directement lire le flux réseau via un ObjectInputStream plutôt que de faire une recopie dans un fichier en local ?

J'ai essayé de passer par un objet ObjectInputStream, mais j'ai aussi eu une erreur de header corrompu.

Mon client a un comportement semblable au suivant:

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
 
public class Client {
	private Socket socket;
	private boolean connected;
 
	public Client() {
	this.connected = false;
	}
 
	public void connect() {
	socket = new Socket("addr", 777);
	}
 
	public void startListening() {
		ObjectInputStream ois = null;
		try {
			ObjectInputStream = new ObjectInputStream(socket.getInputStream());
		} catch (IOException ex) {
			//Exception levée ici !
			return;
		}
 
		while (connected) {
                        //BOUCLE D'ECOUTE
			//Reception et traitement des données
			//Utilisation des méthodes readInt() et readObject() de l'ois
		}
	}
}

J'ai alors remplacé le ObjectInputStream par un DataInputStream et cela fonctionne.
Seul hic : je ne peux plus lire directement l'objet depuis le flux réseau (via readObject()).
J'ai tenté quelquechose dans le genre :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
 
	//méthode appelée dans la boucle d'écoute
	private void createPCAMonitor2(DataInputStream dis) {
        ObjectInputStream ois;
        try {
            ois = new ObjectInputStream(dis);
            try {
                PCADataModel model = (PCADataModel) ois.readObject();
                //traitement du model
            } finally {
                ois.close();
            }
        } catch (IOException ex) {
            //error reading object
        } catch (ClassNotFoundException ex) {
        }
	}

Cela semble fonctionner, le problème est que si je ferme l'ois avec l'appel à close() cela va aussi fermer mon DataInputStream dis (qui est utilisé dans la boucle d'écoute pour la réception et le traitement des données).

Du coup je dois le laisser ouvert? Ou bien passer par un autre flux que je vais pouvoir fermer sans altérer mon DataInputStream?

[MagicTux]

J'ai modifié ma méthode:

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
    private void createPCAMonitor2(DataInputStream dis, int dataSize) {
        ObjectInputStream ois;
        try {
            //ois = new ObjectInputStream(dis);
            byte[] buffer = new byte[dataSize];
            dis.readFully(buffer);
            ByteArrayInputStream bis = new ByteArrayInputStream(buffer);
            try {
                ois = new ObjectInputStream(bis);
                try {
                    PCADataModel model = (PCADataModel) ois.readObject();
                    SwingUtilities.invokeLater(new IHMBuildRunnable(model));
                } finally {
                    ois.close();
                }
            } finally {
                bis.close();
            }
        } catch (IOException ex) {
           //traitement erreur
        } catch (ClassNotFoundException ex) {
           //traitement erreur
        }
 
    }

En passant par un ByteArrayInputStream pour construire un ObjectInputStream, je peux ensuite close les 2 sans altérer le DataInputStream.

Remarque: Il me semble que le close() du ByteArrayInputStream est inutile.