Forums Rue-Montgallet.com
Rue-Montgallet.comRue-Hardware.comRue-Occasion.comRue-DVD.comRue-Jeuxvideo.comRue-AudioVideo.comRue-Telephone.comForums
S'inscrire | S'identifier |
| Recherche avancée | Aide
 

  FORUM


  Programmation


  Java


  connexion client /serveur avec socket

 
 

Achat - Vente Divers : gouki9711 et 22 utilisateurs inconnus

 Mot :   Pseudo :  
 
Bas de page
Auteur
 Sujet :

connexion client /serveur avec socket

 
n°8742
guembasse
Profil : Jeune recrue
Posté le 08-06-2004 à 11:21:39  profilanswer
 

Bonjour,
Je développe une application client/serveur avec une communication via socket.
Voila mon client envoie des informations au serveur qui les traite et les renvoie au client ( tout ce qui est normal)
Mais lorsuq e que je souhaite renvoyer une autre information au serveur ce n'est pas possible car le flux d'entree du serveur est corrompu. J'ai essaye d'effectuer un flush sur le flux de sortie et un reset du flux d'entree mais ca ne fonctionne pas.Et si je ferme les flux d'entree et de sortie il me ferme également la socket et donc la connexion.  
 
Pouvez vous m'iader s'il vous plait??
Merci.

n°8774
ollone
Part of the 'One brothers
Profil : Vieux de la vieille
Posté le 08-06-2004 à 14:59:48  profilanswer
 

Essaies-tu de faire plusieurs échanges de données entre le client et le serveur à la suite, ou est-ce bien plus tard que ton client réintérroge ton serveur ?
 
Voici un exemple Thread écoutant les sockets clientes

Code :
  1. import java.net.*;
  2. import java.io.*;
  4. public class NetServerThread implements Runnable {
  5.   // Variables de classe.
  6.   private int counter = 0;
  7.   private int connectionPort;
  8.   private boolean listening = true;
  9.   private ServerSocket serverSocket;
  10.   private Socket connection;
  11.   private Socket clentSocket;
  12.   private ObjectOutputStream  output;
  13.   private ObjectInputStream  input;
  14.   private NetMessage messageObject;
  15.   private String message;
  17.   // =================================
  18.   // Constructeur du thread serveur.
  19.   // =================================
  20.   public NetServerThread(int port) {
  21.     this.connectionPort = port;
  23.     try {
  24.       serverSocket = new ServerSocket(connectionPort);
  25.       System.out.println("> SERVER : Le serveur attend les connections...\n" );
  26.     }
  27.     catch (IOException e) {
  28.       System.out.println("> SERVER : La socket serveur ne peut pas être lancée sur le port "+connectionPort+"." );
  29.       System.exit(-1);
  30.     }
  31.   }
  33.   // ===============================
  34.   // Execution initiale du Thread.
  35.   // ===============================
  36.   public void run() {
  38.     // Tant qu'on indique au thread de vivre.
  39.     while (listening) {
  40.       try {
  41.         // On accepte la socket cliente.
  42.         connection = serverSocket.accept();
  43.         // Si la connexion est établie.
  44.         if (connection.isBound()) {
  45.           ++counter;
  46.         }
  47.         // On crée maintenant les canaux d'entrée/sortie.
  48.         output=new ObjectOutputStream(connection.getOutputStream());
  49.         output.flush();
  50.         input=new ObjectInputStream(connection.getInputStream());
  51.         // On répond que la connection est établie.
  52.         sendData("SERVER >>> connection successfull" );
  54.         try {
  55.           // On récupère le contenu de la connexion (j'ai envoyé un objet ds ma socket).
  56.           messageObject = (NetMessage) input.readObject();
  57.           System.out.println("> SERVER : message recu = "+messageObject.getMessage());
  59.           // Ne fais pas attention à ca, c'est pour mon programme...
  60.           parent.chatTPane.addConvEntry(messageObject.convID, messageObject.sender, messageObject.messageStr);
  62.           // On ferme la connexion avec le client (ce qui aura pour effet de terminet la socket cliente, mais pas le "serveur" ).
  63.           sendData("TERMINATE" );
  64.         }
  65.         catch(ClassNotFoundException cnfex){
  66.           System.out.println("> SERVER : Le type de l'objet recu est inconnu!" );
  67.         }
  69.       }
  70.       catch (NotSerializableException e) {
  71.         System.out.println("> SERVER : la classe a envoyer n'est pas sérialisable!" );
  72.       }
  73.       catch (IOException e) {
  74.         System.out.println("> SERVER : l'acceptation de la socket cliente a échouée!" );
  75.       }
  76.     }
  78.     // On a décidé de ne plus écouter les appels client; le thread va se terminer.
  79.     try {
  80.       serverSocket.close();
  81.     }
  82.     catch (IOException e) {
  83.       System.out.println("> SERVER : la tentative de fermeture du thread serveur a échouée!" );
  84.     }
  85.   }
  87.   // ------------------------------------------------------------
  88.   // Méthode d'envoi d'un message à travers le canal de sortie.
  89.   // ------------------------------------------------------------
  90.   public void sendData(String s) {
  91.     try {
  92.       output.writeObject(new NetMessage("COMMAND", parent.localUserInfo, s));
  93.       output.flush();
  94.     }
  95.     catch(IOException cnfex) {
  96.       System.out.println("> SERVER : Une erreur est apparue lors de l'écriture de l'objet a envoyé." );
  97.     }
  98.   }
  100.   // ------------------------------------------------------
  101.   // Méthode permettant de mettre fin au thread d'écoute.
  102.   // ------------------------------------------------------
  103.   public void setListening(boolean state) {
  104.     listening = state;
  105.   }
  107.   // ----------------------------------------------------------
  108.   // Méthode d'affichage d'informations relatives au serveur.
  109.   // ----------------------------------------------------------
  110.   public void displayServerInfos() {
  112.     try {
  113.       NetworkInterface nwi = NetworkInterface.getByInetAddress(InetAddress.getByName(parent.localHost));
  114.       System.out.println("-------------------------------------------------" );
  115.       System.out.println("> Network interface : " + nwi.getDisplayName());
  116.       System.getProperties().list(System.out);
  117.       System.out.println("-------------------------------------------------\n" );
  118.     }
  119.     catch(IOException e) {}
  121.   }
  123. }


 
Si tu veux un exemple de code de socket cliente, fais-moi signe.

n°8853
guembasse
Profil : Jeune recrue
Posté le 08-06-2004 à 17:24:21  profilanswer
 

Ben en fait  j'essaie de faire les deux le serveur doit continuellement tourner et des qu'un client se connecte ler serveur traite les informations que ce client lui envoie et le client est capable d'effectuer plusieurs échanges de données avec le serveur.
Voila et merci beaucoup de ton aide

n°8854
ollone
Part of the 'One brothers
Profil : Vieux de la vieille
Posté le 08-06-2004 à 19:00:54  profilanswer
 

Côté client, utilises le même principe que la classe que je t'ai filée (il faut bien sur que ce soit un thread) :

Code :
  1. public void run() {
  2.   while (socketIsActive) {
  3.     [...]
  4.   }
  5. }


 
Ensuite, toujours côté client, sort de ta boucle while une fois que tu as tout traité.

n°8868
guembasse
Profil : Jeune recrue
Posté le 09-06-2004 à 11:55:20  profilanswer
 

Salut
J'ai réalisé donc un thread coté client afin que le client puisse réitérer une opération cela fonctionne mais lorsque j'effectue une deuxieme opération il me renvoie unee exception du type java.io.StreamCorruptedException alors qu'en initialisant à chaque fois le flux de sortie je fais un flush pour vider le flux mais ca ne marche pas  . Comment je peux faire?
 
Merci


Aller à :
Ajouter une réponse

  FORUM


  Programmation


  Java


  connexion client /serveur avec socket

 

Forum MesDiscussions.Net, Version 2007.2
(c) 2000-2007 No1Dev
Page générée en 0.200 secondes