PythonSocketScript/PythonSocketScript/server.py at main · Adebowale-Morakinyo/PythonSocketScript · GitHub

History

59 lines (44 loc) · 1.45 KB

Raw

import socket

import threading

HEADER = 64

PORT = 5050

SERVER = socket.gethostbyname(socket.gethostname())

ADDR = (SERVER, PORT)

FORMAT = 'utf-8'

DISCONNECT_MESSAGE = '!DISCONNECT'

server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

server.bind(ADDR)

clients = set()

clients_lock = threading.Lock()

def handle_client(conn, addr):

print(f'[NEW CONNECTION] {addr} connected.' + '\n')

try:

connected = True

while connected:

msg_length = conn.recv(HEADER)

if msg_length:

msg_length = int(msg_length)

msg = conn.recv(msg_length).decode(FORMAT)

if msg == DISCONNECT_MESSAGE:

connected = False

print(f'[{addr}] {msg}')

conn.send('Message received'.encode(FORMAT))

with clients_lock:

for c in clients:

c.sendall((f'[{addr}] {msg}' + '\n').encode(FORMAT))

finally:

with clients_lock:

clients.remove(conn)

conn.close()

def start():

server.listen()

print(f'[LISTENING] Server is listening on {SERVER}')

while True:

conn, addr = server.accept()

with clients_lock:

clients.add(conn)

thread = threading.Thread(target=handle_client, args=(conn, addr))

thread.start()

print(f'[ACTIVE CONNECTION] {threading.active_count() - 1}')

print('[STARTING] server is starting...')

start()

PythonSocketScript/PythonSocketScript/server.py at main · Adebowale-Morakinyo/PythonSocketScript · GitHub

Expand file tree

Breadcrumbs

server.py

Latest commit

History

Breadcrumbs

server.py

File metadata and controls