一、原理说明

框架代码说明：

#python通过线程和socket 最简单的方式实现TCP聊天功能import socketimport  threadingip='127.0.0.1'port=7777s=socket.socket()#生成socket对象s.bind((ip, port))s.listen()def accp():    while True:        newsock, clients = s.accept()        '''        执行到accept 方法处于阻塞状态 该方法生成 一个新的socket(保存在newsock) ，通过新socket 与客户端建立连接。        通过死循环，当执行到该处代码，程序阻塞，当TCP客户端发起tcp连接请求 ，程序执行到下面，并打印newsock        同时生成一个线程对象，调用recv 方法，(到此accp 第一次循环执行完毕，紧接着执行下一次循环并再此生成一个        新socke 等待其他客户端发过来的TCP连接) ，socket  的recv方法也是阻塞状态，该方法等待接收客户端发过来的数据 ，bytes类型        当 收到客户端发送的数据，recv函数的程序继续往下执行，打印data ，同时打印newsock的，打印这里只是为了验证        这里的socket和 accp函数里面第一次生成的socket是同一个对象，此时该函数执行完毕，同时进入下一次循环，执行到sock recv函数        的时候仍出于阻塞状态，直到TCP客户端发送信的数据过来。通过该方式 简单实现聊天的最初级版本功能                '''        print(newsock)        threading.Thread(target=recv,args=(newsock,),name="recv").start()def recv(newsock):    while True:        data = newsock.recv(1024)#阻塞状态，        print(data)        print(newsock)accp()

版本二：

#TCP 的server端简单示例import socketimport threadingimport datetimeimport loggingformat="%(asctime)s-----%(process)s----%(thread)s-----%(threadName)s--日志消息--%(message)s   "logging.basicConfig(format=format,level=logging.NOTSET)class ChatServer:    def __init__(self,ip='127.0.0.1',port=9999):        self.sock=socket.socket()        self.addr=ip,port        self.event = threading.Event()        self.newsocks={}#保存 newsocket 和tcp客户端连接信息。后面通过循环close socket        self.lock=threading.Lock()    def start(self):        self.sock.bind(self.addr)        self.sock.listen()        threading.Thread(target=self.accept).start()    def accept(self):        while not self.event.is_set():#当event 是false执行            newsocket,clientinfo=self.sock.accept()            with self.lock:                self.newsocks[clientinfo]=newsocket            threading.Thread(target=self.recv,args=(newsocket,clientinfo),name="recv").start()    def recv(self,newsocket,clientinfo):        while not self.event.is_set():            try:                data=newsocket.recv(1024)            except:                data=b''            print(data)            if data.strip()==b'quit' or data.strip()==b'':#tcp客户端 软件如果直接点击断开 会生成一个空byets  这里防止出现异常                with self.lock:                    self.newsocks.pop(clientinfo)                    newsocket.close()                break            msg="{:%Y-%m-%d %H:%M:%S}[{}--{}-{}]".format(datetime.datetime.now(),                                                        *clientinfo,data.decode())            with self.lock:                for s in self.newsocks.values():                    s.send(msg.encode())## 将str类型转成bytes 网络中传输的都是bytes类型    ##data.decode()将受到的bytes类型转换成字符串    def stop(self):        self.event.set()        keys=[]        with self.lock:            keys=list(self.newsocks.values())            self.newsocks.clear()            for soc in keys:                soc.close()        self.sock.close()cs = ChatServer()cs.start()while True:    cmd=input(">>").strip()    if cmd=="q":        cs.stop()        break    logging.info(threading.enumerate())该程序还有bug 就是newsocket.recv(1024)  处可能会因为网络原因产生异常 可以通过 try  except 处理。可以继续优化备注 这里TCP 客户端是通过 tcp/udp调试工具模拟