Discussion :

[Hippocrène]

Bonjour,

je veux utiliser WatchService et Tailer en même temps, j’ai donc écris les lignes suivantes :

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
 
                AgentTailerListener listener = new AgentTailerListener();
                Tailer tailer;
 
                WatchService watcher = FileSystems.getDefault().newWatchService();
                while (true) {
			WatchKey watchKey;
			watchKey = Paths.get("/tmp").register(watcher, ENTRY_CREATE);
			watchKey = watcher.take();
 
			for (WatchEvent<?> event : watchKey.pollEvents()) {
				if (event.kind() == StandardWatchEventKinds.ENTRY_CREATE) {
					tailSource = event.context().toString();
					System.out.println(tailSource);
					File file = new File(tailSource);
					tailer = TailerFactory.createTailer(file, listener);
					(new Thread(tailer)).start();
				}
			}
 
			watchKey.reset();
		}

Néanmoins, ce programme m’affiche
.goutputstream-44TY1X
text.log~
text.log

Mais je veux récupérer uniquement le text.log.

Dois-je utiliser une solution à base de scanner (ou équivalent) ou est-ce mon code qui pourrait être résolu en modifiant quelques trucs ?

[eulbobo]

Ca veut surtout dire que l'éditeur que tu utilises crées 2 fichiers temporaires.

Tu peux faire en sorte de filtrer par rapport au nom du fichier... Il faut qu'il y ait une extension et qu'elle ne finisse pas par ~ par exemple

[Hippocrène]

J’ai écris ça :

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
 
                        for (WatchEvent<?> event : watchKey.pollEvents()) {
                               if (event.kind() == StandardWatchEventKinds.ENTRY_CREATE) {
					tailSource = event.context().toString();
					System.out.println(tailSource);
					File file = new File("/tmp/"+tailSource);
					String end = "log";
					if(file.getName().endsWith(end)){
						tailer = TailerFactory.createTailer(file, listener);
						(new Thread(tailer)).start();;
 
					}
 
				}
			}
 
			watchKey.reset();
}

et maintenant, ça fonctionne un peu quand je lance la commande echo "auiea" > textiue.log (donc création d’un nouveau fichier) le tailer réagit mais quand je refait un echo "aiu" > textiue.log , il ne réagit pas tout le temps…

[eulbobo]

Vu le fonctionnement du WatchService (qui dépend BEAUCOUP de ton OS...), tu devrais dans une première étape récupérer uniquement le nom des fichiers créés que tu stockes dans une liste, puis traiter la liste en lançant les threads désirés après coup.

Essayes déjà ça et dis nous si ça améliore les choses (parce que là comme ça, je ne vois pas pourquoi ça bloquerai)

[Hippocrène]

En fait, je ne sais pas si c’est exactement ce que je veux…

Pour l’instant, ce n’est qu’un test donc je créé plein de fichier avec le terminal.

Mais à la fin, un serveur créera un seul fichier par jour tandis que d’un jour sur l’autre, les anciens fichiers seront sauvegardés. Et ce sera ce fichier journalier qui devra être traité par le tailer et pas un ancien ; donc je ne sais pas si une liste me serait utile…

[eulbobo]

Fais un autre programme qui crée ton fichier directement, ça te permettra d'être sûr que tu n'es pas pollué par des composants externes.

Dans windows, la création d'un nouveau fichier provoque plusieurs évènements différents, et c'est pas forcément ceux que tu veux (vu qu'il va créer deux fichiers en tout), de même que les éditeurs de textes qui risquent de créer des fichiers temporaires.


Ton programme de test :
- création d'un fichier
- petite pause
- ajout de texte dans le fichier (avec un buffer que tu flush régulièrement pour déclencher le tail)


Je pense que c'est la seule solution pour émuler le fonctionnement final que tu veux obtenir

[Hippocrène]

Merci pour ton aide.

En fait je pense avoir réussi à faire directement ce que je voulais.

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
 
                        AgentTailerListener listener = new AgentTailerListener();
			Tailer tailer;
			String tailSource;
			Thread thread;
 
			WatchService watcher = FileSystems.getDefault().newWatchService();
 
				WatchKey watchKey;
				watchKey = Paths.get("/tmp").register(watcher, ENTRY_CREATE);
 
                                //création de la liste dans laquelle je vais mettre les thread que je vais activer puis détruire au fur et à mesure du programme
				List<Thread> threadList = new ArrayList<Thread>();
				while (true) {
					watchKey = watcher.take();
					for (WatchEvent<?> event : watchKey.pollEvents()) {
					if (event.kind() == StandardWatchEventKinds.ENTRY_CREATE) {
 
						tailSource = event.context().toString();
						System.out.println(tailSource);
						File file = new File("/tmp/" + tailSource);
						String end = "log";
						if (file.getName().endsWith(end)) {
							tailer= TailerFactory.createTailer(file, listener);
                                                        //je n’arrete pas le thread au premier tour car il n’y en a pas
							if(threadList.isEmpty()){}
							else{
								Thread.sleep(1000);
								threadList.get(0).stop();
                                                                threadList.clear();}
							System.out.println(threadList.size());
							threadList.add(thread = new Thread(tailer));
							threadList.get(0).start();
						}
 
					}
				}
 
				watchKey.reset();
 
 
			}

[Hippocrène]

Finalement la réponse que je propose est vraiment trop gourmande au niveau des threads.

Je pense que l’utilisation de ThreadPools serait une bonne idée.

Mais j’ai totalement changé de plan pour cette partie, je laisse donc cette supposition sans pouvoir aller plus loin.