Update Python Ofensivo - Más ejercicios con conexiones socket

python-ofensivo/07_conexiones_red_protocolos/04_socket/server.py

@@ -0,0 +1,58 @@
+#!/usr/bin/env python3
+
+import socket
+import threading
+import pdb
+
+
+class ClientThread(threading.Thread):
+
+    def __init__(self, conn, addr):
+        super().__init__()
+        self.conn = conn
+        self.addr = addr
+
+        print(f"\nConexión establecida desde {self.addr}")
+
+    def run(self):
+        msg = ''
+
+        while True:
+
+            data = self.conn.recv(1024)
+            msg = data.decode()
+
+            # pdb.set_trace() # Breakpoint
+
+            if msg.strip() == 'bye':
+                break
+
+            print(f"\n[+] Recibido del cliente {self.addr}: {msg.strip()}")
+            self.conn.send(data)
+
+        print(f"\n[-] Cliente {self.addr} desconectado")
+        self.conn.close()
+
+
+HOST = 'localhost'
+PORT = 1234
+
+with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
+
+    # Alterar propiedades del socket
+    # Reutilizar direcciones
+    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+    # Otras propiedades: https://docs.python.org/3/library/socket.html#socket.socket.setsockopt
+    # socket.IPPROTO_IP, socket.IPPROTO_IPV6, socket.IPPROTO_TCP, socket.IPPROTO_UDP...
+
+    # Enlazar socket a dirección y puerto
+    s.bind((HOST, PORT))
+
+    print(f"Servidor TCP escuchando en {HOST}:{PORT}")
+
+    while True:
+
+        s.listen()
+        conn, addr = s.accept()
+        new_thread = ClientThread(conn, addr)
+        new_thread.start()