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 socket, sys, threading, socketbinance
server_ip = "192.168.0.200"
server_port = 8090
#TODO paramétrer le timeout du serveur durant coupure
status = socketbinance.Socket_order_status()
status.start_socket()
class ThreadClient(threading.Thread):
# class pour géré le thread des connexions client
def __init__(self, conn):
threading.Thread.__init__(self)
self.connexion= conn
def run(self):
#dialogue avec le client
nom = self.getName() #chaque thread possède un nom
#connexion au serveur binance pour récupérer les ordre
while 1:
msgclient = self.connexion.recv(1024).decode("Utf8")
if not msgclient or msgclient.upper() =="FIN":
break
message = "%s > %s" % (nom, msgclient)
print(message)
filter = msgclient.split()
#plus utilisé en attente pour l'instant
#TODO peut être à supprimer si plus utile
if filter[0] == "getbinanceid":
print("rentre dans la condition test binancid")
self.connexion.send(str(status.get_status_binance_id(binanceid=filter[1])).encode("Utf8"))#NEW CANCELLED FILLED
if filter[0] =="getorderid":
print("rentre dans la condition test orderid")
self.connexion.send(str(status.get_status_order_id(orderid=filter[1])).encode("Utf8")) # NEW CANCELLED FILLED
# if filter[0] != "getbinanceid" and filter[0] !="getorderid":
# self.connexion.send('None'.encode("Utf8"))
#ACTIVE SUPPRESIONN SI ORDRE EN FILLED OU CANCELLED
#TODO avoir pour supprimer les ordre qui reste en filled après annulation
# if status.is_cancel_filled(orderid=msgclient) is True:
# print("suppresion de l'ordre :")
# status.del_status_order_id(orderid=msgclient)
#Fermeture de la connexion:
self.connexion.close() # copure la connexion cote serveur
del conn_client[nom] #supprmier son entrée dans le dictionnaire
print("Client %s déconnecté." % nom)
# initialisation du serveur - Mise en place du socket:
mysocket= socket.socket(socket.AF_INET,socket.SOCK_STREAM)
try:
mysocket.bind((server_ip, server_port))
except socket.error:
print("La liaison du socket à l'adresse choisi a echoué")
sys.exit()
print("Serveur pret, en attente de requetes ...")
mysocket.listen(3)
# Attente et prise en charge des connexions demandées par les clients:
# dictionnaire des conneions clients
conn_client={}
while 1:
connexion, adresse= mysocket.accept()
#créer un nouvel objet thread pour gérer la connexion:
th = ThreadClient(connexion)
th.start()
#mémoriser la connexion dans le dictionnaire:
it = th.getName() #identifiant du thread
conn_client[it]=connexion
print("client %s connecté, adressse IP %s, port %s" %\
(it, adresse[0], adresse[1]))
#dialogue avec le client:
msg= "Vous êtes connecté. Envoyé vos messages."
connexion.send(msg.encode("Utf8")) |
variable persistante entre plusieurs programmes différentes
Répondre avec citation
Envoyé par tintin3158
)
Partager