Discussion :

[Fladnag]

Bonjour,

j'ai une application répartie basée sur le systeme de fichier de linux.

J'ai un Thread qui ecrit un fichier et un autre qui attend que le fichier existe et que sa taille soit differente de zero avant de le lire.

Le probleme est qu'il arrive (c'est aléatoire meme si c'est relativement rare) sur des gros fichiers (plus de 8ko) que le fichier ecrit ne s'ecrive pas completement ! (il fait pile 8192 octets au lieu de 9976) Du coup, la lecture est partielle, et mon application tombe (je lis un flux xml)

Comment est-ce possible ? y a t'il des précautions particulieres a prendre ?

Je vous donne le code des deux fonctions appelés par les thread :

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
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
/**
 * Ecrit une chaine dans un fichier
 * @param filename Le nom du fichier a ecrire
 * @param content La chaine a ecrire dans le fichier
 */
	public static void put(String filename, String content) {
System.out.println("Put "+filename+"...");		
		File f=new File(filename);
 
		try {
			FileOutputStream fos=new FileOutputStream(f);
 
			fos.write(getEncodingBytes(content));	// ecriture...
 
			fos.flush();
			fos.close();
 
			fos=null;
 
		} catch (Exception ex) {
			error("Erreur d'E/S flux sortant pour ecriture de "+content.length()+" octets dans "+filename);
			ex.printStackTrace();
		}
		f=null;
System.out.println("Put "+filename+" OK");		
	}
 
/**
 * Lit le fichier et renvoi une chaine de caractere
 * @param filename Le nom du fichier a lire
 * @return Le contenu du fichier
 */	
	public static String read(String filename) {
		String content="";
		int bufferSize=1024;
 
		byte[] buffer=new byte[bufferSize];
 
		int lus=0;
 
		FileInputStream fis=null;
		File f;		
System.out.println("Try to read "+filename+"...");		
		waitUntilExist(filename);	// attente jusqu'a ce que le fichier existe et que la taille soit differente de 0
		f=new File(filename);
 
		content="";
		try {
			fis=new FileInputStream(f);	// creation du flux
 
			while ((lus=fis.read(buffer))!=-1) {
				content+=getEncodingString(buffer, 0, lus);	// concatenation du contenu
			}
			fis.close();
			fis=null;
 
		} catch (Exception ex3) {
			error("Erreur d'E/S flux entrant sur "+filename);
			ex3.printStackTrace();
		}
 
		buffer=null;
		f=null;		
 
System.out.println("Read "+filename+" OK");
		return content;	
	}
 
 
/**
 * Attend que le fichier passé en parametre existe en faisant un sleep sur le thread courant
 * @param filename Le nom du fichier a attendre
 */	
	public static void waitUntilExist(String filename) {
		File f=new File(filename);
System.out.println("Waiting "+filename+" exist...");
		// attente jusqu'a ce que le fichier existe
int i=0;
		while (!f.exists() || (f.length()==0)) {
i++;
System.out.print("w");
				try {
					Thread.sleep(300); // attente 300ms
					i++;
				} catch (Exception ex) {}
		}
		f=null; 	
System.out.println("Sleeping "+300*i+" ms");		
	}

Merci ;o)

Fladnag

PS : les instructions qui ne sont pas indentées sont des instructions de debuggage, elles n'ont pas d'influence sur le reste du code...

[bulbo]

Le probleme c'est surement que le fichier n'est pas completement ecris lorsque la lecture commence..

Pour eviter ce probleme tu peux essayer de synchronizer les deux methodes, change juste leurs declarations comme ceci:

Code :

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

1
2
3
4
 
public static synchronized void put(String filename, String content)...
 
public static synchronizedString read(String filename)...

Cela empechera de commencer la lecture si une ecriture est en cours ...

Bulbo

[Fladnag]

Ok, merci, ca a l'air de marcher apres une petite adaptation...

Dans mes fonctions, le lecteur rentre d'abord dans la fonction, "s'endort" dedant en attendant la creation du fichier par le redacteur. J'ai donc modifié le code du lecteur par :

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
 
/**
 * Lit le fichier et renvoi une chaine de caractere
 * @param filename Le nom du fichier a lire
 * @return Le contenu du fichier
 */	
	public static String read(String filename) {
 
System.out.println("Try to read "+filename+"...");		
		waitUntilExist(filename);	// attente jusqu'a ce que le fichier existe et que la taille soit differente de 0
 
		return read2(filename);
	}
 
	synchronized public static String read2(String filename) {
		String content="";
		int bufferSize=1024;
 
		byte[] buffer=new byte[bufferSize];
 
		int lus=0;
 
		FileInputStream fis=null;
		File f;		
 
		f=new File(filename);
		content="";
		try {
			fis=new FileInputStream(f);	// creation du flux
 
			while ((lus=fis.read(buffer))!=-1) {
				content+=getEncodingString(buffer, 0, lus);	// concatenation du contenu
			}
			fis.close();
			fis=null;
 
		} catch (Exception ex3) {
			error("Erreur d'E/S flux entrant sur "+filename);
			ex3.printStackTrace();
		}
 
		buffer=null;
		f=null;		
 
System.out.println("Read "+filename+" OK");
		return content;			
	}

En rajoutant le synchonized sur le redacteur

Cependant, y aurais t'il un autre moyen ?

Car pour l'instant, je fait tourner l'application en local, mais a terme, ca sera sur le mode client/serveur, donc le lecteur sera sur une machine (une jvm) et le redacteur sur une autre jvm... je ne pense pas que les synchonized fonctionneront entre 2 jvm sur 2 machines differentes...

[bulbo]

Je ne pense pas non plus qu'un client et un serveur tournent sur la meme machine avec le meme disque donc il ne s'agira plus de lire/ecrire le meme fichier mais d'un autre probleme ...

Bulbo

[Fladnag]

si, c'est possible ;o)

En fait, mon programme doit servir de demo, et on voulait faire tourner le serveur sur une machine linux et le client sur une machine windows qui monte la partition linux a travers le reseau !

donc c'est toujours de l'ecriture/lecture de fichier, mais avec 2 jvm differentes...

[bulbo]

Ce que tu peux faire dans ce cas, c'est utiliser une socket de "controle" qui informe le client que l'ecriture est finie du cote serveur...

A mon avis ce serait plus simple de balancer directement le fichier XML sur la socket, mais bon c'est toi qui voit

Bulbo

[Fladnag]

ok, merci ;o)