[Socket] Message different pour 2 execution similaire

Version imprimable

12/05/2004, 13h35
Erok

[Socket] Message different pour 2 execution similaire

Bonjour bonjour,

J'ai +ou - un problème avec une appli Client/Serveur
Je lance le serveur et le client sur la meme machine
a la conexion le serveur envoi un fichier au client
jusque la pa de probleme

mais ce qui est bizarre c'est la conxeion du client, quand je me connecte en donnant localhost comme host, je ne recois pas le fichier, il me leve EOFExcpetion, par contre quand je met 127.0.0.1, je n'ai pa cete exception et tout se deroule normalemen...

je pensais pourtan que 127.0.0.1 et localhost etai approximativement pareil...
12/05/2004, 13h40
Erok

Apparement ca marche maintenant... :?
en fait mon execution se passe en gros comme ca

Lancement du serveur
Conexion du client
Le serveur ouvre le fichier et l'envoie byte par byte
le client recoit byte par byte et ecrit dans un fichier tant que read() ne renvoie pa -1

j'utilise BufferedOutputStream et BufferedInputStream
je ne vois pa vraiment pourquoi il arrive a me lever cete excpetion qqfois
12/05/2004, 14h16
Erok

Bon je pense que je touche du doigt le probleme
en fait le serveur ouvre le fichier, mais il a peut etre pa le temps d'ouvrir le fichier avan que le premier client ne se connect...

j'apporte une petite modif a ske g mi au dessus

Lancement du serveur
Conexion du client
Le serveur ouvre le fichier et l'envoie byte par byte
le client recoit byte par byte et ecrit dans un fichier tant que read() ne renvoie pa -1
lorsqu'il recoit -1 il ecrit le tableau de byte dans un fichier
le client ouvre le fichier en lecture

l'exception est levée a la derniere etape
la reception et lecriture du fichier est gérée dans un thread
l'ouverture du fichier est dans le client qui instancie le Thread

comment je peu faire pour que le client attende que le thread ait bien ecri le fichier?

Dans ton client:

Code:

1
2
3
4
5
6
7
8
9
 
private String lock = new String("lock");
 
...
tonThread.start();
synchronized(lock)
{
  lock.wait();
}

Dans ton thread:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
 
try
{
  // reception des donnees etc ...
 
}
catch (Exception e)
{
  // ton traitement
}
finally
{
  synchronized(lock)
  {
    lock.notifyAll();
  }
}

Avec ca tu devrais t'en sortir ...

Bulbo :wink:

12/05/2004, 14h31
Erok

hmmm il me di que je ne peu pa utiliser finally san un try
:?: :?: :?: :?: :?:
12/05/2004, 14h37
bulbo

Citation:

Envoyé par Erok

hmmm il me di que je ne peu pa utiliser finally san un try
:?: :?: :?: :?: :?:

Il y a pourtant un try dans le code que je t'ai file ..

meme si le try n'est pas forcement necessaire, il vaut mieux en avoir un et mettre le notifyAll dans un finally pour eviter de laisser bloque l'autre thread en cas d'oubli..

Bulbo :wink:

oui oui j'avai vu j'ai pourtant bien adapté ton code au mien...

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
 
    try {
	    byte[] tmp = new byte[1];
	    while (i!=-1) {
	        i=entree.read(tmp);
	        monFichier.write(tmp);
	    }
	}catch(java.io.IOException e) { System.out.println("IO Error");};
 
	finally {
 	    synchronized(lock) {
   		lock.notifyAll();
  	     }
    }

a moins que j'ai fai une erreur...

12/05/2004, 14h50
bulbo

Tu as fait une erreur: le ; apres } du bloc catch...

Bulbo :wink:
12/05/2004, 14h58
Erok

Desolé j'ai du mal avec les Synchronized des threads...c un point obscur pour moi
j'ai encore 2 erreur...

ClientThread.java:47: cannot resolve symbol
symbol : variable lock
location: class ClientThread
synchronized(lock) {
^
ClientThread.java:48: cannot resolve symbol
symbol : variable lock
location: class ClientThread
lock.notifyAll();

C'est normal, il fallait adapter l'exemple :roll:

J'ai declare la variable lock private dans ton client, alors forcement le thread ne peut pas l'utiliser..

Ce que tu peux faire c'est definir des methodes dans Client qui font le boulot..
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 // Dans Client private String lock = new String("lock"); public void attendre() { synchronized(lock) { lock.wait(); } } public void debloquer() { synchronized(lock) { lock.notifyAll(); } }
Comme ca tu peux faire qq chose dans ce gout la:
Code:

1 2 monClient.debloquer();
Bulbo :wink:

12/05/2004, 15h23
Erok

Les synchronized resteront toujours un msytere pour moi je croi....
j'ai adapté ton code au mien... le blocage est fai par le Client apre l'instanciation du thread, une foi ke le thread a fini sa lecture, il appele la fonction de deblocage du pere... enfin il est sensé le faire mai apparement il le fai pas ...

javai essayé aussi que lorsque le thread est cré il blokai le client...
mai la j'avai koikil arrive un probleme avec mon fichier...
12/05/2004, 15h33
bulbo

Peux-tu montrer les bouts de codes qui posent problemes ..

Bulbo :?:

Bien sur :)

pour le client :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
 
Client(String host,int port) throws Exception{
 
	 lock = new String ("lock");
    	 S = new Socket(host,port);
         out = new PrintWriter(S.getOutputStream());
         in = new BufferedInputStream(S.getInputStream());
	 monThread = new ClientThread(out,in,this);
	 maRecherche=new Interface_RecherchePDB(this);
	 try {
	     ObjectInputStream lecture=new ObjectInputStream(new FileInputStream("./BasePDB2.dat"));
             monTableauPDB=(Vector)lecture.readObject();
	     }catch(FileNotFoundException e){System.out.println("File not found");}
              catch(ClassNotFoundException e1) {System.out.println("Class not found");}
	      catch(EOFException e3) {System.out.println("End of file error");};
	Affichage();
 
    }

le thread instancié par le client, pren en parametre les entree et sorti du socket ainsi que la classe qui l'a instacié :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
 
public void run(){
	try {monFichier = new FileOutputStream("./BasePDB2.dat");}catch(java.lang.Exception e) {};
 
	int i=1;
	monPere.blocage();
 
	try {
	    byte[] tmp = new byte[1];
	    while (i!=-1) {
	        i=entree.read(tmp);
	        monFichier.write(tmp);
	    }
	}catch(java.io.IOException e) { System.out.println("IO Error");};
 
	monPere.deblocage();
    }

c'est la version qui me fait toujours EOFException

sinon j'ai pensé a qqc dotre
ca serait rajouté dans le Client, apre la creation du thread une boucle qui attendrai que le thread soit interompu
dans le thread, une foi que j'ai lu, je fai interrupt()
comme ca je revien dan le client jouvre mon fichier, et je notify le thread...

est ce que c'est pa un peu ...bourrin comme methode?[/code]

C'est normal que ca ne marche pas.

La methode blocage() bloc le Thread qui l'execute (pas le bon dans ton cas).

Tu dois lancer le ClientThread et ensuite faire le blocage (et surtout pas faire le blocage dans le run de ton Thread)

Client:
Code:

1 2 3 4 ... monThread = new ClientThread(out,in,this); blocage()
Thread:
Code:

1 2 3 4 5 6 7 8 9 10 11 12 try { byte[] tmp = new byte[1]; while (i!=-1) { i=entree.read(tmp); monFichier.write(tmp); } }catch(java.io.IOException e) { System.out.println("IO Error"); } finally { monPere.deblocage(); }
La synchro est faite correctement dans ce cas..

Bulbo :wink:

12/05/2004, 15h56
Erok

oui je lai aussi essayé comme ca :)
mais ca se bloque sans redemarrer

mai ma solution avec interrupt et notify serai pa bonn? ou alor tro barbare?
12/05/2004, 16h07
bulbo

Trop barbare c'est clair ...

Ce que je ne comprends pas c'est que ca bloque sans redemarrer, tu fais bien un start() du Thread pour le lancer et tu n'appelles pas directement la methode run() :?:

Montre voir le constructeur de ClientThread ..

Bulbo :?:

Code:

1
2
3
4
5
6
7
 
ClientThread(PrintWriter out,BufferedInputStream in,Client C) {
        sortie=out;
	entree=in;
	monPere=C;
	this.start();
    }

12/05/2004, 16h13
bulbo

Tu as bien vire le monpere.blocage() du code du ClientThread ?

Sinon je ne vois vraiment pas pourquoi ca bloque.

Bulbo :(
12/05/2004, 16h16
Erok

ouep ...c etrange en effet
je vai verifié que l'envoi est bien fai au cas ou... pourtan g rien touché ici
12/05/2004, 16h18
Erok

le code d'envoi est bon....c'est celui que javai ecri et qui marchai
12/05/2004, 17h35
bulbo

Ecoute je te fais un pov' exemple ce soir et tu n'auras qu'a verifier les diffs
des programmes pour voir ou est la difference ...

Bulbo :wink:

Voici un exemple qui cree un fichier toto.txt dans un thread (un fichier random de 1000 lignes)
Dans le thread principal je me bloque durant l'ecriture et ensuite je compte les lignes du fichier (comme ca je suis sur que l'ecriture dans le fichier est bien termine)

Il fonctionne bien et c'est exactement le code que je t'ai file precedemment ..
si ca marche pas dans ton code n'essaie de chipoter met le code que je t'ai file tel quel et essaye de comprendre pourquoi ca marche ...

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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
 
import java.io.*;
import java.util.Random;
 
public class DummyTest
{
 
  private String lock = new String("lock");
 
  public DummyTest() throws Exception
  {
    Thread task = new Thread()
    {
      public void run()
      {
        // on cree un fichier aleatoire mais de 1000 lignes
        PrintWriter writer = null;
        try
        {
          writer = new PrintWriter(new FileOutputStream("toto.txt"), true);
          Random rd = new Random();
          int size = 0;
          int ind2 = 0;
          for (int index = 0; index < 1000; index++)
          {
            size = rd.nextInt(81);
            for (ind2 = 0; ind2 < size; ind2++)
            {
              writer.print((char) (rd.nextInt(26) + 'a'));
            }
            writer.print('\n');
            writer.flush();
          }
          System.out.println("Ecrit: 1000");
        }
        catch (Exception e)
        {
          e.printStackTrace();
        }
        finally
        {
          writer.close();
          debloquer();
        }
      }
    };
 
    task.start();
    bloquer();
    countLines();
  }
 
  private void countLines() throws Exception
  {
    BufferedReader reader = new BufferedReader(new InputStreamReader(new FileInputStream("toto.txt")));
    String line = null;
    int count = 0;
    while ((line = reader.readLine()) != null)
    {
      count++;
    }
    System.out.println("Lu : " + count);
  }
 
  public void bloquer()
  {
    synchronized (lock)
    {
      try
      {
        lock.wait();
      }
      catch (InterruptedException e)
      {
      }
    }
  }
 
  public void debloquer()
  {
    synchronized (lock)
    {
      lock.notifyAll();
    }
  }
 
  public static void main(String[] argv)
  {
    try
    {
      new DummyTest();
    }
    catch (Exception e)
    {
      e.printStackTrace();
    }
  }
 
}

Bonne chance,

Bulbo :wink:

13/05/2004, 09h56
Erok

Avant d'essayer ton code j'ai essayé une autre petite chose

une foi que mon thread a fini de lire sur le socket, il lance une fonction du Client qui permet d'ouvrir le fichier
Or on arrve jamais a ce point

sur mess bout de code qui sont au dessus, ca se situe a l'endoirt monPere.deblocage();
ce point n'est jamais atteint, c'est pour ca qu'il reste bloqué...

Qu'est ce qui empecherai que le run() d'un thread aille jusqu'a la fin...?
13/05/2004, 10h33
Erok

bon il ne sort pas de sa boucle while...ou alor il en sort mais il ne finit pa son run()....au choix mai la 2eme solution ne me parai pa possible
13/05/2004, 10h49
Erok

Bon et bien le probleme etai simple
mon thread ecoute sur le socket tant que le flux ne se termine pas
je pensai que une foi que tt les données etait transférée ca reviendrait a ce que le flux soit terminé mai en fait pas du tou... donc le thread est toujours en train de lire sur le flux d'entree et donc il ne peut pas sortir de sa boucle While
donc du coté serveur je ferme le flux ce qui signale au thread que le flux est terminé et que je peu sortir de mon while

cette partie march en tou cas

Merci bien ^^ :) :!: :!: