Java

[Debutant] Pb avec ObjectOutputStream et les socket

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : [Debutant] Pb avec ObjectOutputStream et les socket

etheriel

J'arrive pas à comprendre où est le souci avec ce client et ce serveur qui communique par socket:

Client:

Code :

import java.util.HashMap;
import java.net.ServerSocket;
import java.net.Socket;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.ObjectOutputStream;
import java.io.ObjectInputStream;
import xxx.Encours;
public final class Client_tcp {
public Client_tcp() {
Encours e1 = new Encours("E1" );
Encours e2 = new Encours("E2" );
Encours e100 = new Encours("E100" );
try {
Socket s = new Socket("localhost",5432);
OutputStream os = s.getOutputStream();
InputStream is = s.getInputStream();
ObjectOutputStream oos = new ObjectOutputStream(os);
ObjectInputStream ois = new ObjectInputStream(is);
e1.setCurrent(new Integer(1));
System.out.println("envoi de "+e1.getName()+" avec current="+e1.getCurrent());
oos.writeObject(e1);
e2.setCurrent(new Integer(2));
System.out.println("envoi de "+e2.getName()+" avec current="+e2.getCurrent());
oos.writeObject(e2);
e1.setCurrent(new Integer(3));
System.out.println("envoi de "+e1.getName()+" avec current="+e1.getCurrent());
oos.writeObject(e1);
e100.setCurrent(new Integer(100));
System.out.println("envoi de "+e100.getName()+" avec current="+e100.getCurrent());
oos.writeObject(e100);
s.close();
} catch(Exception e) {
// Traitement d'erreur
e.printStackTrace();
}
}
public static void main(String a[]) throws Exception {
new Client_tcp();
}
}

Serveur:

Code :

import java.net.ServerSocket;
import java.net.Socket;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.ObjectOutputStream;
import java.io.ObjectInputStream;
import java.rmi.RemoteException;
import java.util.HashMap;
import xxx.Encours;
public final class Serveur_tcp {
public Serveur_tcp() {
Encours msg;
try {
ServerSocket ecoute = new ServerSocket(5432,5);
Socket service = (Socket)null;
while(true) {
service = ecoute.accept();
OutputStream os = service.getOutputStream();
InputStream is = service.getInputStream();
ObjectOutputStream oos = new ObjectOutputStream(os);
ObjectInputStream ois = new ObjectInputStream(is);
do
{
msg = (Encours) ois.readObject();
System.out.println("==>"+msg.getCurrent());
} while(msg.getCurrent() < 10);
System.out.println("fin de session" );
}
//service.close();
} catch (Exception e) {
// traitement d'erreur
e.printStackTrace();
}
}
public static void main(String a[]) throws Exception {
new Serveur_tcp();
}
}

Voici ce qu'envoie le client (resultat "normal" ):

Code :

envoi de EV4 avec current=1
envoi de EV5 avec current=2
envoi de EV4 avec current=3
envoi de E100 avec current=100

Voici ce que recoit le serveur:

Code :

==>1
==>2
==>1
==>100
fin du serveur

Pourquoi le serveur ne recoit-il pas la version "maj" de mon objet e1, avec la valeur "3", telle qu'elle a ete affectée dans le client ???

Message édité par etheriel le 26-02-2004 à 17:01:45

Publicité

burnedsoul

etheriel a écrit :

e1.setCurrent(new Integer(1));
System.out.println("envoi de "+e1.getName()+" avec current="+e1.getCurrent());
oos.writeObject(e1);

e2.setCurrent(new Integer(2));
System.out.println("envoi de "+e2.getName()+" avec current="+e2.getCurrent());
oos.writeObject(e2);

e1.setCurrent(new Integer(3));
System.out.println("envoi de "+e1.getName()+" avec current="+e1.getCurrent());
oos.writeObject(e1);

Ca ne serait pas plutôt "e3.setCurrent(new Integer(3));" ?

etheriel

non, non , justement: e1.setCurrent(....)
je m'attends à ce que l'objet e1, que j'ai deja transmis une fois, soit transmis à nouveau avec cette nouvelle valeur. Or c'est l'ancienne qui est recupérée !

burnedsoul

Oups pardon j'avais mal lu ton code désolé

etheriel

up !

Personne n'a une idée ?

Message édité par etheriel le 27-02-2004 à 10:04:48

jawad

moi je dirrais que le probleme se situe au niveau de xxx.Encours

EpoK

Let's burn

code de setCurrent ?

HannibAlBundie

moi, d'un point de vue personnel, j'aimerais bien voir ta classe Encours stp :jap:

Ernestor

modo-coco :o

Je replace ici un post que j'avais fait dans le topic de HannibalAlBundie, ca convient aussi je pense

J'ai eu des problèmes aussi avec les streams via des sockets. Par contre je me rappele plus dequels exactement mais je viens de jeter un oeil à mon code.

Et en gros, y a deux problèmes, deux bugs référencés :

- http://developer.java.sun.com/deve [...] 26188.html
- http://developer.java.sun.com/deve [...] 65324.html

Le premier précise qu'il faut récupérer le OutputStream avant le InputStream sur la socket. C'est ce que tu fais.

Le second, je sais plus exactement ce que c'est mais à cause de lui, dans mon code j'ai un

Code :

outputStream.reset();

placé systématiquement AVANT de faire un readObject() sur l'outputStream.

Je pense que dans le cas précis, le reset permettrait de résoudre le problème

---------------
Idéaliste pragmatique gauchiste cherche camarades pour fonder un parti

FORUM HardWare.fr

Programmation

Java

[Debutant] Pb avec ObjectOutputStream et les socket

Sujets relatifs
Que signifie "invalid_socket" ?	[java]help graph débutant
[JAVA] [debutant] To thread or not to thread?	débutant cherche outils pas cher pour programmer sous palm OS
envoyer un fichier autre que les .txt avec les socket	[java3d] Questions de debutant
[JAVA] [Débutant] Mettre en couleur les onglets d'un JTabbedPane ?	[jbuilder] ajouter package (débutant)
[C++] Debutant en Cgi sur sc12	[PB][Débutant] Sélection dans un Combobox
Plus de sujets relatifs à : [Debutant] Pb avec ObjectOutputStream et les socket

Page générée en 0.091 secondes