-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathsockets-server-threads.py
More file actions
60 lines (38 loc) · 1.32 KB
/
sockets-server-threads.py
File metadata and controls
60 lines (38 loc) · 1.32 KB
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
#Biblioteca sockets
import socket
from threading import Thread
import time
#Porta do servidor
port = 8084
class ThreadServer(Thread):
def __init__ (self, addr, conn):
Thread.__init__(self)
self.addr = addr
self.conn = conn
def run(self):
#Mensagem que o servidor envia
msg = 'Eu sou o SERVIDOR. Thread atendendo {}'.format(self.addr)
print("Thread servindo cliente ", self.addr)
print('Dados da conexão: ', self.conn)
#Recebe os dados
data = self.conn.recv(4096)
#Trata os dados recebidos
from_client = data
print(from_client.decode())
#Envia uma mensagem
self.conn.send(msg.encode())
# time.sleep(3) #Aguarda antes de fechar a conexão
#Fecha a conexao
self.conn.close()
print('client disconnected')
#Objeto socket
serv = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#Associa o socket a uma porta local
serv.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) #Possibilita reusar portas
serv.bind(('0.0.0.0',port))
serv.listen()
#Servidor fica aguardando conexões.
#Quando receber uma conexão, repassa para um thread processar a conexão
while True:
conn, addr = serv.accept()
ThreadServer(addr,conn).start()