Geneste weergave | Lineaire weergave

Elco · 30-04-2006 23:35:39

Omdat het net even makkelijker leest in het Nederlands heb ik even snel deze beginner-tutorial samengesteld voor het gebruik van (single-threaded server en TCP only) sockets in Python

TCP-ECHOCLIENT IN PYTHON

Het gebruik van sockets in Python wordt ondersteunt via de socket module. Een typisch voorbeeld bij socket-tutorials is het maken van een echo-server. In dit artikel zullen we zo een dergelijke client-server toepassing bouwen. (We maken hier gebruik van TCP-sockets, indien er genoeg interesse is voor UDP-sockets kan ik daar ook een artikel over schrijven

)

Server-gedeelte:
Zoals reeds vermeld moet gebruik gemaakt worden van de socket module van Python, deze kan geimporteerd worden met volgende code:

Code:

from socket import *

Om een socket aan te maken moeten we 2 zaken opgegeven: de host en het poortnummer. Om kort te zijn kan op deze manier een proces worden geidentificeerd dat op een bepaalde host loopt. Deze 2 zullen we als een tuple voorstellen genaamd locatie (bevat respectievelijk host- en poortnr-informatie):

Code:

locatie=('localhost',12345)

We hebben nu dus de benodigde module opgegeven, en we hebben informatie over de locatie, nu moet dus nog de socket zelf aangemaakt worden. Dit gebeurt als volgt:

Code:

serversock = socket(AF_INET, SOCK_STREAM)

Hierin geeft SOCK_STREAM aan dat het TCP-sockets betreft, en AF_INET dat het voor internet protocol (IP) bedoeld is. (We maken dus TCP-IP gerichte sockets)

We hebben nu een socket aangemaakt, maar deze is nog 'maagdelijk', het is enkel een object, maar het doet nog niets. Voor een serversocket te bekomen moeten we het binden aan een het opgegeven adres, en dan geven we de socket informatie over de aanvragen op de locatie die we hem doorgaven:

Code:

serversock.bind(locatie)

serversock.listen(2)

Bij listen kunnen we een parameter opgeven (>=1) die aangeeft hoeveel clients zullen kunnen verbonden worden (deze worden in een wachtrij geplaatst indien de server al een client bedient) Indien de wachtrij vol is worden bijkomende verbindingen geweigerd. (Om ipv sequentiele toegangen toe te staan kan ook gebruik gemaakt worden van een threaded server, indien ook hier vraag naar is, schrijf ik daar ook een deel over

)

Nu kunnen we de 'functionaliteit' van de server gaan implementeren. Voor de eenvoud zorgen we dat de server oneindig blijft functioneren, dus met een oneindige lus (while 1)

PHP-code:

while 1:
   print 'Wachtend op verbinding'
   clientsock, adres = serversock.accept()
   print 'Connectie van: ', adres


serversock.close() 

Door accept() op te roepen zal het serverprogramma wachten tot er een verbinding wordt gemaakt met onze ingestelde socket. Dan pas gaat hij verder met de uitvoering van de volgende print. Accept() geeft dan een socket-object terug dat een voorstelling is van de socket van de client (clientsock). We kunnen dit gaan gebruiken om de data uit te lezen of te schrijven. Verdere info over de locatie van de client krijgen we in variabele adres. De verbinding wordt gesloten met serversock.close()

Nu kan dus verbinding gemaakt worden met de server, maar deze doet nog niets zinnigs: een echo-server zal info inlezen en diezelfde info opnieuw versturen. Dit doen we opnieuw in een lusje:

PHP-code:

while 1:
        data = clientsock.recv(1024)
        if data:
            clientsock.send('echo:' + data)
        else:
            break
    clientsock.close() 

Als we dit nu allemaal samenvoegen krijgen we het volgende programma:

PHP-code:

from socket import *

locatie=('localhost',12345)
serversock = socket(AF_INET, SOCK_STREAM)

serversock.bind(locatie)
serversock.listen(2)

while 1:
    print 'Wachtend op verbinding'
    clientsock, adres = serversock.accept()
    print 'Connectie van: ', adres

    while 1:
        data = clientsock.recv(1024)
        if data:
            clientsock.send('echo:' + data)
        else:
            break
    clientsock.close()

serversock.close() 

Met behulp van de recv(1024) lezen we een buffer van 1024 bytes in vanuit de socket, zolang die niet null is sturen we de string bestaande uit deze buffer en 'echo:' ervoor terug naar de client via send() van de socket.

Client-gedeelte:
Het maken van de client-socket verloopt vrij gelijkaardig. Maar hier moeten we gebruik maken van de connect methode van de socket, en opgeven met welke locatie we verbinding willen maken:

Code:

from socket import *

locatie = ('localhost', 12345)

clientsock = socket(AF_INET, SOCK_STREAM)

clientsock.connect(locatie)

Nu zullen we ter illustratie een string opsturen en kijken wat we terugkrijgen van de server (hopelijk hetzelfde als wat we opgestuurd hebben, met 'echo:' ervoor)

:

Code:

data = 'TESTING SERVER'

clientsock.send(data)

data = clientsock.recv(1024)

print data

clientsock.close()

Het totale client programma ziet er dan als volgt uit:

PHP-code:

from socket import *

locatie = ('localhost', 12345)
clientsock = socket(AF_INET, SOCK_STREAM)
clientsock.connect(locatie)

data = 'TESTING SERVER'
clientsock.send(data)

data = clientsock.recv(1024)
print data

clientsock.close() 

Bij eventuele fouten (typ-fouten zijn snel gemaakt, maar de 'volledige code blokken' zijn rechtstreeks gekopieerd uit werkende codebestanden dus die werken zeker), vragen of opmerkingen laat gerust iets weten

Grtz,
Elco

EDIT:
even de code bestanden voor server en client bijgevoegd in zip als bijlage (al bedankt voor de goede respons

)