-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathserver.py
56 lines (46 loc) · 1.69 KB
/
server.py
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
import socket
import threading
import sys as sys
# Server IP and port
IP = "127.0.0.1"
PORT = 55555
# Socket type and options
server_socket = socket.socket(family=socket.AF_INET, type=socket.SOCK_STREAM)
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
server_socket.bind((IP, PORT))
server_socket.listen()
# dictionary of client sockets and their nicknames
clients = {}
#debuggin
print(f'Listening for connections on {IP}:{PORT}...')
# Sending Messages To All Connected Clients
def broadcast(message, client_socket):
# Send messages to all clients except to the original sender
for client in clients.keys():
if client is not client_socket:
client.send(message.encode('utf-8'))
# Function to be called per client
def handle(client_socket):
while True:
message = client_socket.recv(1024).decode('utf-8')
broadcast(message, client_socket)
if "!exit" in message:
client_socket.close()
broadcast('{} left!'.format(clients[client_socket]), client_socket)
clients.pop(client_socket)
sys.exit()
# Receiving / Listening Function
def receive():
while True:
# Accept Connection
client_socket, address = server_socket.accept()
print("Connected with {}".format(str(address)))
# Request And Store Nickname
client_socket.send('Nickname?'.encode('utf-8'))
nickname = client_socket.recv(1024).decode('utf-8')
# Add client info to the dictionary
clients.update({client_socket: nickname})
# Start Handling Thread For Client
thread = threading.Thread(target=handle, args=(client_socket,))
thread.start()
receive()