import threading

import socket

server=socket.socket()

ip_port=("127.0.0.1",8008)

server.bind(ip_port)

server.listen(5)

def action(conn):

    while 1:

        data=conn.recv(1024)

        print(data)

        msg=input("服务端输入")

        conn.send(bytes(msg,encoding="utf-8"))

if __name__ == '__main__':

    while 1:

        conn,addr=server.accept()

        p=threading.Thread(target=action,args=(conn,))

        p.start()

import socket

client=socket.socket()

client.connect(("127.0.0.1",8008))

while 1:

    msg=input("客户端输入")

    if not msg:

        continue

    client.send(msg.encode("utf-8"))

    data=client.recv(1024)

    print(data)