多用户多房间Tp聊天Python

1、Server#coding:utf8importthreadingfromsocketimport*fromtimeimportctime,sleep#fromos.pathimportsplitHOST=PORT=32123BUFSIZE=1024ADDR=(HOST,PORT)chatSerSock=socket()chatSerSock.bind(ADDR)chatSerSock.listen(5)clients=None:,defDeal(sck,username,room):adata=sck.recv(BUFSIZE).decode()ifadata!=success:print(

2、clienthaveaproblem)sck.close()foriinclientsroom.keys():ifi!=username:fmtdatai=01loginroom2.format(ctime(),username,room)try:clientsroomi.send(fmtdatai.encode()except(Exception)ase:print(msgsendwrong,e)whileTrue:try:while1:data=sck.recv(BUFSIZE).decode()iflen(data.strip()0:breakelse:print(cannotsendn

3、ull)except:print(loseaconnect)sck.close()breakfmtdatau=01say:n2.format(ctime(),username,data)print(fmtdatau)try:foriinclientsroom.keys():ifi!=username:ifdata!=quit:fmtdatai=01say:n2.format(ctime(),username,data)#print(fmtdatai)try:clientsroomi.send(fmtdatai.encode()except(Exception)ase:print(roomsen

4、dwrong,e)else:fmtdatao=user0in1isoutat2.format(username,room,ctime()#print(fmtdatao)clientsroomi.send(fmtdatao.encode()ifdata=quit:delclientsroomusernamesck.send(data.encode()sck.close()breakexcept:passwhile1:/print(waitingforconnection.,)try:chatCliSock,addr=chatSerSock.accept()except:print(accepte

5、xc)sleep(1)continueprint(.connectedfrom:,addr)try:data=chatCliSock.recv(BUFSIZE).decode()except:print(inrecvmain)username,room=data.split()#print(username,u,room,r,data)ifroomnotinclients.keys():#print(room)clientsroom=#print(inroom,clients.keys()try:ifusernameinclientsroom.keys():print(inusr)chatCl

6、iSock.send(reuse.encode()chatCliSock.close()else:#print(insucess)chatCliSock.send(success.encode()clientsroomusername=chatCliSockt=threading.Thread(target=Deal,args=(chatCliSock,username,room)t.start()except:print(theclientexitwithanexception)chatSerSock.close()client#coding:utf8fromsocketimport*fro

7、mtimeimportctime,sleepimportthreadingimportsysHOST=localhostPORT=32123BUFSIZE=1024ADDR=(HOST,PORT)threads=defSend(sck,test):sck.send(success.encode()whileTrue:try:while1:data=input()iflen(data)0:breaksck.send(data.encode()ifdata=quit:breakexcept:passdefRecieve(sck,test):whileTrue:#print(inrecv)sleep

8、(1)try:data=sck.recv(BUFSIZE).decode()except:print(inrecvwrongc)passifdata=quit:sck.close()breakelse:print(n,data,n)username=input(inputusername:)room=input(inputroom:)chatCliSock=socket()chatCliSock.connect(ADDR)fmtusr=01.format(username,room)chatCliSock.send(fmtusr.encode()print(fmtusr)data=chatCliSock.recv(BUFSIZE).decode()try:ifdata=reuse:print(user%shavebeenloginedroom%s%(username,room)input()/sys.exit(1)elifdata=success:print(user%sloginroom%ssuccess%(username,room)t=threading.Thread(target=Send,args=(chatCliSock,None)threads.append(t)t=threading.Thread(targ