socket多線程通信

服務端：

import socketserver
# import random

class MyServer(socketserver.BaseRequestHandler):

    def setup(self):
        pass

    def handle(self):
        conn = self.request
        msg = "hello world!"
        conn.send(msg.encode())
        while True:

            data = conn.recv(1024)
            print(data.decode())

            if msg == b'exit':
                break
            msg_input = input("請輸入發送的消息：")
            conn.send(msg_input.encode())
            # conn.send(str(random.randint(1,1000)).encode())
        conn.close()

    def finish(self):
        pass

if __name__ == "__main__":
    server = socketserver.ThreadingTCPServer(("127.0.0.1",9999),MyServer)
    server.serve_forever()

客戶端：

import socket

client = socket.socket()

ip_port = ("127.0.0.1",9999)

client.connect(ip_port)

while True:

    data = client.recv(1024)

    print(data.decode())

    msg_input = input("請輸入發送的消息：")

    client.send(msg_input.encode())

    if msg_input == "exit":
        break

    # data = client.recv(1024)

    # print(data.decode())