Sockets - client serveur

Version imprimable

Bonjour à tous,

Je dois réaliser un projet dans le cadre d'un cours d'architecture des SI mais je suis complétement largué alors j'espere que votre communauté pourra m'aider :cry:

Je vous copie l'ennoncé pour que vous puissiez comprendre mon travail :

Développez en java et en utilisant les sockets, une application client-serveur telle qu'un utilisateur, en utilisant la partie cliente, saisit la réservation d'un billet de train (dates, horaires, classe, destination, aller-retour etc.) Cette réservation est transmise à la partie serveur pour vérification de places suffisantes (on fait l'hypothèse que la destination et autres informations sont correctes et correspondent à des trains existants). S'il reste de la place dans le train, la réservation est confirmée, sinon, l'utilisateur est averti de la non satisfaction de la requête. Vous définirez le nombre de places disponibles pour chaque train.

On utilisera l'API java.net pour l'utilisation des sockets.

Que faut il regarder ?
-Le nombre de clients connectés en meme temps.
-Verrouillage/Deverouillage (type de gestion des accés concurrents)
-2 pases COMIT (validation à deux phases)
-...

Nous avons vu en cours les architectures des SI et les relations client-serveur! Mais nous n'avons fait aucun cours de java relatif aux sockets ni quoi que ce soit...

J'ai donc commencé en faisant des recherches sur la voile en cherchant un système client serveur en java et j'ai donc trouvé ceci:

Classe ClientSocketTrain

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.ClassNotFoundException;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
 
public class ClientSocketTrain {
    public static void main(String[] args) {
        try {
            //
            // Creer une connection avec le socket serveur sur l'application du serveur
            //
            InetAddress host = InetAddress.getLocalHost();
            Socket socket = new Socket(host.getHostName(), 7777);
 
            //
            // Envoie un message à l'application serveur (client à l'origine)
            //
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject("test");
 
            //
            // Lit et affiche la réponse du message envoyé par l'application serveur
            //
            ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
            String message = (String) ois.readObject();
            System.out.println("Message: " + message);
 
            ois.close();
            oos.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
}

Classe ConnectionHandler:

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.ClassNotFoundException;
import java.net.Socket;
 
class ConnectionHandler implements Runnable {
    private Socket socket;
 
    public ConnectionHandler(Socket socket) {
        this.socket = socket;
 
        Thread t = new Thread(this);
        t.start();
    }
 
    public void run() {
        try
        {
            //
            // Lit le message envoyé par l'application client
        	//
            ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
            String message = (String) ois.readObject();
 
            System.out.println("Message Recu: " + message);
 
 
 
            // 
            // Envoie une réponse à l'application cliente
            //
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject("Bonjour...");
 
            ois.close();
            oos.close();
            socket.close();
 
            System.out.println("En attente d'un message du client...");
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
}

Classe ServerSocketTrain:

Code:

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
30
31
32
33
34
35
36
37
38
import java.io.IOException;
import java.net.Socket;
import java.net.ServerSocket;
 
public class ServerSocketTrain {
    private ServerSocket server;
    private int port = 7777;
 
    public ServerSocketTrain() {
        try {
            server = new ServerSocket(port);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
 
    public static void main(String[] args) {
        ServerSocketTrain example = new ServerSocketTrain();
        example.handleConnection();
    }
 
    public void handleConnection() {
        System.out.println("En attente du message du client...");
 
        //
        // Ici le serveur fait une boucle pour accepter toutes les connections engagées par
        // l'application cliente.
        //
        while (true) {
            try {
                Socket socket = server.accept();
                new ConnectionHandler(socket);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

Tout fonctionne pour le moment! En meme temps j'ai juste récupérer du code! Mais maintenant je ne sais vraiment pas par ou commencer... j'ai vraiment besoin de votre aide alors j'espere que vous allez rapidement me répondre pour que je puisse travailler dessus ! De plus notre professeur ne nous a donné que 5 jours de délai. Jusqu'à lundi prochain..

Merci d'avance

29/10/2009, 22h42
DaveRidic
Bonsoir,

ce qu'il faut savoir, c'est que le package java.net te fournit 2 classes qui te seront très utiles :
- Socket
- ServerSocket
Tu vas devoir créer 2 applications.
- Une côté client, qui utilise un objet de la classe Socket
- Et une côté server qui utilise un objet de la classe ServerSocket
Commence par faire des recherches sur ces deux classes et renseigne-toi bien sur ce site. (exemple : http://gfx.developpez.com/tutoriel/java/network/)

Pour faire simple, un socket est une route à double sens (un sens entrant appelé "inputStream" et un sens sortant appelé "outputStream").

1°) Ton appli client collecte les informations de réservation
2°) Elle envoie ces infos, via le outputStream de ton Socket à ton appli serveur
3°) Ton appli serveur lit ses informations sur son inputStream
4°) Il traite ses informations (vérification de places disponibles)
5°) Il envoie la réponse, via le outputStream de ton ServerSocket à ton appli client
6°) Ton appli client lit la réponse dans son inputStream et la traite

Ce n'est pas très compliqué, tu verras. Allez, bon courage ! ;)

Alors dans un premier temps tu vas devoir creer un objet Train, un objet Billet et un objet Reservation. Pour commencer il vaut mieux faire assez simple, et etoffer après. Par exemple:

La classe billet

Code:

1
2
3
4
5
6
7
8
9
 
public class Billet{
 private String nomDuClient;
 
 //constructeur de l'objet Billet
 public Billet(String nomDuClient){
  this.nomDuClient=nomDuClient;
 }
}

la classe Train

Code:

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
30
31
32
33
34
35
36
 
public class Train{
 private int idTrain;
 private String destination;
 private Billet[] tabBillet;
 
 //constructeur de Train
 public Train(int idTrain,String destination, int nbPlace){
  this.idTrain=idTrain;
  this.destination=destination;
  tabBillet=new Billet[nbPlace];
 }
 //Fonction pour ajouter un billet au train
 //elle retourne true si le billet est ajouté, sinon false.
 //elle est synchronized pour qu'un seul thread puisse l'utiliser en même temps
 public synchronized boolean ajouterBillet(Billet leBillet){
  for(int cpt=0;cpt<tabBillet.length;cpt++){
   if(tabBillet[cpt]==null){
    tabBillet[cpt]=leBillet;
    return true; 
   }
  }
  return false;
 }
 //Fonction pour afficher ton train
 public String afficherTrain(){
  int nbPlaceLibre=0;
  for(int cpt=0;cpt<tabBillet.length;cpt++){
   if(tabBillet==null){
    nbPlaceLibre=tabBillet.length-cpt;
    break;
   }
  }
  return "Train N°"+idTrain+",Destination: "+destination+", Nbre place dispo: "+nbPlaceLibre;
 }
}

Ta classe Reservation

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
 
public class Reservation implements Serializable{
 int idTrain;
 Billet leBillet;
 public Reservation(int idTain, String nomClient){
  this.idTrain=idTrain;
  this.leBillet=new Billet(nomClient);
 }
 //accesseurs
 public int getIdTrain(){
  return this.idTrain;
 }
 public Billet getBillet(){
  return leBillet;
 }
}

tuto pour la synchronisation:http://rom.developpez.com/java-synchronisation/
A partir de là, sur ton serveur tu peux créer une liste de trains (3 ou 4 pour avoir un jeu d'essai un peu représentatif);
par exemple:

Code:

1
2
3
4
5
6
7
8
 
private ArrayList<Train> listeTrain;
 
listeTrain=new ArrayList<Train>();
listeTrain.add(new Train(1,"Toulouse",20));
listeTrain.add(new Train(2,"Rouen",10));
listeTrain.add(new Train(3,"Montpellier",30));
listeTrain.add(new Train(4,"Paris",50));

Toujours sur ton serveur de socket il te faut une fonction pour envoyer un affichage de ta liste de trains
+ un accesseur sur ta liste de train

Code:

1
2
3
4
5
6
7
8
9
10
11
 
public String[] afficherListeTrain(){
 String[] list=new String[listeTrain.size()];
 for(int cpt=0;cpt<listeTrain.size();cpt++){
  list[cpt]=listeTrain.get(cpt);
 }
 return list;
}
public ArrayList<Train> getListeTrain(){
 return listeTrain;
}

Et passer une reference sur du serverSocketTrain sur ConenctionHandler

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
 
 //dans ServerSocketTrain
 while (true) {
            try {
                Socket socket = server.accept();
                new ConnectionHandler(socket,this);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
 //dans ConnectionHandler
 private Socket socket;
 private ServerSocketTrain serveur;
 private thread t;
 public ConnectionHandler(Socket socket, ServerSocketTrain serveur) {
  this.socket = socket;
  this.serveur=serveur;
  t = new Thread(this);
  t.start();
 }
 //petite modif sur ton run (finalement un grosse)
 public void run(){
  //on créé les moyen de communiquer avec le client
  ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
  ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
  //defacto on envoie la liste des trains au client
  //pas certain qu'on puisse directement envoyer un tableau de string 
  //mais on  va faire comme si
  oos.writeObject(serveur.afficherListeTrain());
  oos.flush();
  Object lecture;
  while(!socket.isClosed){
   lecture=ois.readObject();
   if(lecture instanceOf Reservation){
    int idTrain=(Reservation) lecture.getIdTrain();
    Train train=null;
    for(int cpt=0;cpt<serveur.getListeTrain().size();cpt++){
     if(serveur.getListeTrain().get(cpt).getIdTrain()==idTrain){
      train=serveur.getListeTrain.get(cpt);
      break;
     }
    }
    if(train!=null){
     boolean ajout=train.ajouterBillet((Reservation)lecture.getBillet());
     oos.writeBoolean(ajout);
     oos.flush;
     t.sleep(100);
     oos.writeObject(serveur.afficherListeTrain());
     oos.flush;
    }
   } 
  }
  oos.close();
  ois.close();
 }

Avec ca tu as les grande lignes du serveur (va falloir certainement ajuste et corriger certaines chose);
Avant de se connecter au serveur, le client devra saisir sont nom.
Qd ton client va se connecter, il faut qu'il interprete la liste des trains (un String[]) et l'afficher.
Ton utilisateur devra choisir un train (en saisissant l'idTrain du train par exemple);
Ton client créé un objet Reservation en fonction du idTrain choisi et du nom client;
La reservation est envoyé au serveur;
Le serveur repond pas true ou false pour valider la reservation.

Citation:

-Le nombre de clients connectés en meme temps.

Au niveau de ton serveur de socket tu peux imlpementer un variable static "nbClient" initialiser a 0. A chaque fois que tu accepte une connection tu l'incremente de 1, et tu la décremente de 1 lors de la deconnection.
Pour ça, l'ideal est de passer par des fonctions synchronisées etant donné que tu va faire du multiThreading.

Bon y a vraiment les grandes lignes, va certainement te faloir un peu de boulot pour que ca marche (l'utilisation d'un IDE c'est qd meme mieux: voir eclipse).. bonne chance :ccool:

02/11/2009, 12h50
Vinceee38

Waouu merci beaucoup pour vos réponses, je vais regarder ca de tres pres , j'ai deux heures pour le faire. Je vous tiens au courant mais je pense pouvoir deja enormement avancer avec ce que vous m'avez fourni. Merci beaucoup c'est super :ccool:

Voila ou j'en suis :

Je lance l'application serveur qui elle s'execute correctement et m'affiche le message: en attente du message client...

Seulement voila quand j'execute le coté client voila l'erreur qui s'affiche du coté serveur:
Code:

1 2 3 4 5 6 java.io.EOFException at java.io.ObjectInputStream$BlockDataInputStream.peekByte(Unknown Source) at java.io.ObjectInputStream.readObject0(Unknown Source) at java.io.ObjectInputStream.readObject(Unknown Source) at ConnectionHandler.run(ConnectionHandler.java:34) at java.lang.Thread.run(Unknown Source)
et voici le message qui m'est retourné du coté client :

Code:

Message: [Ljava.lang.String;@a90653

Est ce que vous auriez une idée sur cette erreur que je n'arrive pas à comprendre! Pourtant j'ai cherché sur le net

Merci d'avance :ccool:

02/11/2009, 15h10
Torg666

Tu as un problème de End of File (c'est bien la premiere fois que je la vois celle là)... sans code ca va etre difficile de t'aider.
Pense aussi que tu a la javadoc qui te permet de "décoder" les exceptions et optionnellement aussi de connaitre un peu mieux les objets que tu manipule :ccool:
(suffit de cliquer sur le lien de ma signature)

Merci beaucoup pour ta réponse vraiment trés rapide !

J'ai essayé de me renseigner sur diverses recherches et j'ai trouvé quelques trucs disant que j'executais soit disant le thread trop tot.

Je ne vois pas vraiment ! Je pensais mettre un sleep mais apparement ca ne marche pas !

Je laisse le code de ma classe serveur peut etre que tu pourra m'aider un peu plus facilement :

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
import java.io.IOException;
import java.net.Socket;
import java.net.ServerSocket;
import java.util.ArrayList;
 
public class ServerSocketTrain {
    private ServerSocket server;
    private int port = 8765;
    private ArrayList<Train> listeTrain;
 
 
    public ServerSocketTrain() {
        try {
            server = new ServerSocket(port);
            listeTrain=new ArrayList<Train>();
            listeTrain.add(new Train(1,"Toulouse",20));
            listeTrain.add(new Train(2,"Rouen",10));
            listeTrain.add(new Train(3,"Montpellier",30));
            listeTrain.add(new Train(4,"Paris",50));
 
 
        } 	catch (IOException e) {
            e.printStackTrace();
        }
 
    }
 
    public static void main(String[] args) {
        ServerSocketTrain example = new ServerSocketTrain();
        example.handleConnection();
    }
 
    public void handleConnection() {
        System.out.println("En attente du message du client...");
 
        //
        // Ici le serveur fait une boucle pour accepter toutes les connections engagées par
        // l'application cliente.
        //
        while (true) {
            try {
                Socket socket = server.accept();
                new ConnectionHandler(socket, this);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
 
    public String[] afficherListeTrain(){
    	String[] list=new String[listeTrain.size()];
    	for(int cpt=0;cpt<listeTrain.size();cpt++){
 
    		list[cpt]= listeTrain.get(cpt).toString();
    	}
    	return list;
    }
 
    public ArrayList<Train> getListeTrain(){
    	return listeTrain;
    }
 
 
}

Merciiiiiiiiiiiiiiiiiiiii :oops:

Ah oui et la classe client :

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.ClassNotFoundException;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
 
public class ClientSocketTrain {
    public static void main(String[] args) {
        try {
            //
            // Creer une connection avec le socket serveur sur l'application du serveur
            //
            InetAddress host = InetAddress.getLocalHost();
            Socket socket = new Socket(host.getHostName(), 8765);
 
            //
            // Envoie un message à l'application serveur (client à l'origine)
            //
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject("test");
 
            //
            // Lit et affiche la réponse du message envoyé par l'application serveur
            //
            ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
            String message = ois.readObject().toString();
            System.out.println("Message: " + message);
 
            ois.close();
            oos.flush();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        	catch (ClassCastException e) {
            e.printStackTrace();
        }
    }
}

J'ai remarqué que quand je supprimais les ligne :

Code:

1
2
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject("test");

et le oos.flush() qui va avec, alors l'erreur n'apparait plus mais dans ce cas le programme ne fonctionne pas ! Le serveur ne recoit pas de message, et tout ce qu'on tappe du coté client ne sert a rien , et on ne recoit rien du coté client non plus

02/11/2009, 15h35
Torg666

Le code cote client ca donne quoi?
02/11/2009, 15h38
Vinceee38

Je l'ai mi un peu plus haut :/ Désolé j'ai été un peu lent

Citation:
Code:

1 2 String message = ois.readObject().toString();
Te renvoi l'adresse memoire, normal car il lit un objet de type Object.
Si, comme dans mon exemple, tu renvoi un tableau de String il faut faire:
Code:

1 2 3 4 5 6 7 8 9 Object message= ois.readObject(); if(message instanceOf String[]){ String[] tableString=(String[])message; } //et ensuite passer ca dans une boucle for(int cpt=0;cpt<tableString.length;cpt++){ System.out.(tableString[cpt]); }
Si tu renvoi à la connection un String (genre: "vous etes connecté"), alors:
Code:

1 2 3 4 5 Object message=ois.readObject(); if(message instanceOf String){ System.out.println((String)message); }
Essaye de flush oos apres avoir fait ton writeObject("test");

De plus tu as oublié de fermer oos et socket. :aie:

Vois si ca resoud pas le souci

Merci beaucoup , j'ai remplacé mon code en suivant tes conseils, en revanche il y a une chose que ne comprend pas c'est dans ServerSocketTrain :
Code:

1 2 3 4 5 6 7 public String[] afficherListeTrain(){ String[] list=new String[listeTrain.size()]; for(int cpt=0;cpt<listeTrain.size();cpt++){ list[cpt]= listeTrain.get(cpt).toString(); } return list; }
Si je ne met pas le toString() alors j'ai une erreur:

Type mismatch: cannot convert from Train to String

Je vais essayer de comprend merci beaucoup

Meme quand j'essaye de le "caster" il n'y a rien à faire cela ne veux pas :cry:

Citation:
Envoyé par Vinceee38
Merci bcp , j'ai remplacé mon code en suivant tes conseils, en revanche il y a une chose que ne comprend pas c'est dans ServerSocketTrain :
Code:

1 2 3 4 5 6 7 public String[] afficherListeTrain(){ String[] list=new String[listeTrain.size()]; for(int cpt=0;cpt<listeTrain.size();cpt++){ list[cpt]= listeTrain.get(cpt).toString(); } return list; }
Si je ne met pas le toString() alors j'ai une erreur:

Type mismatch: cannot convert from Train to String

Je vais essayer de comprend merci bcp
Normal, j'ai fait une boulette :mouarf:
en fait ce qu'il faudrai faire:
Code:

1 2 3 4 5 6 7 8 public String[] afficherListeTrain(){ String[] list=new String[listeTrain.size()]; for(int cpt=0;cpt<listeTrain.size();cpt++){ list[cpt]= listeTrain.get(cpt).afficherTrain(); } return list; }
En fait là, listeTrain.get(cpt) te renvoi un objet de type Train. Pour l'afficher correctement, il faut appeler la methode afficherTrain() de ton instance de Train.
Par contre, le toString va bien renvoyer un String... mais c'est la reference (ou adresse memoire) de cette instance de Train qu'il va te renvoyer :ccool:

je t'invite à regarder dans la classe Object la methode toString(), vu que toute les classes héritent de la classe Object (si je dis pas de bêtise 8O ).
La javadoc c'est vraiment incontournable si tu veux développer :aie:

Hihi merci ca marche puis j'ai meme compris pour l'histoire du toString() :)

Effectivement c'est mieux en appellant la méthode ! Par contre l'erreur EOFExecption persiste :(

Voici à quoi ressemble mes deux classes mnt:

Client:

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.ClassNotFoundException;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
 
public class ClientSocketTrain {
    public static void main(String[] args) {
        try {
            //
            // Creer une connection avec le socket serveur sur l'application du serveur
            //
            InetAddress host = InetAddress.getLocalHost();
            Socket socket = new Socket(host.getHostName(), 8765);
 
            //
            // Envoie un message à l'application serveur (client à l'origine)
            //
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject("test");
            oos.flush();
 
            //
            // Lit et affiche la réponse du message envoyé par l'application serveur
            //
            ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
            Object message= ois.readObject();
            String[] tableString = null;
            if(message instanceof String[]){
             tableString=(String[])message;
            }
            //et ensuite passer ca dans une boucle
            for(int cpt=0;cpt< tableString.length;cpt++){
             System.out.println(tableString[cpt]);
            }
 
            System.out.println("Message: " + message);
 
            ois.close();
            oos.flush();
            socket.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        	catch (ClassCastException e) {
            e.printStackTrace();
        }
    }
}

serveur:

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
import java.io.IOException;
import java.net.Socket;
import java.net.ServerSocket;
import java.util.ArrayList;
 
public class ServerSocketTrain {
    private ServerSocket server;
    private int port = 8765;
    private ArrayList<Train> listeTrain;
 
 
    public ServerSocketTrain() {
        try {
            server = new ServerSocket(port);
            listeTrain=new ArrayList<Train>();
            listeTrain.add(new Train(1,"Toulouse",20));
            listeTrain.add(new Train(2,"Rouen",10));
            listeTrain.add(new Train(3,"Montpellier",30));
            listeTrain.add(new Train(4,"Paris",50));
 
 
        } 	catch (IOException e) {
            e.printStackTrace();
        }
 
    }
 
    public static void main(String[] args) {
        ServerSocketTrain example = new ServerSocketTrain();
        example.handleConnection();
    }
 
    public void handleConnection() {
        System.out.println("En attente du message du client...");
 
        //
        // Ici le serveur fait une boucle pour accepter toutes les connections engagées par
        // l'application cliente.
        //
        while (true) {
            try {
                Socket socket = server.accept();
                new ConnectionHandler(socket, this);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
 
    public String[] afficherListeTrain(){
    	 String[] list=new String[listeTrain.size()];
    	 for(int cpt=0;cpt<listeTrain.size();cpt++){
    	  list[cpt]= listeTrain.get(cpt).afficherTrain();
    	 }
    	 return list;
    	}
 
 
    public ArrayList<Train> getListeTrain(){
    	return listeTrain;
    }
 
 
}

Je suis embetant je sais mais tu es mon seul espoir :ccool:

merci encore

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
public class ClientSocketTrain {
 public static void main(String[] args) {
  try {
// Creer une connection avec le socket serveur sur l'application du serveur
   InetAddress host = InetAddress.getLocalHost();
   Socket socket = new Socket(host.getHostName(), 8765);
// Envoie un message à l'application serveur (client à l'origine)
   ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
   oos.writeObject("test");
   oos.flush();
// Lit et affiche la réponse du message envoyé par l'application serveur
   ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
   Object message= ois.readObject();
   String[] tableString = null;
   if(message instanceof String[]){
    tableString=(String[])message;
   }
//et ensuite passer ca dans une boucle
   for(int cpt=0;cpt< tableString.length;cpt++){
     System.out.println(tableString[cpt]);
   }
// assez inutile, tu affiche l'adresse mémoire de message
   System.out.println("Message: " + message);
  } catch (UnknownHostException e) {
   e.printStackTrace();
  } catch (IOException e) {
   e.printStackTrace();
  } catch (ClassNotFoundException e) {
   e.printStackTrace();
  }catch (ClassCastException e) {
   e.printStackTrace();
//Block finally pour s'assurer que tout est bien fermé
  }finally{
   try{
    oos.close();
    ois.close();
    socket.close();
    }catch(IOException ioe){
     ioe.printStackTrace();
    }
  }
 }
}

En ce qui concerne la EOFException, ca indique que tu as atteind la fin de la lecture. Avec ce code, as-tu la liste des trains qui s'affiche coté client?
Edit: renvoi l'integralité du message d'erreur

Merci merci !

Donc deja avant d'executer le code cela me met une erreur sur :
Code:

1 2 3 oos.close(); ois.close(); socket.close();
Il me dit pour chacun qu'il ne peut pas etre resolved.

J'ai donc enlevé le try catch qui concernait ce bout de code et j'ai executé pour voir !

Du coté client cela affiche ceci:
Code:

1 2 3 4 5 Train N°1,Destination: Toulouse, Nbre place dispo: 0 Train N°2,Destination: Rouen, Nbre place dispo: 0 Train N°3,Destination: Montpellier, Nbre place dispo: 0 Train N°4,Destination: Paris, Nbre place dispo: 0 Message: [Ljava.lang.String;@de6ced
Ca marche du coté client mais la place dispo est à 0 et le message est toujours "bisar" (le code memoire quoi)lol

Sinon coté serveur :
Code:

1 2 3 4 5 6 7 8 9 10 11 En attente du message du client... java.net.SocketException: Connection reset at java.net.SocketInputStream.read(Unknown Source) at java.net.SocketInputStream.read(Unknown Source) at java.io.ObjectInputStream$PeekInputStream.peek(Unknown Source) at java.io.ObjectInputStream$BlockDataInputStream.peek(Unknown Source) at java.io.ObjectInputStream$BlockDataInputStream.peekByte(Unknown Source) at java.io.ObjectInputStream.readObject0(Unknown Source) at java.io.ObjectInputStream.readObject(Unknown Source) at ConnectionHandler.run(ConnectionHandler.java:34) at java.lang.Thread.run(Unknown Source)
Peut etre l'erreur est due au bout de code que j'ai enlevé comme je l'explique plus haut !

Arf je me suis fais avoir comme une bleusaille :mouarf:
J'ai pas tenu compte de la portée des variables:

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
 
public class ClientSocketTrain {
 
 public static void main(String[] args) {
 ObjectOutputStream oos=null;
 ObjectInputStream ois=null;
 Socket socket=null;
  try {
// Creer une connection avec le socket serveur sur l'application du serveur
// A propos ça marche uniquement si les 2 appli tourne sur le meme poste.
   InetAddress host = InetAddress.getLocalHost();
   socket = new Socket(host.getHostName(), 8765);
// Envoie un message à l'application serveur (client à l'origine)
   oos = new ObjectOutputStream(socket.getOutputStream());
   oos.writeObject("test");
   oos.flush();
// Lit et affiche la réponse du message envoyé par l'application serveur
   ois = new ObjectInputStream(socket.getInputStream());
   Object message= ois.readObject();
   String[] tableString = null;
   if(message instanceof String[]){
    tableString=(String[])message;
   }
//et ensuite passer ca dans une boucle
   for(int cpt=0;cpt< tableString.length;cpt++){
     System.out.println(tableString[cpt]);
   }
// assez inutile, tu affiche l'adresse mémoire de message
   System.out.println("Message: " + message);
  } catch (UnknownHostException e) {
   e.printStackTrace();
  } catch (IOException e) {
   e.printStackTrace();
  } catch (ClassNotFoundException e) {
   e.printStackTrace();
  }catch (ClassCastException e) {
   e.printStackTrace();
//Block finally pour s'assurer que tout est bien fermé
  }finally{
   try{
    oos.close();
    ois.close();
    socket.close();
    }catch(IOException ioe){
     ioe.printStackTrace();
    }
  }
 }
}

La socket exception est normal, tu ferme le socket, donc le serveur le signale. C'est géré comme ça.

Pour lire le String "test", il faut faire comme sur le client mais dans ton connectionhandler (un peu comme pour lire une reservation cf plus haut)

Bon et bien... moi j'ai fini ma journée, bonne chance pour la suite :ccool:

Citation:

Envoyé par Torg666

Arf je me suis fais avoir comme une bleusaille :mouarf:
J'ai pas tenu compte de la portée des variables:

La socket exception est normal, tu ferme le socket, donc le serveur le signale. C'est géré comme ça.

Pour lire le String "test", il faut faire comme sur le client mais dans ton connectionhandler (un peu comme pour lire une reservation cf plus haut)

Bon et bien... moi j'ai fini ma journée, bonne chance pour la suite :ccool:

Merci beaucoup pour m'avoir aidé autant que ca ! Je ne sais pas comment te remercier! Bonne fin de soirée à toi ;)

Si quelqu'un d'autre passe par la , du coté client je n'ai plus d'erreur mais du coté serveur j'ai de nouveau l'erreur :
Code:

1 2 3 4 5 6 7 En attente du message du client... java.io.EOFException at java.io.ObjectInputStream$BlockDataInputStream.peekByte(Unknown Source) at java.io.ObjectInputStream.readObject0(Unknown Source) at java.io.ObjectInputStream.readObject(Unknown Source) at ConnectionHandler.run(ConnectionHandler.java:34) at java.lang.Thread.run(Unknown Source)
Besoin d'aide.

Sur afficherTrain, il y a aussi un oubli (désolé):

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
 
//Fonction pour afficher ton train
 public String afficherTrain(){
  int nbPlaceLibre=0;
  for(int cpt=0;cpt<tabBillet.length;cpt++){
//ici il faut verifier que l'element du tableau est null
   if(tabBillet[cpt]==null){
    nbPlaceLibre=tabBillet.length-cpt;
    break;
   }
  }
  return "Train N°"+idTrain+",Destination: "+destination+", Nbre place dispo: "+nbPlaceLibre;
 }

Pour EOFException je vois pas par contre... :arf:
Arrive-tu as lire le "test" coté serveur?

Citation:
Envoyé par Torg666
Sur afficherTrain, il y a aussi un oubli (dsl):
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 //Fonction pour afficher ton train public String afficherTrain(){ int nbPlaceLibre=0; for(int cpt=0;cpt<tabBillet.length;cpt++){ //ici il faut verifier que l'element du tableau est null if(tabBillet[cpt]==null){ nbPlaceLibre=tabBillet.length-cpt; break; } } return "Train N°"+idTrain+",Destination: "+destination+", Nbre place dispo: "+nbPlaceLibre; }
Pour EOFException je vois pas par contre... :arf:
Arrive-tu as lire le "test" coté serveur?
Merci encore pour ton aide!
J'ai corrigé la methode afficherTrain qui affiche bien le nombre de places maintenant mais il y a toujours les memes erreurs:

coté client ca va:
Code:

1 2 3 4 5 Train N°1,Destination: Toulouse, Nbre place dispo: 20 Train N°2,Destination: Rouen, Nbre place dispo: 10 Train N°3,Destination: Montpellier, Nbre place dispo: 30 Train N°4,Destination: Paris, Nbre place dispo: 50 Message: [Ljava.lang.String;@a90653
coté serveur:
Code:

1 2 3 4 5 6 7 En attente du message du client... java.io.EOFException at java.io.ObjectInputStream$BlockDataInputStream.peekByte(Unknown Source) at java.io.ObjectInputStream.readObject0(Unknown Source) at java.io.ObjectInputStream.readObject(Unknown Source) at ConnectionHandler.run(ConnectionHandler.java:34) at java.lang.Thread.run(Unknown Source)
Il n'apparait pas le message "test" :(

J'ai peut etre fait une erreur ailleur...je ne sais pas

j'ai trouvé ca sur le web :

Code:

1
2
3
Make sure to create the input stream only after you have written the object(s).
 
Otherwise, if you create the input stream before, you will get this EOF.

Je ne sais pas si ca peut aider...

03/11/2009, 11h05
Torg666

En cherchant sur le forum, j'ai trouvé cette discution:
http://www.developpez.net/forums/d18...st-darret-eof/

Apperement ca dois venir de la condition de la boucle while.
Peux-tu redonner l'integralite du code de connectionhandler stp

C'est moi qui te remercie !

ConnectionHandler:

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.ClassNotFoundException;
import java.net.Socket;
 
class ConnectionHandler implements Runnable  {
    private Socket socket;
    private ServerSocketTrain serveur;
    private Thread t;
 
    public ConnectionHandler(Socket socket,ServerSocketTrain serveur) {
        this.socket = socket;
        this.serveur=serveur;
        t = new Thread(this);
        t.start();
 
    }
 
    public void run() {
        try
        {
        	  //on créé les moyen de communiquer avec le client
        	  ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
        	  ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
 
        	  //de fait on envoie la liste des trains au client
        	  //pas certain qu'on puisse directement envoyer un tableau de string 
        	  //mais on  va faire comme si
        	  oos.writeObject(serveur.afficherListeTrain());
        	  oos.flush();
        	  Object lecture;
        	  while(!socket.isClosed()){
        		  lecture=ois.readObject();
 
        		  if(lecture instanceof Reservation){
        			  int idTrain=((Reservation) lecture).getIdTrain();
        			  Train train=null;
        			  for(int cpt=0;cpt<serveur.getListeTrain().size();cpt++){
        				  if(serveur.getListeTrain().get(cpt).getIdTrain()==idTrain){
        					  train=serveur.getListeTrain().get(cpt);
        					  break;
        				  }
        			  }
        			  if(train!=null){
        				  boolean ajout=train.ajouterBillet(((Reservation) lecture).getBillet());
        				  oos.writeBoolean(ajout);
        				  oos.flush();
        				  Thread.sleep(100);
 
        				  oos.writeObject(serveur.afficherListeTrain());
        				  oos.flush();
        			  }
        		  } 
        	  }
        	  oos.close();
        	  ois.close();
 
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
			e.printStackTrace();
		}
    }
 
 
}

Je vais aller voir le sujet dont tu parles, je ne penses pas que je comprendrais mieux que toi mais on sait jamais j'aurais peut etre un declic :mouarf:

ok donc la EOFexception est normale, il faut la gérer.
J'ai modifié le code donc j'envoi toutes les classes:
ClientSocketTrain

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
 
public class ClientSocketTrain {
 
	public static void main(String[] args) {
		ObjectOutputStream oos=null;
		ObjectInputStream ois=null;
		Socket socket=null;
		String[] tableString=null;
		Object message=null;
		try {
// Creer une connection avec le socket serveur sur l'application du serveur
// A propos ça marche uniquement si les 2 appli tourne sur le meme poste.
			InetAddress host = InetAddress.getLocalHost();
			socket = new Socket(host.getHostName(), 8765);
// Envoie un message à l'application serveur (client à l'origine)
			oos = new ObjectOutputStream(socket.getOutputStream());
			oos.writeObject("test");
			oos.flush();
 
			ois = new ObjectInputStream(socket.getInputStream());
			message= ois.readObject();
		// Lit et affiche la réponse du message envoyé par l'application serveur
			if(message instanceof String[]){
				tableString=(String[])message;
			 //et ensuite passer ca dans une boucle
				for(int cpt=0;cpt< tableString.length;cpt++){
					System.out.println(tableString[cpt]);
				}
			}
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}catch (ClassCastException e) {
			e.printStackTrace();
//Block finally pour s'assurer que tout est bien fermé
		}finally{
			try{
				oos.close();
				ois.close();
				socket.close();
			}catch(IOException ioe){
				ioe.printStackTrace();
			}
		}
	}
}

ServerSocketTrain

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
 
import java.io.IOException;
import java.net.ServerSocket;
import java.util.ArrayList;
 
public class ServerSocketTrain {
    private ServerSocket server;
    private int port = 8765;
    private ArrayList<Train> listeTrain;
 
    public static void main(String[] args) {
        ServerSocketTrain example = new ServerSocketTrain();
        example.handleConnection();
    }
 
    public ServerSocketTrain() {
        try {
            server = new ServerSocket(port);
            listeTrain=new ArrayList<Train>();
            listeTrain.add(new Train(1,"Toulouse",20));
            listeTrain.add(new Train(2,"Rouen",10));
            listeTrain.add(new Train(3,"Montpellier",30));
            listeTrain.add(new Train(4,"Paris",50));
        }catch (IOException e) {
        	e.printStackTrace();
        }	
    }
    public void handleConnection() {
        System.out.println("En attente du message du client...");
// Ici le serveur fait une boucle pour accepter toutes les connections engagées par
// l'application cliente.
        while (!server.isClosed()) {
            try {
                new ConnectionHandler(server.accept(), this);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
 
    public String[] afficherListeTrain(){
    	String[] list=new String[listeTrain.size()];
    	for(int cpt=0;cpt<listeTrain.size();cpt++){
    		list[cpt]= listeTrain.get(cpt).afficherTrain();
    	}
    	return list;
    }
 
    public ArrayList<Train> getListeTrain(){
    	return listeTrain;
    }
}

ConnectionHandler

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
 
import java.io.EOFException;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.ClassNotFoundException;
import java.net.Socket;
 
class ConnectionHandler implements Runnable  {
    private Socket socket=null;
    private ServerSocketTrain serveur=null;
    private Thread t=null;
    private ObjectInputStream ois=null;
    private ObjectOutputStream oos=null;
    private Object lecture=null;
    private int idTrain=0;
    private Train train=null;
    private boolean ajout=false;
    private boolean hasObject=false;
 
    //Constructeur
    public ConnectionHandler(Socket socket,ServerSocketTrain serveur) {
        this.socket = socket;
        this.serveur=serveur;
        t = new Thread(this);
        t.start();
    }
    //fonction run du thread
    public void run() {
        try{
//on créé les moyen de communiquer avec le client
        	ois = new ObjectInputStream(socket.getInputStream());
        	oos = new ObjectOutputStream(socket.getOutputStream());
//de fait on envoie la liste des trains au client
//pas certain qu'on puisse directement envoyer un tableau de string 
//mais on  va faire comme si
        	oos.writeObject(serveur.afficherListeTrain());
        	oos.flush();
        	hasObject=true;
        	while(!socket.isClosed()&& hasObject){
        		try{
        			lecture=ois.readObject();
        			if(lecture instanceof Reservation){
        				idTrain=((Reservation) lecture).getIdTrain();
        				for(int cpt=0;cpt<serveur.getListeTrain().size();cpt++){
        					if(serveur.getListeTrain().get(cpt).getIdTrain()==idTrain){
        						train=serveur.getListeTrain().get(cpt);
        						break;
        					}
        				}
        				if(train!=null){
        					ajout=train.ajouterBillet(((Reservation) lecture).getBillet());
        					oos.writeBoolean(ajout);
        					oos.flush();
        					oos.writeObject(serveur.afficherListeTrain());
        					oos.flush();
        				}
        			}else if(lecture instanceof String){
        				System.out.println((String)lecture);
        			}
        		}catch(EOFException eof){
        			hasObject=false;
        			System.out.println("Fin connection du client");
        		}
        	}
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }finally{
			try {
				ois.close();
				oos.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
    	}
    }
}

Train

Code:

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
30
31
32
33
34
35
36
37
38
39
40
 
public class Train{
	private int idTrain;
	private String destination;
	private Billet[] tabBillet;
 
 //constructeur de Train
	public Train(int idTrain,String destination, int nbPlace){
		this.idTrain=idTrain;
		this.destination=destination;
		tabBillet=new Billet[nbPlace];
	}
 //Fonction pour ajouter un billet au train
 //elle retourne true si le billet est ajouté, sinon false.
 //elle est synchronized pour qu'un seul thread puisse l'utiliser en même temps
	public synchronized boolean ajouterBillet(Billet leBillet){
		for(int cpt=0;cpt<tabBillet.length;cpt++){
			if(tabBillet[cpt]==null){
				tabBillet[cpt]=leBillet;
				return true; 
			}
		}
		return false;
	}
 //Fonction pour afficher ton train
	public String afficherTrain(){
		int nbPlaceLibre=0;
		for(int cpt=0;cpt<tabBillet.length;cpt++){
			if(tabBillet[cpt]==null){
				nbPlaceLibre=tabBillet.length-cpt;
				break;
			}
		}
		return "Train N°"+idTrain+",Destination: "+destination+", Nbre place dispo: "+nbPlaceLibre;
	}
 //accesseur sur idTrain
	public int getIdTrain(){
		return idTrain;
	}
}

Billet

Code:

1
2
3
4
5
6
7
8
9
 
public class Billet{
	private String nomDuClient;
 
 //constructeur de l'objet Billet
	public Billet(String nomDuClient){
		this.nomDuClient=nomDuClient;
	}
}

Reservation

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
import java.io.Serializable;
 
public class Reservation implements Serializable{
	private int idTrain;
	private Billet leBillet;
 
	public Reservation(int idTrain, String nomClient){
		this.idTrain=idTrain;
		this.leBillet=new Billet(nomClient);
	}
//accesseurs
	public int getIdTrain(){
		return this.idTrain;
	}
	public Billet getBillet(){
		return leBillet;
	}
}

Bon et la ca marche :ccool:

Bon il te reste à faire:
- Afficher le nombre de clients connectés: je t'ai donné la solution, reste qu'a l'implementer.
- Ecouter la saisie du client et envoyer une reservation au serveur: je te conseil de regarder la classe scanner dans la javadoc, il faut aussi que tu ajoute la classe reservation du côté client.
- Ecouter la reponse du serveur lorsqu'il repond a une reservation.
- Selon l'ennoncé, il te faut introduire une validation avant d'ajouter un billet au train (l'histoire de commit en 2 phases si j'ai bien pigé)
- le multithreading.... voir le tutorial sur la synchronisation.

Hésite pas si tu as des questions, mais avec ce qu'on a déjà fait et pour peux que tu ai un peu compris ca devrai pas poser trop de souci :mrgreen:

03/11/2009, 12h51
Vinceee38

Citation:

Envoyé par Torg666

Bon et la ca marche :ccool:

Bon il te reste à faire:
- Afficher le nombre de clients connectés: je t'ai donné la solution, reste qu'a l'implementer.
- Ecouter la saisie du client et envoyer une reservation au serveur: je te conseil de regarder la classe scanner dans la javadoc, il faut aussi que tu ajoute la classe reservation du côté client.
- Ecouter la reponse du serveur lorsqu'il repond a une reservation.
- Selon l'ennoncé, il te faut introduire une validation avant d'ajouter un billet au train (l'histoire de commit en 2 phases si j'ai bien pigé)
- le multithreading.... voir le tutorial sur la synchronisation.

Hésite pas si tu as des questions, mais avec ce qu'on a déjà fait et pour peux que tu ai un peu compris ca devrai pas poser trop de souci :mrgreen:

Rolala effectivement tout marche maintenant c'est génial merci beaucoup :)

Dans un premier je vais essayer de prendre en compte la saisie du client pour créer une réservation ! ca sera deja bien ! Je te tiens au courant ;)

MERCI MERCI MERCI encore ! :ccool:

Me revoila lol

J'ai reussi à faire en sorte que l'utilisateur rentre un numéro pour capturer sa demande et l'envoyer au serveur en faisant comme ceci:
Code:

1 2 3 4 5 6 7 oos = new ObjectOutputStream(socket.getOutputStream()); BufferedReader in = new BufferedReader(new InputStreamReader(System.in)); String capture = in.readLine(); oos.writeObject(capture); oos.flush();
Par contre ce que je n'arrive pas à modifier c'est le fait que la liste des trains apparait qu'aprés que l'utilisateur ait saisie son texte.

Comment puis je modifier ceci ? merci d'avance

faire en sorte que la liste des trains apparaissent directement quand l'utilisateur se connecte, et que la saisie soit demandée aprés l'affichage de la liste

Dans connectionhandler

Code:

1
2
3
4
5
6
7
8
9
 
        				if(train!=null){
        					ajout=train.ajouterBillet(((Reservation) lecture).getBillet());
        					oos.writeBoolean(ajout);
        					oos.flush();
//ici je revoi la liste des trains
//        					oos.writeObject(serveur.afficherListeTrain());
//        					oos.flush();
        				}

De plus:

Code:

1
2
3
4
5
6
7
	oos = new ObjectOutputStream(socket.getOutputStream());
 
			BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
			String capture = in.readLine();
 
			oos.writeObject(capture);
			oos.flush();

tu renvois un String au serveur, il ne va pas savoir l'interpreter correctement (il devrai juste l'afficher). Par contre si tu envoie un objet Reservation, il va l'interpreter et en plus te repondre true/false.
Attention y a quelque petite modif:
ConnectionHandler

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
 
import java.io.EOFException;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.ClassNotFoundException;
import java.net.Socket;
 
class ConnectionHandler implements Runnable  {
    private Socket socket=null;
    private ServerSocketTrain serveur=null;
    private Thread t=null;
    private ObjectInputStream ois=null;
    private ObjectOutputStream oos=null;
    private Object lecture=null;
    private int idTrain=0;
    private Train train=null;
    private boolean ajout=false;
    private boolean hasObject=false;
 
    //Constructeur
    public ConnectionHandler(Socket socket,ServerSocketTrain serveur) {
        this.socket = socket;
        this.serveur=serveur;
        t = new Thread(this);
        t.start();
    }
    //fonction run du thread
    public void run() {
        try{
//on créé les moyen de communiquer avec le client
        	ois = new ObjectInputStream(socket.getInputStream());
        	oos = new ObjectOutputStream(socket.getOutputStream());
//de fait on envoie la liste des trains au client
//pas certain qu'on puisse directement envoyer un tableau de string 
//mais on  va faire comme si
        	oos.writeObject(serveur.afficherListeTrain());
        	oos.flush();
        	hasObject=true;
        	while(!socket.isClosed()&& hasObject){
        		try{
        			lecture=ois.readObject();
        			if(lecture instanceof Reservation){
        				idTrain=((Reservation) lecture).getIdTrain();
        				for(int cpt=0;cpt<serveur.getListeTrain().size();cpt++){
        					if(serveur.getListeTrain().get(cpt).getIdTrain()==idTrain){
        						train=serveur.getListeTrain().get(cpt);
        						break;
        					}
        				}
        				if(train!=null){
        					ajout=train.ajouterBillet(((Reservation) lecture).getBillet());
        					oos.writeObject(new Boolean(ajout));
        					oos.flush();
        					oos.writeObject(serveur.afficherListeTrain());
        					oos.flush();
        				}
        			}else if(lecture instanceof String){
        				System.out.println((String)lecture);
        			}
        		}catch(EOFException eof){
        			hasObject=false;
        			System.out.println("Fin connection du client");
        		}
        	}
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }finally{
			try {
				ois.close();
				oos.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
    	}
    }
}

ClientSocketTrain

Code:

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
 
import java.io.EOFException;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
 
public class ClientSocketTrain {
 
	public static void main(String[] args) {
		ObjectOutputStream	oos=null;
		ObjectInputStream 	ois=null;
		Socket 				socket=null;
		String[] 			tableString=null;
		Object 				message=null;
		boolean 			hasObject=false;
		Scanner 			scan=new Scanner(System.in);
		String 				nom=null;
		int 				idTrain=0;
		try {
// Creer une connection avec le socket serveur sur l'application du serveur
// A propos ça marche uniquement si les 2 appli tourne sur le meme poste.
			InetAddress host = InetAddress.getLocalHost();
			socket = new Socket(host.getHostName(), 8765);
			oos = new ObjectOutputStream(socket.getOutputStream());
			ois = new ObjectInputStream(socket.getInputStream());
// Envoie un message à l'application serveur (client à l'origine)
			oos.writeObject("test");
			oos.flush();
			hasObject=true;
			while(!socket.isClosed() && hasObject){
				try{
					message= ois.readObject();
					// Lit et affiche la réponse du message envoyé par l'application serveur
						if(message instanceof String[]){
							tableString=(String[])message;
						 //et ensuite passer ca dans une boucle
							System.out.println("Liste des trains:");
							for(int cpt=0;cpt< tableString.length;cpt++){
								System.out.println(tableString[cpt]);
							}
							if(nom==null){
								System.out.println("Saisissez votre nom: ");
								nom=scan.nextLine();
								System.out.println();
							}
							System.out.println("Choissez votre train: ");
							idTrain=scan.nextInt();
							oos.writeObject(new Reservation(idTrain,nom));
							oos.flush();
						}else if(message instanceof Boolean){
							if((Boolean)message){
								System.out.println("Reservation confirmée.");
							}else{
								System.out.println("Train complet, impossible de reserver une place");
							}
						}
				}catch(EOFException eof){
					hasObject=false;
				}
			}
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}catch (ClassCastException e) {
			e.printStackTrace();
//Block finally pour s'assurer que tout est bien fermé
		}finally{
			try{
				oos.close();
				ois.close();
				socket.close();
			}catch(IOException ioe){
				ioe.printStackTrace();
			}
		}
	}
}

Billet

Code:

1
2
3
4
5
6
7
8
9
10
11
 
import java.io.Serializable;
 
public class Billet implements Serializable{
	private String nomDuClient;
 
 //constructeur de l'objet Billet
	public Billet(String nomDuClient){
		this.nomDuClient=nomDuClient;
	}
}

Pense à ajouter Reservation et Billet dans l'appli cliente.

Chez moi ca marche :ccool:

03/11/2009, 14h46
Vinceee38

C'est parfait ce que tu m'as donné ! C'est exactement ce qu'il me fallait !
Je vais essayer d'ameliorer un peu le programme mais la je pense qu'il est deja bien avancé ;)

En tout cas je ne serais jamais arrivé la sans ton aide.

Je te remercie encore :ccool:
03/11/2009, 15h22
Torg666

Citation:

Envoyé par Vinceee38

C'est parfait ce que tu m'as donné ! C'est exactement ce qu'il me fallait !
Je vais essayer d'ameliorer un peu le programme mais la je pense qu'il est deja bien avancé ;)

En tout cas je ne serais jamais arrivé la sans ton aide.

Je te remercie encore :ccool:

De rien, ca tombé bien parceque là je suis entre 2 projets donc j'ai pas grand chose à faire. Je viens de terminer un projet la dessus sauf que je ne recois pas des objets, mais des octets à traiter...
j'espère que t'as compris... parceque si t'on prof te pose des questions ça risque de poser problème 8O
03/11/2009, 15h36
Vinceee38

lol oui je pense avoir compris la base ;)
Je vais prendre le temps de bien regarder ce soir avant de l'envoyer :D

J'ai eu de la chance alors que tu passes dans le coin :)