這篇文章將為大家詳細(xì)講解有關(guān)Python中怎么利用Socket編程實現(xiàn)多線程聊天室,文章內(nèi)容質(zhì)量較高,因此小編分享給大家做個參考,希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。
#coding = utf-8 import socket import threading class UdpServer(threading.Thread): def __init__(self): threading.Thread.__init__(self) self.address = ('127.0.0.1', 10000) self.s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) self.s.bind(self.address) self.stop_flag = False def recieve_msg(self): (data, addr) = self.s.recvfrom(2048) if data: print 'recieve data from', addr print data def run(self): while not self.stop_flag: self.recieve_msg() def stop(self): self.stop_flag = True class UdpClient(threading.Thread): def __init__(self): threading.Thread.__init__(self) self.address = ('127.0.0.1', 10001) self.s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) self.stop_flag = False def send_msg(self): data = raw_input() if not data: print 'Wrong inpiut' return else: self.s.sendto(data, self.address) def run(self): while not True: self.send_msg() def stop(self): self.stop_flag = True def main(): t1 = UdpServer() t2 = UdpClient() t1.start() t2.start() if __name__ == '__main__': main()
關(guān)于Python中怎么利用Socket編程實現(xiàn)多線程聊天室就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,可以學(xué)到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。