Python-сообщество

import socket
import threading
import multiprocessing
import socketserver

class MprocessingTCPRequestHandler(socketserver.BaseRequestHandler):
    def handle(self):
        data = self.request.recv(1024)
        cur_thread = multiprocessing.current_process()
        response = bytes("%s: %s" % (cur_thread.name, data),'ascii')
        self.request.send(response)

class MprocessingTCPServer(socketserver.ForkingMixIn, socketserver.TCPServer):
    pass

def client(ip, port, message):
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.connect((ip, port))
    sock.send(message)
    response = sock.recv(1024)
    print("Received: %s" % response)
    sock.close()

if __name__ == "__main__":
    HOST, PORT = "localhost", 9999
    server = MprocessingTCPServer((HOST, PORT), MprocessingTCPRequestHandler)
    ip, port = server.server_address

    server_thread = threading.Thread(target=server.serve_forever)
    server_thread.setDaemon(True)
    server_thread.start()
    print("Server loop running in thread:", server_thread.name)

    client(ip, port, b"Hello World 1")
    client(ip, port, b"Hello World 2")
    client(ip, port, b"Hello World 3")

    server.shutdown()