單進(jìn)程服務(wù)器

1. 完成一個(gè)簡(jiǎn)單的TCP服務(wù)器

from socket import *serSocket = socket(AF_INET, SOCK_STREAM)# 重復(fù)使用綁定的信息 serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR , 1)localAddr = ('', 7788)serSocket.bind(localAddr)serSocket.listen(5)while True:print('-----主進(jìn)程，，等待新客戶端的到來------')newSocket,destAddr = serSocket.accept()print('-----主進(jìn)程，，接下來負(fù)責(zé)數(shù)據(jù)處理[%s]-----'%str(destAddr))try:while True:recvData = newSocket.recv(1024)if len(recvData)>0:print('recv[%s]:%s'%(str(destAddr), recvData))else:print('[%s]客戶端已經(jīng)關(guān)閉'%str(destAddr))breakfinally:newSocket.close()serSocket.close()

2. 總結(jié)

• 同一時(shí)刻只能為一個(gè)客戶進(jìn)行服務(wù)，不能同時(shí)為多個(gè)客戶服務(wù)
• 類似于找一個(gè)“明星”簽字一樣，客戶需要耐心等待才可以獲取到服務(wù)
• 當(dāng)服務(wù)器為一個(gè)客戶端服務(wù)時(shí)，而另外的客戶端發(fā)起了connect，只要服務(wù)器listen的隊(duì)列有空閑的位置，就會(huì)為這個(gè)新客戶端進(jìn)行連接，并且客戶端可以發(fā)送數(shù)據(jù)，但當(dāng)服務(wù)器為這個(gè)新客戶端服務(wù)時(shí)，可能一次性把所有數(shù)據(jù)接收完畢
• 當(dāng)recv接收數(shù)據(jù)時(shí)，返回值為空，即沒有返回?cái)?shù)據(jù)，那么意味著客戶端已經(jīng)調(diào)用了close關(guān)閉了；因此服務(wù)器通過判斷recv接收數(shù)據(jù)是否為空 來判斷客戶端是否已經(jīng)下線

多進(jìn)程服務(wù)器

1. 多進(jìn)程服務(wù)器

from socket import * from multiprocessing import * from time import sleep# 處理客戶端的請(qǐng)求并為其服務(wù) def dealWithClient(newSocket,destAddr):while True:recvData = newSocket.recv(1024)if len(recvData)>0:print('recv[%s]:%s'%(str(destAddr), recvData))else:print('[%s]客戶端已經(jīng)關(guān)閉'%str(destAddr))breaknewSocket.close()def main():serSocket = socket(AF_INET, SOCK_STREAM)serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR , 1)localAddr = ('', 7788)serSocket.bind(localAddr)serSocket.listen(5)try:while True:print('-----主進(jìn)程，，等待新客戶端的到來------')newSocket,destAddr = serSocket.accept()print('-----主進(jìn)程，，接下來創(chuàng)建一個(gè)新的進(jìn)程負(fù)責(zé)數(shù)據(jù)處理[%s]-----'%str(destAddr))client = Process(target=dealWithClient, args=(newSocket,destAddr))client.start()#因?yàn)橐呀?jīng)向子進(jìn)程中copy了一份（引用），并且父進(jìn)程中這個(gè)套接字也沒有用處了#所以關(guān)閉 newSocket.close()finally:#當(dāng)為所有的客戶端服務(wù)完之后再進(jìn)行關(guān)閉，表示不再接收新的客戶端的鏈接 serSocket.close()if __name__ == '__main__':main()

2. 總結(jié)

• 通過為每個(gè)客戶端創(chuàng)建一個(gè)進(jìn)程的方式，能夠同時(shí)為多個(gè)客戶端進(jìn)行服務(wù)
• 當(dāng)客戶端不是特別多的時(shí)候，這種方式還行，如果有幾百上千個(gè)，就不可取了，因?yàn)槊看蝿?chuàng)建進(jìn)程等過程需要好較大的資源

多線程服務(wù)器

#coding=utf-8 from socket import * from threading import Thread from time import sleep# 處理客戶端的請(qǐng)求并執(zhí)行事情 def dealWithClient(newSocket,destAddr):while True:recvData = newSocket.recv(1024)if len(recvData)>0:print('recv[%s]:%s'%(str(destAddr), recvData))else:print('[%s]客戶端已經(jīng)關(guān)閉'%str(destAddr))breaknewSocket.close()def main():serSocket = socket(AF_INET, SOCK_STREAM)serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR , 1)localAddr = ('', 7788)serSocket.bind(localAddr)serSocket.listen(5)try:while True:print('-----主進(jìn)程，，等待新客戶端的到來------')newSocket,destAddr = serSocket.accept()print('-----主進(jìn)程，，接下來創(chuàng)建一個(gè)新的進(jìn)程負(fù)責(zé)數(shù)據(jù)處理[%s]-----'%str(destAddr))client = Thread(target=dealWithClient, args=(newSocket,destAddr))client.start()#因?yàn)榫€程中共享這個(gè)套接字，如果關(guān)閉了會(huì)導(dǎo)致這個(gè)套接字不可用，#但是此時(shí)在線程中這個(gè)套接字可能還在收數(shù)據(jù)，因此不能關(guān)閉#newSocket.close() finally:serSocket.close()if __name__ == '__main__':main()

?

?

轉(zhuǎn)載于:https://www.cnblogs.com/leecoffee/p/9035540.html

總結(jié)

以上是生活随笔為你收集整理的python网络编程（八）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。