第利用Python打造一個(gè)多人聊天室的示例詳解vii.掌握利用Socket進(jìn)行編程的技術(shù)

viii.必須掌握多線(xiàn)程技術(shù)，保證雙方可以同時(shí)發(fā)送

ix.建立聊天工具

x.可以和多個(gè)人同時(shí)進(jìn)行聊天

xi.必須使用圖形界面，顯示雙方的語(yǔ)錄

四、實(shí)驗(yàn)環(huán)境

PC多臺(tái)，操作系統(tǒng)Win7，win10（32位、64位）

具備軟件python3.6。

五、操作方法與實(shí)驗(yàn)步驟

服務(wù)端

1.調(diào)入多線(xiàn)程、與scoket包，用于實(shí)現(xiàn)多線(xiàn)程連接

2.記錄本地地址與端口，開(kāi)啟監(jiān)聽(tīng)，等待請(qǐng)求

3.收到某個(gè)客戶(hù)端的請(qǐng)求，建立連接，為每一個(gè)客戶(hù)端分配一個(gè)線(xiàn)程，并記錄客戶(hù)端地址與端口

4.收到某個(gè)客戶(hù)端發(fā)送的數(shù)據(jù)，將數(shù)據(jù)轉(zhuǎn)發(fā)給所有與服務(wù)器連接的客戶(hù)機(jī)。

5.當(dāng)某個(gè)客戶(hù)端斷開(kāi)連接，通知所有與服務(wù)器連接的客戶(hù)機(jī)。

6.服務(wù)器一直保持監(jiān)聽(tīng)狀態(tài)，等待其他客戶(hù)端接入服務(wù)器

7.代碼

importsocket

importthreading

num=0

defchat(service_client_socket,addr):

#等待接收客戶(hù)端消息存放在2個(gè)變量service_client_socket和addr里

ifnotaddrinuser:

print('Acceptnewconnectionfrom%s:%s...'%addr)

#如果addr不在user字典里則執(zhí)行以下代碼

forscsinserv_clie_socket:

serv_clie_socket[scs].send(data+'進(jìn)入聊天室...'.encode('utf-8'))

#發(fā)送user字典的data和address到客戶(hù)端

user[addr]=data.decode('utf-8')#data是最新進(jìn)入聊天室的客戶(hù)，解壓后放入user

serv_clie_socket[addr]=service_client_socket#將服務(wù)器與服務(wù)器端口號(hào)為addr的套接字放入字典

#接收的消息解碼成utf-8并存在字典user里,鍵名定義為addr

#print("可以開(kāi)始聊天了")

#如果addr在user字典里，跳過(guò)本次循環(huán)

whileTrue:

d=service_client_socket.recv(1024)

if(('EXIT'.lower()ind.decode('utf-8'))|(d.decode('utf-8')=='error1')):

#如果EXIT在發(fā)送的data里

name=user[addr]

#user字典addr鍵對(duì)應(yīng)的值賦值給變量name

user.pop(addr)

serv_clie_socket.pop(addr)

#刪除user里的addr

forscsinserv_clie_socket:

#從user取出address

serv_clie_socket[scs].send((name+'離開(kāi)了聊天室...').encode('utf-8'))

#發(fā)送name和address到客戶(hù)端

print('Connectionfrom%s:%sclosed.'%addr)

globalnum

num=num-1

break

else:

print('"%s"from%s:%s'%(d.decode('utf-8'),addr[0],addr[1]))

forscsinserv_clie_socket:

#從user遍歷出address

ifserv_clie_socket[scs]!=service_client_socket:

#address不等于addr時(shí)，執(zhí)行下面的代碼

serv_clie_socket[scs].send(d)

#發(fā)送data到客戶(hù)端

s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)#創(chuàng)建socket對(duì)象

addr=('127.0.0.1',9999)

s.bind(addr)#綁定地址和端口

s.listen(128)

print('TCPServeron',addr[0],":",addr[1],"......")

user={}#存放字典{addr:name}

serv_clie_socket={}#存放{socket:不同線(xiàn)程的套接字}

whileTrue:

try:

print("等待接收客戶(hù)端的連接請(qǐng)求....")

service_client_socket,addr=s.accept()#等待接收客戶(hù)端的連接請(qǐng)求

print("接收到客戶(hù)端的連接請(qǐng)求....")

exceptConnectionResetError:

print('Someoneleftunexcept.')

data=service_client_soc