Discussion :

[bomberwaterman]

bonjour a tous,
Je suis en train de galerer a creer une appli client/serveur (un classique me direz vous. sauf que la je dois integrer une interface graphique avec tkinter.

Mon probleme c'est que le mainloop de tkinter me bloque la reception des messages. En effet j'ai un thread de reception comme ceci

Code :

S�lectionner tout - Visualiser dans une fen�tre � part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
class reception_c(th.Thread):
    def __init__(self,conn):
        th.Thread.__init__(self)
        self.connexion = conn
        condition = th.Condition()

        while 1:
                message = self.connexion.recv(255)
                print message

                if not message:
                    pass
                    print "detection de deconnection du serveur\n"
                    break

et cest donc la ligne avec le recv qui me bloque car lui me bloque l'ensemble du programme.

quand je met

Code :

S�lectionner tout - Visualiser dans une fen�tre � part

1
2
thread_ecoute=reception_c(self.connexion)
        fenetre.mainloop()

c'est l'interface graphique qui ne demarre pas et quand j'inverse, l'interface graphique demarremais pas l'ecoute, je n'y comprend rien.

J'ai recherch� du cot� de la socket blockante ou bien du cote des files d'attente de thread mais je n'arrive pas a les mettre en place.

voilou, si quelqu'un voit pourquoi �� bloque

merci d'avance

[eyquem]

Je suis incapable de r�pondre mais ce message pour te signaler que tu n'es pas le premier � �tre victime de recv qui semble poser un probl�me particulier:

http://www.developpez.net/forums/d62...urllib-socket/

http://www.developpez.net/forums/d63...rllib-urlopen/

Je n'ai pas eu assez de courage jusqu'� pr�sent pour m'attaquer � ce probl�me pour le comprendre avec mes faibles connaissances de base.

[bomberwaterman]

merci pour ta r�ponse, il semble en effet que recv pose des probl�me. Cependant mon probleme est li� surtout a tkinter donc j'oriente surtout mes recherches vers ce module.

a+

[DelphiManiac]

Etant curieux de nature et n'ayant pas la r�ponse, je me suis pench� sur la question et il ne me semble pas y avoir de probl�me, a moins que je n'ai pas bien compris la question.

Le serveur de test :

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
#-*- coding: utf-8 -*- 
 
# Définition d'un serveur réseau gérant un système de CHAT simplifié.
# Utilise les threads pour gérer les connexions clientes en parallèle.
 
HOST = 'localhost'
PORT = 40000
 
import socket, sys, threading
 
class ThreadClient(threading.Thread):
    '''dérivation d'un objet thread pour gérer la connexion avec un client'''
    def __init__(self, conn):
        threading.Thread.__init__(self)
        self.connexion = conn
 
    def run(self):
        # Dialogue avec le client :
        nom = self.getName()        # Chaque thread possède un nom
        while 1:
            msgClient = self.connexion.recv(1024)
            if msgClient.upper() == "FIN" or msgClient =="":
                break
            message = "%s> %s" % (nom, msgClient)
            print message
            # Faire suivre le message à tous les autres clients :
            for cle in conn_client:
#                if cle != nom:      # ne pas le renvoyer à l'émetteur
                conn_client[cle].send(message)
 
        # Fermeture de la connexion :
        self.connexion.close()      # couper la connexion côté serveur
        del conn_client[nom]        # supprimer son entrée dans le dictionnaire
        print u"Client %s déconnecté." % nom
        # Le thread se termine ici    
 
# Initialisation du serveur - Mise en place du socket :
mySocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
try:
    mySocket.bind((HOST, PORT))
except socket.error:
    print u"La liaison du socket à l'adresse choisie a échoué."
    sys.exit()
print u"Serveur prêt, en attente de requêtes ..."
mySocket.listen(5)
 
# Attente et prise en charge des connexions demandées par les clients :
conn_client = {}                # dictionnaire des connexions clients
while 1:    
    connexion, adresse = mySocket.accept()
    # Créer un nouvel objet thread pour gérer la connexion :
    th = ThreadClient(connexion)
    th.start()
    # Mémoriser la connexion dans le dictionnaire : 
    it = th.getName()        # identifiant du thread
    conn_client[it] = connexion
    print u"Client %s connecté, adresse IP %s, port %s." %\
           (it, adresse[0], adresse[1])
    # Dialogue avec le client :
    connexion.send("Vous êtes connecté. Envoyez vos messages.")

Le client de test :

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
#!/bin/python
 
import socket;
import sys;
import Tkinter;
 
#-*- coding: utf-8 -*- 
 
# Définition d'un client réseau gérant en parallèle l'émission
# et la réception des messages (utilisation de 2 THREADS).
 
host = 'localhost'
port = 40000
 
import socket, sys, threading
 
class ThreadReception(threading.Thread):
    """objet thread gérant la réception des messages"""
    def __init__(self, conn):
        threading.Thread.__init__(self)
        self.connexion = conn           # réf. du socket de connexion
 
    def run(self):
        while 1:
            message_recu = self.connexion.recv(1024)
            print "*" + message_recu + "*"
            if message_recu =='' or message_recu.upper() == "FIN":
                break
        # Le thread <réception> se termine ici.
        # On force la fermeture du thread <émission> :
        print u"Client arrêté. Connexion interrompue."
        self.connexion.close()
 
class fenetre(threading.Thread):
    def run(self):
        Tkinter.Label(text = "Welcome!").pack();
        Tkinter.Button(text = "Send coucou", command = self.send_many).pack();
        Tkinter.Button(text = "Se déconnecter", command = self.send_FIN).pack();
        Tkinter.mainloop();
 
    def send_many(self):
        many = send_coucou(connexion)
        many.start()
 
    def send_FIN(self):
        connexion.send('FIN')
 
class send_coucou(threading.Thread):
    def __init__(self, connexion):
        threading.Thread.__init__(self)
        self.connexion = connexion
 
    def run(self):
        for i in xrange(1, 10000):
            self.connexion.send('coucou %s\r\n' % i)
 
# Programme principal - Établissement de la connexion :
connexion = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
try:
    connexion.connect((host, port))
except socket.error:
    print u"La connexion a échoué."
    sys.exit()    
print u"Connexion établie avec le serveur."
Connected = False;
 
# Dialogue avec le serveur : on lance deux threads pour gérer
# indépendamment l'émission et la réception des messages :
th_R = ThreadReception(connexion)
th_R.start()
fen = fenetre()
fen.start()

Le serveur ne fais que faire un echo de ce qu'il re�oit. Apr�s avoir lanc� le server et le client, je peut cliquer l'envois de coucou les messages passent bien entre les 2 sans qu'aucun des 2 ne soit bloqu�.

D�sol�, c'est du copier/coller � l'arrache de diff�rents exemples, s�rement pas tr�s propre. Merci � http://fr.wikibooks.org/wiki/Apprend...un_r%C3%A9seau pour la source du copier/coller

[bomberwaterman]

hallucinant, cela faisait plus d'une semaine que j'essayai pleins de possibilit�s sans trouver de solutions concluantes...

Merci beaucoup DelphiManiac, pour cette r�ponse pertinente, le pire c'est que tes 2 morceaux de codes ne sont pas tr�s diff�rents de ce que j'avais refait, il va falloir que j'y regarde de plus pr�s.

En tout cas c'est exactement ce qu'il me fallait.

merci beaucoup, bonne soir�e

[bomberwaterman]

tant que j'y suis, en regardant le programme je vois que les variables d'un m�me module sont accessibles dans n'importe quelle classe. Je me trompe?

a+ bonne soir�e

[DelphiManiac]

Oui, les variables ont diff�rentes port�es comme dans la plupart des langages. Regarde la documentation, tu trouveras tout les �l�ments.