socket.py

import threading
import socket
import time

ADDR = '127.0.0.1'
PORT = 8890


class Server:
    def __init__(self):
        self.t = threading.Thread(target=self.serve, daemon=True)
        socketClient = socket.socket()
        socketClient.connect((ADDR, PORT))
        self.socketClient = socketClient

    def run(self):
        self.t.run()

    def serve(self):
        for i in range(10000):
            self.socketClient.send(b'hello')
            time.sleep(1)


class Client:
    def __init__(self):
        time.sleep(1)
        socketClient = socket.socket()
        socketClient.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        socketClient.bind((ADDR, PORT))
        socketClient.listen(1)
        self.socketClient = socketClient
        self.t = threading.Thread(target=self.readLine, daemon=True)

    def run(self):
        self.t.start()

    def readLine(self):
        while True:
            conn, addr = self.socketClient.accept()
            print('Connected by', addr)
            while True:
                data = conn.recv(8192 * 2)
                print(data)


if __name__ == '__main__':
    client = Client()
    client.run()
    server = Server()
    server.run()