多用户多房间Tp聊天Python

1、百度文库Server#coding:utf8import threadingfrom socket import *from time import ctime,sleep#from os.path import splitHOST =''PORT = 32123BUFSIZE = 1024ADDR = (HOST, PORT)chatSerSock = socket。chatSerSock.bind(ADDR)chatSerSock.listen(5)clients = None:,def Deal(sck, username, room):adata=sck.recv(BU

2、FSIZE).decode()if adata!='success':print('client have a problem')sck.close()for i in clientsroom.keys():if i != username:12fmtdatai='01loginroom百度文库2'.format(ctime(),username,room)try:clientsroomi.send(fmtdatai.encode()except(Exception) as e:print('msg send wrong',e)w

3、hile True:try:while 1:data = sck.recv(BUFSIZE).decode()if len(data.strip()>0:breakelse:print('cannot send null ')except:print('lose a connect ')sck.close()breakfmtdatau='01say :n2'.format(ctime(),username,data)print(fmtdatau)try:22百度文库for i in clientsroom.keys():if i != us

4、ername:if data != "quit": fmtdatai='01say :n2'.format(ctime(),username,data)#print(fmtdatai) try:clientsroomi.send(fmtdatai.encode()except(Exception) as e:print('room send wrong',e)else: fmtdatao='user 0 in 1 is out at2'.format(username,room,ctime()#print(fmtdatao)c

5、lientsroomi.send(fmtdatao.encode()if data = "quit":del clientsroomusername sck.send(data.encode() sck.close() break34百度文库except:passwhile 1:/print('waiting for connection.')try:chatCliSock,addr = chatSerSock.accept()except:print('accept exc')sleep(1)continueprint (".co

6、nnected from: ",addr)try:data=chatCliSock.recv(BUFSIZE).decode()except:print('in recv main')username,room = data.split()#print (username,' u ',room,' r ',data)if room not in clients.keys():#print(room)clientsroom = #print('in room',clients.keys()44百度文库try:if user

7、name in clientsroom.keys():print('in usr')chatCliSock.send("reuse".encode()chatCliSock.close()else:#print('in sucess')chatCliSock.send("success".encode()clientsroomusername = chatCliSockt = threading.Thread(target=Deal, args=(chatCliSock, username, room)t.start()e

8、xcept:print('the client exit with an exception')chatSerSock.close()client#coding:utf8from socket import *from time import ctime,sleepimport threading55百度文库import sysHOST = 'localhost'PORT= 32123BUFSIZE = 1024ADDR = (HOST, PORT)threads =def Send(sck,test):sck.send('success'.en

9、code()while True:try:while 1:data = input('>>') if len(data)>0:breaksck.send(data.encode() if data = "quit":breakexcept:passdef Recieve(sck,test):while True:#print('in recv')66百度文库sleep(1)try:data = sck.recv(BUFSIZE).decode() except:print('in recv wrong c')

10、passif data = "quit":sck.close()breakelse:print(''n', data,''n')username=input('input username:')room=input('input room:')chatCliSock =socket()chatCliSock.connect(ADDR)fmtusr='0 1'.format(username,room)chatCliSock.send(fmtusr.encode()print(fm

11、tusr)data = chatCliSock.recv(BUFSIZE).decode()try:77百度文库if data = "reuse":print("user %s have been logined room %s" %(username, room)input() /sys.exit(1)elif data = "success":print("user %s login room %s success" %(username, room)t = threading.Thread(target=Send, args = (chatCliSock, None)threads.append(t)t = threa