threads en chat sur Python

threads en chat sur Python - Python - Programmation

Marsh Posté le 16-01-2010 à 16:34:56    

Bonjour,
Je vient de faire un programme de chat entre PC et SERVEUR sous Python.J'ai réalisé l'a-synchronisme via les Threads.
Mon problème est que je ne peut visualisée les donnée envoyées par le client au serveur qu'après faire une émission du serveur au client. Et si j'élimine par exemple le thread d'émission du serveur, alors là l'affichage du message reçu par le serveur est immédiat. Si quelqu'un pourrait me donner un coup de main, je lui serai reconnaissant.
Voilà ci joint mon programme:

Code :
  1. #####################CLIENT#####################
  3. host = "00:24:7E:D6:C5:9A"
  4. port = 3
  6. import socket, sys, threading, time
  7. from bluetooth import *
  9. class ThreadReception(threading.Thread):
  10.     def __init__(self, conn):
  11.         threading.Thread.__init__(self)
  12.         self.connexion = conn         
  13.        
  14.     def run(self):
  15.         while 1:
  16.             message_recu = self.connexion.recv(1024)
  17.             print "*" + message_recu + "*"
  18.             if message_recu.upper() == "FIN":
  19.                 break
  20.             time.sleep(0.001)
  21.    
  22. class ThreadEmission(threading.Thread):
  23.     def __init__(self, conn):
  24.         threading.Thread.__init__(self)
  25.         self.connexion = conn         
  26.        
  27.     def run(self):
  28.         while 1:
  29.             message_emis = raw_input()
  30.             self.connexion.send(message_emis)
  31.             time.sleep(0.001)
  33. # Programme principal - Établissement de la connexion :
  34. connexion = BluetoothSocket( RFCOMM )
  35. try:
  36.     connexion.connect((host, port))
  37. except socket.error:
  38.     print "La connexion a échoué."
  39.     sys.exit()   
  40. print "Connexion établie avec le serveur."
  41.            
  42. # Dialogue avec le serveur : on lance deux threads pour gérer
  43. # indépendamment l'émission et la réception des messages :
  44. th_E = ThreadEmission(connexion)
  45. th_R = ThreadReception(connexion)
  46. th_E.start()
  47. th_R.start()
  48. th_E.join()
  49. th_R.join()
  50. connexion.close()
  51. ###############SERVEUR####################
  53. from bluetooth import *
  54. import socket, sys, threading,time
  56. port = 3
  58. class ThreadReception(threading.Thread):
  59.     def __init__(self, conn):
  60.         threading.Thread.__init__(self)
  61.         self.connexion = conn         
  62.        
  63.     def run(self):
  64.         while 1:
  65.             try:
  66.                 message_recu = self.connexion.recv(1024)
  67.                 print "*" + message_recu + "*"
  68.                 if message_recu.upper() == "FIN":
  69.                     break
  70.             except:pass   
  71.             time.sleep(0.001)
  73.    
  74. class ThreadEmission(threading.Thread):
  75.     def __init__(self, conn):
  76.         threading.Thread.__init__(self)
  77.         self.connexion = conn         
  78.        
  79.     def run(self):
  80.         while 1:
  81.             message_emis = raw_input()
  82.             try:
  83.                 self.connexion.send(message_emis)
  84.                 if message_emis.upper() == "FIN":
  85.                     break
  86.             except:pass   
  87.             time.sleep(0.001)
  88.            
  89. # Programme principal - Établissement de la connexion :
  91. server_sock = BluetoothSocket( RFCOMM )
  92. server_sock . bind(( "", 3))
  93. server_sock . listen(2)
  95. connexion , client_info = server_sock . accept( )
  96. print "Accepted connection from " , client_info
  97.            
  98. # Dialogue avec le client : on lance deux threads pour gérer
  99. # indépendamment l'émission et la réception des messages :
  101. th_R = ThreadReception(connexion)
  102. th_E = ThreadEmission(connexion)
  103. th_E.start()
  104. th_R.start()
  105. th_R.join()
  106. th_E.join()
  108. connexion.close()
  109. server_sock.close()
  110. <code>

Reply

Marsh Posté le 16-01-2010 à 16:34:56   

Reply

Marsh Posté le 16-01-2010 à 22:21:26    

la question est: pourquoi un thread d'emission dans le serveur ??
le serveur doit juste ecouter sur le port et répondre au demandes...


---------------
Nos estans firs di nosse pitite patreye...
Reply

Marsh Posté le 16-01-2010 à 22:38:01    

Je sais que c'est pas le cas ordinaire. Mais j'aimerais bien faire la chose comme Ça avec plus d'interactivité entre Client/serveur.
Est-ce impossible?


Message édité par mcherkao88 le 16-01-2010 à 22:39:46
Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed