lessons period 2

period_2/01-sockets/804/client.py

@@ -0,0 +1,30 @@
+import socket
+
+HOST = socket.gethostbyname("localhost")
+PORT = 5053
+ADDR = (HOST, PORT)
+HEADER = 64
+FORMAT = "utf-8"
+
+server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+server.connect(ADDR)
+
+def send(message):
+    message = message.encode(FORMAT)
+    msg_length = len(message)
+    send_length = str(msg_length).encode(FORMAT)
+    send_length += b' ' * (HEADER - len(send_length))
+    server.send(send_length)
+    server.send(message)
+    print(server.recv(2048).decode(FORMAT))
+
+def handleSend():
+    connected = True
+    while connected:
+        message = input("Please enter a message: ")
+        if message == "!DISCONNECT":
+            connected = False
+        else:
+            send(message)
+
+handleSend()

period_2/01-sockets/804/server.py

@@ -0,0 +1,44 @@
+import socket
+import threading
+
+HOST = socket.gethostbyname("localhost")
+PORT = 5053
+ADDR = (HOST, PORT)
+HEADER = 64
+FORMAT = "utf-8"
+
+server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+server.bind(ADDR)
+
+def handleClient(conn, addr):
+    client_name = conn.recv(HEADER).decode(FORMAT)
+    print(f"[NEW CONNECTION] {client_name} connected.")
+    connected = True
+    while connected:
+        msg_length = conn.recv(HEADER).decode(FORMAT)
+        if msg_length:
+            msg_length = int(len(msg_length))
+            msg = conn.recv(msg_length).decode(FORMAT)
+            if msg == "!DISCONNECT":
+                connected = False
+            print(f"[{client_name}] {msg}")
+            conn.send("Msg received".encode(FORMAT))
+
+    conn.send("Bye bye".encode(FORMAT))
+    conn.close()
+    print(f"[DISCONNECTED] {client_name} disconnected.")
+    print(f"[ACTIVE CONNECTIONS] {threading.activeCount() - 2}]")
+
+
+
+def start():
+    server.listen()
+    print(f"[LISTENING] Server is listening on {HOST}")
+    while True:
+        conn, addr = server.accept()
+        thread = threading.Thread(target=handleClient, args=(conn, addr))
+        thread.start()
+        print(f"[ACTIVE CONNECTIONS] {threading.activeCount() - 1}")
+
+print("[STARTING] server is starting...")
+start()