基于tcp多线程的聊天系统

import socket
from threading import Thread
import time

def talk(con):
    while True:
        data_bytes = con.recv(1024)
        t = time.strftime("%Y/%m/%d %H:%M:%S",time.localtime(time.time()))
        print("\033[1;31;47m",t,data_bytes.decode("utf-8"))
        
def server(ip,port):
    master = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
    master.bind((ip,port))
    master.listen(1)
    con,a = master.accept()
    t = Thread(target=talk,args=(con,))
    t.start()
    while True:
        data = input("\033[1;30;47m")
        con.send(data.encode("utf-8"))
if __name__ == "__main__":
    server("127.0.0.1",8080)

import time
import socket
from threading import Thread

def talk(con):
    while True:
        data_bytes = con.recv(1024)
        t = time.strftime("%Y/%m/%d %H:%M:%S",time.localtime(time.time()))
        print("\033[1;31;47m",t,data_bytes.decode("utf-8"))

def client(ip,port):
    conn = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
    conn.connect((ip,port))
    t = Thread(target=talk,args=(conn,))
    t.start()
    while True:
        data = input("\033[1;30;47m")
        conn.send(data.encode("utf-8"))

if __name__ == "__main__":
    client("127.0.0.1",8080)