快捷導(dǎo)航

python 簡單搭建阻塞式單進(jìn)程,多進(jìn)程,多線程服務(wù)的實(shí)例

更新時(shí)間：2017年11月01日 14:12:46 作者：hongxinerke

下面小編就為大家?guī)硪黄猵ython 簡單搭建阻塞式單進(jìn)程,多進(jìn)程,多線程服務(wù)的實(shí)例。小編覺得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧

我們可以通過這樣子的方式去理解apache的工作原理

1 單進(jìn)程TCP服務(wù)（堵塞式）

這是最原始的服務(wù)，也就是說只能處理個(gè)客戶端的連接，等當(dāng)前客戶端關(guān)閉后，才能處理下個(gè)客戶端，是屬于阻塞式等待

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))
  break
 finally:
  newSocket.close()

這種阻塞型自然不適合處理多客戶端的請求，于是有了改版

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

采取多進(jìn)程處理多客戶端連接請求，對單進(jìn)程進(jìn)行了優(yōu)化。

from socket import *
from multiprocessing import *
from time import sleep
# 處理客戶端的請求并為其服務(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))
   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)程，，等待新客戶端的到來------')
  newSocket,destAddr = serSocket.accept()
  print('-----主進(jìn)程，，接下來創(chuàng)建.個(gè)新的進(jìn)程負(fù)責(zé)數(shù)據(jù)處理[%s]-----'
  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()

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

3 多線程服務(wù)

采用多線程處理多客戶端連接請求，由于線程共享資源，不用像進(jìn)程那樣復(fù)制出多個(gè)資源，因此處理更快。

#coding=utf-8
from socket import *
from threading import Thread
from time import sleep

# 處理客戶端的請求并執(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)程，，等待新客戶端的到來------')
   newSocket,destAddr = serSocket.accept()
   print('-----主進(jìn)程，，接下來創(chuàng)建.個(gè)新的進(jìn)程負(fù)責(zé)數(shù)據(jù)處理[%s]-----'
   client = Thread(target=dealWithClient, args=(newSocket,destAddr))
   client.start()

   #這里不要關(guān)閉，線程共享資源，關(guān)閉了會(huì)導(dǎo)致全部線程均關(guān)閉
   #newSocket.close()
 finally:
  serSocket.close()
if __name__ == '__main__':
main()

以上這篇python 簡單搭建阻塞式單進(jìn)程,多進(jìn)程,多線程服務(wù)的實(shí)例就是小編分享給大家的全部內(nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: