Relais TCP-IP PYTHON

Relais TCP-IP PYTHON - Python - Programmation

Marsh Posté le 09-07-2010 à 10:54:43    

Bonjour à tous.
Je suis nouveau dans Python, même si je connais bien Java ou le c#.
Je souhaite établir un relais TCP-IP entre des machines distantes, et un utilisateur (je me limite à un pour le moment)
 
Je vous explique mon petit soucis :
 
Petite particularité, les machines et l'utilisateur n'accepent pas les connexions entrantes. C'est donc eux qui doivent initier la connexion.
 
Paramètres obligatoires dans mon cas :  
 
- il peut y avoir une multitude de machines
- il y a un utilisateur
- les machines et l'utilisateur doivent pouvoir se connecter et se déconnecter quand bon leur semble. (en effet, mes "machines" seront à termes équipées d'un modem GPRS, donc la connexion continue sera utile :) )
- tout message provenant de l'utilisateur est envoyé à toutes les machines
- tout message provenant d'un modem est envoyé à l'utilisateur (avec identification de la machine en question, afin que l'on sache d'ou il provient)
 
Mon script de connexion côté machine est écrit et fonctionnel, il se connecte au serveur, et à partir de ce moment on peut en faire ce qu'on veut ( c'est en fin de compte un script de connexion modem GPRS qui est lié au serveur).
 
La ou j'ai un petit soucis, c'est au niveau du script serveur et script utilisateur.
En effet, l'utilisateur se connecte, mais je n'arrive pas à envoyer de mesages, ou à faire quoi que ce soit.
 
Je vous copie donc mes scripts :  
 
serveur :  

Code :
  1. import socket, sys, threading
  3. host = "192.168.0.29"
  4. portModem = 60000
  5. portUtil = 60005
  7. #Personnalisation de la classe thrading
  8. class ThreadMachine(threading.Thread) :
  9. def __init__(self, conn) :
  10.  threading.Thread.__init__(self)
  11.  self.connexion = conn
  13. def run(self) :
  14.  #dialogue
  15.  nom =self.getName()
  16.  while 1 :
  17.                        
  18.                         msgUtil = connexionUtil.recv(1024)
  19.   for cle in conn_machine :
  20.                             conn_machine[cle].send(msgUtil + "Nom :" + nom + "\n" )
  21.                             print msgUtil + "Nom :" + nom
  22.                             msgMachine = connexion.recv(1024)
  23.                             connexionUtil.send("Réponse Machine : " + msgMachine + "\n" )
  25.  self.connexion.close()
  26.  del conn_machine[nom]
  27.  print "Client %s déconnecté \n" % nom
  29. #création du socket
  30. socketMachine = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  31. socketUtil = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  32. #Liaison à une adresse spécifique
  33. try :
  34. socketMachine.bind((host, portModem))
  35. except socket.error, e:
  36. print "Impossible d'établir la liason Machine \n"
  37. print e
  38. sys.exit()
  39. print "serveur prêt \n"
  40. socketMachine.listen(5)
  42. #dico contenant tous les modems connectés
  43. conn_machine = {}
  46. try :
  47. socketUtil.bind((host, portUtil))
  48. except socket.error, e:
  49. print "Impossible d'établir la liason Utilisateur \n"
  50. print e
  51. sys.exit()
  52. socketUtil.listen(1)
  54. while 1 :
  55. connexion, adresse = socketMachine.accept()
  56.         connexionUtil, adresseUtil = socketUtil.accept()
  57. th=ThreadMachine(connexion)
  58. th.start()
  59. it=th.getName()
  60. conn_machine[it] = connexion
  61. print "Machine %s connecté, adresse IP %s, port %s \n" % (it, adresse[0], adresse[1])


 
et l'utilisateur :  

Code :
  1. import socket, sys, threading
  3. host = "192.168.0.29"
  4. portModem = 60000
  5. portClient = 60005
  7. #Personnalisation de la classe thrading
  8. class ThreadReception(threading.Thread) :
  9. #gère la reception des messages
  10. def __init__(self, conn) :
  11.  threading.Thread.__init__(self)
  12.  self.connexion = conn #référence du socket de connexion
  14. def run(self) :
  15.  while 1 :
  16.   msgRecu = self.connexion.recv(1024)
  17.   print "*" + msgRecu + "*\n"
  18.   if msgRecu == "" or msgRecu.upper() == "FIN" :
  19.    break
  20.   #Thread reception FIN
  21.   #Fermeture thread emission
  22.   threadEmis._Thread__stop()
  23.   print "Client arrété, connexion in terrompue \n"
  24.   self.connexion.close()
  27. class ThreadEmission(threading.Thread) :
  28. #gère l'envoi des messages
  29. def __init__(self, conn) :
  30.  threading.Thread.__init__(self)
  31.  self.connexion = conn #référence du socket de connexion
  33. def run(self) :
  34.  while 1 :
  35.   msgEmis = raw_input()
  36.   self.connexion.send(msgEmis)
  38. #programme
  39. connexion = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  40. try :
  41. connexion.connect((host, port))
  42. except socket.error :
  43. print "la connexion a échoué \n"
  44. sys.exit()
  45. print "connexion établie avec le serveur \n"
  47. #dialogue
  48. threadEmis = ThreadEmission(connexion)
  49. threadRep = ThreadReception(connexion)
  50. threadEmis.start()
  51. threadRep.start()


 
Voila ... j'espère avoir été clair !  
si vous pouviez me dire pourquoi ca me fonctionne pas, et me donner des solutions qui répondent à mes obligations ...  
d'avance merci !!

Reply

Marsh Posté le 09-07-2010 à 10:54:43   

Reply

Marsh Posté le 09-07-2010 à 15:54:46    

up ? :s

Reply

Marsh Posté le 15-07-2010 à 09:25:53    

up ? :S

Reply

Sujets relatifs:

Leave a Replay

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