Réception UDP, passer un tour de boucle

Version imprimable

Bonjour,

Voici la situation : je me connecte successivement à différents serveurs via une socket UDP au travers d'une boucle afin de récupérer certaines informations. Cependant il se peut que dans certains serveurs ne soient pas en route. Est-il possible de définir un temps d'attente max pour la réception pour "esquiver" un tour de boucle et ainsi continuer à parcourir les serveurs tout en gardant les informations obtenues avant et après le passage par le serveur "éteint" ?

voici mon bout de code qui vous aidera sans doute à comprendre :

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
//shop est la liste des serveurs
while (shop.hasNext())
			{
				String currentShop = shop.next() ;
				out.print("<form action='AdminManager'>Boutique " + currentShop);
				out.print("<input type='hidden' name='action' value='validate' />");
				out.print("<input type='hidden' name='port' value='"+ displayShops.gs.getPortCommande(currentShop) +"' />");
 
 
				DatagramPacket packet = new DatagramPacket(message,message.length,
				                                        new InetSocketAddress("localhost", displayShops.gs.getPortCommande(currentShop)));
 
//on demande au serveur de nous envoyer la liste
				socket.send(packet);
 
//on se prepare a recevoir
				byte[] reponse = new byte[1024] ; 
				packet = new DatagramPacket(reponse,reponse.length);
				try
		        {
					socket.receive(packet); 
		            doc = sxb.build(new ByteArrayInputStream(packet.getData(),packet.getOffset(),(packet.getOffset()+packet.getLength())%1024));
		            racine = doc.getRootElement();
					Iterator<Element> commandes = racine.getChildren("commande").iterator();
 
					while (commandes.hasNext())
					{
						Element current = commandes.next();
						out.print("\t<p><input type='checkbox' name='commande' value='" + current.getChildText("id") +"' /> Commande " + current.getChildText("id") + " " + current.getChildText("date") + "</p>");
					}
					out.print("<p><input type='submit' value='Valider' /></p></form>");	
		        } catch(JDOMException e){
		        	    System.err.println("Erreur lors de la lecture de la reponse du serveur: " + e);
		        	    System.exit(-1);
		        	} catch (IOException e) {
		        		System.err.println("(Reception Client) Erreur lors de la reception du message-reponse : " + e);
		        	    System.exit(-1);
		        	   }
		}

Merci d'avance pour votre aide.

14/12/2013, 14h44
joel.drigo

Salut,

Pour le receive(), tu as une notion de timeout par la méthode setSOTimeout().

Cela dit, pourquoi ne pas se connecter en parallèle sur chaque serveur (un thread par connexion) : comme ça, aucun des accès n'est "bloqué" par un autre... Les connexions à des serveurs absents ne fonctionnent pas et on les ignore, c'est tout. Globalement le temps de réception de tes données sera le max des temps de réception de chaque connexion, au lieu d'être le cumul...
14/12/2013, 18h01
R00t_infinity

J'ai en effet essayé avec des threads cependant les out.print se mélangent, je n'ai par exemple aucun resultat dans la premiere table et des resultats dans la deuxieme table qui devraient etre dans la premiere...

Quelle partie de mon code mettriez-vous dans le run du thread ?

Salut,

Si ce sont des logs que tu traces, ils devraient être unitaire et, donc, ça ne pose pas vraiment de problème qu'ils soient mélangés (Si ces logs sont bien formattés, on aura le nom du thread, le date et heure, la classe, la méthode et la ligne de log, etc..., tout ce qu'il faut pour s'y retrouver).
S'il s'agit de rapport résultat, il suffit de construire ce résultat dans le thread, et de le tracer unitairement lors qu'il est complet, ou de le sortir dans un fichier à part, ou de l'afficher dans la GUI, ou autre. Si tu as besoin de collecter des résultats de plusieurs connexions pour faire un résultat unique, collectes les dans une classe dédiée, avec une liste de rapport, et un CountDownLatch pour déterminer que tous les résultats sont produits, pour produire le rapport cumulé.

Je mettrais l'ensemble du contenu du bloc while dans un thread à part (fais toi une classe "boite noire", qui prend en entrée les paramètres et donne en sortie un résultat.

Là ou tu as :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 pour tous les serveurs { préparer paramètres de connexion essayer { se connecter attendre le résultat avec un timeout si timeout atteint loguer serveur ne répond pas sinon afficher le résultat fin si } en cas d'erreur { loguer erreur } }
Tu auras :
Code:

1 2 3 4 5 6 7 pour tous les serveurs { préparer paramètres de connexion lancer thread avec ces paramètres } éventuellement attendre que tous les résultats sont prêts (CountDownLatch)
et le thread :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 essayer { se connecter attendre le résultat avec un timeout si timeout atteint loguer serveur ne répond pas sinon afficher le résultat fin si } en cas d'erreur { loguer erreur } éventuellement décrémenter le countdownlatch
Quand je parle de thread, ça peut être un service d'exécution (ExecutorService), qui te permettra éventuellement de gérer des pools, de contrôler le nombre de threads, etc.

17/12/2013, 12h49
R00t_infinity

Je m'en suis sortis, merci beaucoup.