Discussion :

[Loenix]

Bonjour à tous,

Mon probleme est relativement simple mais j'ignore totalement quelle méthode adopter pour le contourner.

J'ai désire faire un petit jeu online, pour cela j'ai deux client et un serveur. Les deux client se connecte au serveur et chaque donnée envoyé par les clients sont renvoyées vers tous les clients connectés au serveur (le serveur ne fait que récupèrer les requettes et les renvoies aux autres clients).

Mon probleme,
En loopback (tout sur la meme machine) aucun probleme toutes les requettes sont envoyés et récupérés, mais lorsque je commence a mettre en place ce systeme sur un réseau, il arrive sans arret que les requettes soit groupés.

En gros, les clients envoient des requettes successives : 1, 2, 3
Les données ne transite pas à la meme vitesse et du coup en faisant un connexion.recev, j'obtient :123, ou 12, 1

Ce que je souhaiterai faire, c'est bien entendu pour chaque envoie de requette une seule reception et non fusionné mais requettes :s

J'espere avoir été compris mais dans le ca sonctraire, n'hesitez pas à me le faire savoir

Merci d'avance à tous...

Mickael

[josmiley]

détailles un peu stp ...

[PauseKawa]

Bonjour,

Il suffit de donner la taille des requêtes, Comprendre connexion.recev(taille).

Si la taille n'est pas connue d'avance pourquoi ne pas passer par un marquer (Copier/coller rapide)

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
        self.EndMarker='*End*'
....
    def recvall(self):
        reponse=[]
        rcvdata=''
        while True:
            rcvdata=self.connect.recv(20)
            if self.EndMarker in rcvdata:
                reponse.append(rcvdata[:rcvdata.find(self.EndMarker)])
                break
            reponse.append(rcvdata)
            if len(reponse) > 1:
                veriflist = reponse[-2] + reponse[-1]
                if self.EndMarker in veriflist:
                    reponse[-2] = veriflist[:veriflist.find(self.EndMarker)]
                    reponse.pop()
                    break
        return ''.join(reponse)

Mais le principal c'est de bien différencier les clients (re ctrl c)

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
73
74
75
76
77
78
79
80
81
82
83
84
import threading
import socket
from string import split
 
dictclients = {}
 
class Client(threading.Thread):
    def __init__(self, socketclient):
        threading.Thread.__init__(self)
        self.clisock = socketclient
        self.EndMarker='*End*'
 
    def newConnect(self):
        NewClient = self.clisock.recv(500)
        if NewClient in dictclients.keys():
            self.clisock.send('Nok')
        else:
            self.clisock.send('Ok')
            NewType = self.clisock.recv(1)
            self.clisock.send('Ok')
            NewPass = self.clisock.recv(500)
            self.cliname = NewClient.strip()
            self.clipass = NewPass.strip()
            self.clitype = NewType.strip()
            dictclients[self.cliname] = (self.clipass, self.clitype, self.clisock, self)
            self._stopevent = threading.Event()
 
    def returnclilist(self):
        _deadclients = []
        for keys, values in dictclients.iteritems():
            print keys, values
            if values[2] != self.clisock:
                try:
                    values[2].send('test')
                except socket.error, e:
                    _deadclients.append(keys)
        for clients in _deadclients:
            dictclients[clients][3].stop()
            del dictclients[clients]
        retstr = ''
        for elems in dictclients.keys():
            if len(elems) < 11:
                elem = elems + (' ' * (11 - len(elems)))
            retstr = retstr + elem + dictclients[elems][1]
        self.clisock.send(retstr)
        print dictclients
 
    def run(self):
        self.newConnect()
        while not self._stopevent.isSet():
            try:
                buff = self.clisock.recv(20)
            except:
                buff = ''
            if 'ListeClient' in buff:
                self.returnclilist()
            self._stopevent.wait(2.0)
        self.clisock.close()
# Le try pour :
#Traceback (most recent call last):
#  File "/usr/lib/python2.6/threading.py", line 532, in __bootstrap_inner
#    self.run()
#  File "alivesvr.py", line 56, in run
#    buff = self.clisock.recv(20)
#  File "/usr/lib/python2.6/socket.py", line 167, in _dummy
#    raise error(EBADF, 'Bad file descriptor')
#error: [Errno 9] Bad file descriptor
# A gerer plus tard
 
    def stop(self):
        self._stopevent.set()
 
if __name__ == "__main__":
    svrsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    svrsocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    try:
        svrsocket.bind(('',8000))
    except ValueError, e:
        print e
    svrsocket.listen(5)
    while True:
        (socketclient, addr) = svrsocket.accept()
        ct = Client(socketclient)
        ct.start()

@+

[Loenix]

Bonjour,

Merci pour votre reponse, en effet, j'ai finis par adopter une borne a la fin de ma requette, et depuis, tout fonctionne bien.

Merci beaucoup

Résolu

Mickael