您好,登錄后才能下訂單哦!
這篇文章主要介紹Python如何實(shí)現(xiàn)服務(wù)器,文中介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們一定要看完!
具體如下:
python - 單進(jìn)程服務(wù)器
#coding=utf-8 from socket import * #創(chuàng)建套接字 serSocket = socket(AF_INET, SOCK_STREAM) #重復(fù)使用綁定信息 serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1) localAddr = ('', 7788) #綁定端口ip serSocket.bind(localAddr) #監(jiān)聽 serSocket.listen(5) while True: print('---主進(jìn)程,等待新客戶端的到來(lái)---') newSocket,destAddr = serSocket.accept() print('---主進(jìn)程,接下來(lái)負(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)閉') break finally: newSocket.close() serSocket.close()
總結(jié)
同一時(shí)刻只能為一個(gè)客戶進(jìn)行服務(wù),不能同時(shí)為多個(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ù)是否為空 來(lái)判斷客戶端是否已經(jīng)下線。
python - 多進(jìn)程服務(wù)器
#coding=utf-8 from socket import * from multiprocessing import * from time import sleep #處理客戶端的請(qǐng)求并為其服務(wù) def dealWithClient(newSocket,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)閉') break finally: newSocket.close() def main(): #創(chuàng)建套接字 serSocket = socket(AF_INET, SOCK_STREAM) #重復(fù)使用綁定信息 serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1) localAddr = ('', 7788) #綁定端口ip serSocket.bind(localAddr) #監(jiān)聽 serSocket.listen(5) try: while True: print('---主進(jìn)程,等待新客戶端的到來(lái)---') newSocket,destAddr = serSocket.accept() print('---主進(jìn)程,接下來(lái)負(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()
總結(jié)
通過為每個(gè)客戶端創(chuàng)建一個(gè)進(jìn)程的方式,能夠同時(shí)為多個(gè)客戶端進(jìn)行服
務(wù)當(dāng)客戶端不是特別多的時(shí)候,這種方式還行,如果有成百上千個(gè),就不
可取了,因?yàn)槊看蝿?chuàng)建進(jìn)程的過程需要消耗較多的資源。
python - 多線程服務(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)) break newSocket.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)程,,等待新客戶端的到來(lái)------') newSocket,destAddr = serSocket.accept() print('-----主進(jìn)程,,接下來(lái)創(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: # 當(dāng)為所有的客戶端服務(wù)完之后再進(jìn)行關(guān)閉,表示不再接收新的客戶端的鏈接 serSocket.close() if __name__ == '__main__': main()
單進(jìn)程服務(wù)器-非堵塞模式
服務(wù)器:
#coding=utf-8 from socket import * import time # 用來(lái)存儲(chǔ)所有的新鏈接的socket g_socketList = [] def main(): serSocket = socket(AF_INET, SOCK_STREAM) serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR , 1) localAddr = ('', 7788) serSocket.bind(localAddr) #可以適當(dāng)修改listen中的值來(lái)看看不同的現(xiàn)象 serSocket.listen(1000) #將套接字設(shè)置為?堵塞 #設(shè)置為?堵塞后,如果accept時(shí),恰巧沒有客戶端connect,那么accept會(huì) #產(chǎn)生一個(gè)異常,所以需要try來(lái)進(jìn)行處理 serSocket.setblocking(False) while True: #?來(lái)測(cè)試 #time.sleep(0.5) try: newClientInfo = serSocket.accept() except Exception as result: pass else: print("一個(gè)新的客戶端到來(lái):%s"%str(newClientInfo)) newClientInfo[0].setblocking(False) g_socketList.append(newClientInfo) # 用來(lái)存儲(chǔ)需要?jiǎng)h除的客戶端信息 needDelClientInfoList = [] for clientSocket,clientAddr in g_socketList: try: recvData = clientSocket.recv(1024) if len(recvData)>0: print('recv[%s]:%s'%(str(clientAddr), recvData)) else: print('[%s]客戶端已經(jīng)關(guān)閉'%str(clientAddr)) clientSocket.close() g_needDelClientInfoList.append((clientSocket,clientAddr)) except Exception as result: pass for needDelClientInfo in needDelClientInfoList: g_socketList.remove(needDelClientInfo) if __name__ == '__main__': main()
客戶端:
#coding=utf-8 from socket import * import random import time serverIp = input("請(qǐng)輸入服務(wù)器的ip:") connNum = input("請(qǐng)輸入要鏈接服務(wù)器的次數(shù)(例如1000):") g_socketList = [] for i in range(int(connNum)): s = socket(AF_INET, SOCK_STREAM) s.connect((serverIp, 7788)) g_socketList.append(s) print(i) while True: for s in g_socketList: s.send(str(random.randint(0,100))) # 用來(lái)測(cè)試 #time.sleep(1)
以上是“Python如何實(shí)現(xiàn)服務(wù)器”這篇文章的所有內(nèi)容,感謝各位的閱讀!希望分享的內(nèi)容對(duì)大家有幫助,更多相關(guān)知識(shí),歡迎關(guān)注億速云行業(yè)資訊頻道!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。