begin process at 2012 05 24 05:16:49
  Trouver un code source :
 
dans
 
Accueil > 

Code

 > 

Réseau & internet

 > SOCKET MULTITHREAD SIMPLE

SOCKET MULTITHREAD SIMPLE


 Description

Voici la base pour créer des sockets multi-clients.
Je n'est pas trouvé de source qui proposé d’expliquer comment créer un script avec socket multi-thread tous simplement (la plus part sont des scripts bien complets qui ne permettent peut être pas au débutant comment le système fonctionne)

J'ai d'ailleurs mis du temps à comprendre et à décrypter les sources.

Source

  • import socket, threading
  • # [2] ~~ FONCTION EN BOUCLE ATTENTE DES CLIENTS
  • ################################################
  • def AttenteClient():
  • global Sck, conn, addr
  • i = 0
  • while 1:
  • conn.append(i)
  • addr.append(i)
  • conn[i], addr[i] = Sck.accept()
  • print " >> Nouvelle Connexion : " + addr[i][0]
  • conn[i].send("Hello Moto !\r\n")
  • # Appel d'un nouveau thread pour gerer ce client
  • th = threading.Thread(target=GestionConnexion, args=str(i))
  • th.start()
  • i = i + 1
  • # [3] ~~ GESTION DE LA CONNEXION DU CLIENT
  • #########################################################
  • def GestionConnexion(i):
  • global Sck, conn, addr
  • donnees = ''
  • while 1:
  • recu = conn[int(i)].recv(1024).decode("latin9")
  • if not recu: break
  • if recu[len(recu) - 1] != '\n': donnees = donnees + recu
  • elif donnees != "":
  • print " >> " + addr[int(i)][0] + " : " + donnees
  • # Envoi du message a tous le monde :
  • for a in range(len(conn) - 1):
  • conn[a].send(" >> " + addr[int(i)][0] + " : " + donnees + "\r\n")
  • donnees = ''
  • else:donnees = ''
  • # Fin de boucle, le thread s'arrete et le client et deco:
  • print " >> " + addr[int(i)][0] + " est deconnect."
  • # [1] ~~ CREATION DU SOCKET
  • #########################################################
  • Host = "127.0.0.1"
  • Port = 56
  • # Tableaux qui regrouperont les connexions :
  • conn = []
  • addr = []
  • # On cree le socket et on le met en ecoute, puis appel en boucle de la fonction
  • # qui acceptera les connexions en incrementant la liste
  • Sck = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  • Sck.bind((Host, Port))
  • Sck.listen(1)
  • AttenteClient()
import socket, threading

# [2] ~~ FONCTION EN BOUCLE ATTENTE DES CLIENTS
################################################
def AttenteClient():
    global Sck, conn, addr
    i = 0
    while 1:       
        conn.append(i)
        addr.append(i)
        conn[i], addr[i] = Sck.accept()

        print " >> Nouvelle Connexion : " + addr[i][0]
        conn[i].send("Hello Moto !\r\n")
        
        # Appel d'un nouveau thread pour gerer ce client
        th = threading.Thread(target=GestionConnexion, args=str(i))
        th.start()
        i = i + 1


# [3] ~~ GESTION DE LA CONNEXION DU CLIENT
#########################################################
def GestionConnexion(i):
    global Sck, conn, addr
    donnees = ''
    
    while 1:
        recu = conn[int(i)].recv(1024).decode("latin9")            
        if not recu: break

        if recu[len(recu) - 1] != '\n': donnees = donnees + recu
        elif donnees != "":
        
            print " >> " + addr[int(i)][0] + " : " + donnees
            # Envoi du message a tous le monde :
            for a in range(len(conn) - 1):
                conn[a].send(" >> " + addr[int(i)][0] + " : " + donnees + "\r\n")

            donnees = ''
        else:donnees = ''
                

    # Fin de boucle, le thread s'arrete et le client et deco:
    print " >> " + addr[int(i)][0] + "  est deconnect."




# [1] ~~ CREATION DU SOCKET
#########################################################
Host = "127.0.0.1"
Port = 56

# Tableaux qui regrouperont les connexions :
conn = []
addr = []

# On cree le socket et on le met en ecoute, puis appel en boucle de la fonction
# qui acceptera les connexions en incrementant la liste
Sck = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
Sck.bind((Host, Port))
Sck.listen(1)
AttenteClient()

 Conclusion

Voila, ici le système est un tchat mais à vous de gérer vos conditions pour vos données reçus :)


 Sources du même auteur

CALCULE LA FRÉQUENCE DU CPU
TRANSFERT DE FICHIER PAR SOCKET
PYSCANLOG SCANNER DE FICHIER LOG

 Sources de la même categorie

TRANSFERT DE FICHIER PAR SOCKET par Guillamue06
Source avec une capture AUTO-FOLLOW/UNFOLLOW [TWITTER] EN [PERL] UTILISANT NET::TWIT... par GeroXXXX
Source avec Zip PINGEUR RÉSEAU par jeanbleo44
Source avec Zip Source avec une capture LISTING ET LOGS DES CONNEXIONS ET DECONNEXIONS DE MACHINES Q... par saigneurdushi
Source avec Zip Source avec une capture REMOTE WINDOWS PROMPT par NqrK

 Sources en rapport avec celle ci

TRANSFERT DE FICHIER PAR SOCKET par Guillamue06
TK_WATCH :HORLOGE GRAPHIQUE par afranck64
TÉLCHARGEUR YOUTUBE par rezuz
Source avec Zip SOCKET : CLIENT ET SERVEUR SINGLE ET MULTI-THREAD par Ulala2
EXEMPLE DE THREAD par Shinji

Commentaires et avis

Commentaire de taz_iup le 21/10/2011 12:11:18

Sinon tu peux utiliser le module SocketServer
doc ici : http://docs.python.org/library/socketserver.html

 Ajouter un commentaire


Discussions en rapport avec ce code source dans le forum

Socket et Threading [ par dabcorp ] Bonjour , J'ai fait un client/serveur socket , mais je me comprend pas les threads ... Je suis obligé de faire une boucle pour relance le progra chat basique en python [ par rezuz ] bonjour, je suis en train d'essayer de programmer un chat en python, principalement dans le but d'apprendre l'utilisation des sockets et de la commun urllib2 et interface graphique [ par rezuz ] bonjour à tous. aprés avoir eu de nombreux "problemme" avec les 72 minutes de limitation vidéo de MEGAVIDEO, j'ai décidé de faire un programme qui se fenêtre avec client /serveur avec socket. [ par francoisjack ] Bonjour a tous j'ai un problème avec mon pt programme je veux faire une connexion entre deux fenêtres client et serveur avec une connexion via socket Scanner de port [ par iAure5974 ] Salut tout le monde il y a peu de temps j'ai codé un petit scanner de port en python (2.7.2) qui fonctionne plutôt bien mais je le trouve lent (normal 2 socket au meme temps? [ par stoner2008 ] Bonjour, est il possible de trouver sur un meme object deux sockets differente(une TCP et l'autre en UDP) en effet la socket udp sert à communiquer a suspend/load thread [ par stoner2008 ] bonjour, j'ai un thread qui execute plusieurs instructions.j'aimerais bien faire une pause et reprendre mon thread de là ou je me suis arrêté.pour ce Client Serveur Netstat [ par power211 ] Bonjour à tous, je suis un ptit nouveau ds le monde du python, projet d ecole oblige mais c vrai que  le python c rapide comme langage.Bon t Socket+timeout [ par power211 ] Re Bonjour tout lemonde,bon voila j aurai une ptite question sur les sockets plus les timeout.Donc je vais directement aller au but avec un exemple co reseau local, serveur/client [ par xilure ] Bonjour,j'ai fait un petit scripte, que me permet soit d'etre un serveur ou un clien, et d'envoyer des message (chat en reseau) Mais voila, quand je s


Nos sponsors


Sondage...

Comparez les prix

CalendriCode

Mai 2012
LMMJVSD
 123456
78910111213
14151617181920
21222324252627
28293031   

Consulter la suite du CalendriCode

A découvrir



 
Développement réalisé par Nicolas SOREL (Nix) avec l'aide de : Cyril DURAND et Emmanuel (EBArtSoft), Merci à Vincent pour ses précieux conseils.
CodeS-SourceS.com© Toute reproduction même partielle est interdite sauf accord écrit du Webmaster
CodeS-SourceS.com© est une marque déposée tous droits réservés

Google Coop CodeS-SourceS Google Coop CodeS-SourceS
Temps d'éxécution de la page : 0,796 sec (3)

Nous contacter | Annoncer sur CodeS-SourceS | Mentions légales