-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathserver.py
40 lines (34 loc) · 1.05 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
import socket
import threading
import queue
messages=queue.Queue()
clients=[]
server=socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
server.bind(("localhost", 9999))
def recieve():
while True:
try:
message, addr=server.recvfrom(1024)
messages.put((message,addr))
except:
pass
def broadcast():
while True:
while not messages.empty():
message,addr=messages.get()
print(message.decode())
if addr not in clients:
clients.append(addr)
for client in clients:
try:
if message.decode().startswith("SIGNUP_TAG:"):
name=message.decode()[message.decode().index(".")+1:]
server.sendto(f"{name} joined!".encode(), client)
else:
server.sendto(message,client)
except:
clients.remove(client)
t1=threading.Thread(target=recieve)
t2=threading.Thread(target=broadcast)
t1.start()
t2.start()