[Socket] Comment casser un read bloquant ?

voici le problème et ma modélisation:
le programme est un proxy mais juste le coté serveur suffit pour illustrer le probleme.
En fait au lieu de simplement lancer un Thread pour chaque nouvelle connexion entrante, je passe par un InputConnectionManager qui contient un Vector avec tous les Threads (InputConnection).
j'utilise donc dans le serveur une methode de se Manager qui me retourne le Thread que je lance donc ensuite.
Lors de la fermeture du server (Ctrl-C), je veux fermer proprement toutes les connexions. j'ai donc mis un ShutdownHook dans le serveur.

Code:

---

1 2 3 4 5 6

Runtime.getRuntime().addShutdownHook(new Thread() { public void run() { close(); } });

---

Dans ce close, je force la fin de tout mes Threads (input connexion) un par un et j'attends leur fin (join).
Tout ça marche très bien à un détail près: mes Threads restent bloqués sur des read (socket). C'est le fonctionnement normal: le client est censé m'envoyer une commande ou bien fermer la socket mais je fais mes tests en telnet et cela est un peu soppo. De plus tant qu'un seul des clients ne m'a pas envoyé quelque chose, le serveur n'est pas fermé puisqu'il reste sur le join. Il n'y a pas un moyen de break les read bloquant afin de forcer la fermeture ?

(les threads sont une boucle infinie: réception commande/ envoi réponse qui ne se break que lorsque la cmd est QUIT, c'est pour ça que je me retrouve avec un read bloquant)

Merci d'avance pour l'aide ;)

PS: je viens de penser à un truc: est ce possible d'utiliser des signaux en java ? le serveur pourrait propager le Ctrl-C à tous les Threads. ça devrait killer les reads et avec un ShutdownHook je pourrai être propre. je verrai ça se soir, là je dois bouger.

Killer les threads (Thread.stop) , c'est possible, mais:
1. c'est mal
2. ca ne marchera pas dans ton cas (socket read)

Seule solution, fermer le socket (Socket.close)

je sais que killer un thread c'est mal mais je ne sais pas comment faire...
je tente de fermer la socket, mais ça ne marche pas :s
le Thread reste bloqué sur le read de la socket alors que via une autre classe (mon manager) j'appelle sa methode stopThread dans laquelle je ferme les buffer reader/writter et la socket.
j'ai mis des traces, et quoi qu'il arrive, la methode stopThread n'est exécutée qu'après le read débloqué :'(
une solution ?

En plaçant un timeout sur la socket çà ne pourrait pas faire l'affaire?


void connect(SocketAddress endpoint, int timeout)
Connects this socket to the server with a specified timeout value.

merci pour l'idée, mais cela ne règle pas mon problème.
En effet, j'utilise un BufferedReader,

Code:

---

in=new BufferedReader(new InputStreamReader(sock.getInputStream()));

---

et la Socket sock provient d'un accept d'une ServerSocket. Il ne me semble pas y avoir de timer configurable dessus :s

Je pense qu'il faudrait directement agir sur le Reader, mais je n'ai rien trouvé ni dans java.io.Reader ni dans java.io.BufferedReader.
Je ne pense pas que les signaux existent en Java mais il doit bien y avoir un moyen de communiquer avec un Thread !
Que pensez vous des exceptions ? le problème c'est que je ne pense pas que l'on puisse la dirigé vers un id spécifique si ?


Rq d'après la javadoc, le TimeOut ne semble de plus concerner que l'établissement de la connexion.

Code:

---

SocketTimeoutException - if timeout expires before connecting

---

Salut,

Je ne vois pas où est le problème.

Tu fais une méthode close() dans ton serveur qui ferme ainsi toutes les connexions + son socket d'écoute, et tu l'appel depuis le Thread principal (ici ton serveur doit être dans un Thread à part, ainsi que chaque connexion cliente).

P.S: java.nio c'est mieux.

P.S2: si tu utilises l'invite de commandes, tu dois faire SHIFT + ENTRER pour envoyer le message, et pas ENTRER uniquement sinon le readLine du BufferedReader ne se déclenche car il attend un \r\n (c'est ce qui délimite les lignes).

oki, c'est de ma faute :oops:
en vous faisant un code exemple illustrant mon pb, j'ai trouvé par hasard...
je faisais ça dans la methode pour fermer mes Threads handler de connection:

Code:

---

1 2 3 4 5 6 7 8 9 10

try{; in.close(); out.close(); sock.close() } catch(IOException e){ System.out.println("Error Closing socket..."); return; }

---

le in.close() attend la fin du read qui se trouve dans la boucle du run.
en mettant le sock.close en premier ça marche :p
sorry et merci encore ;)
++