快捷導(dǎo)航

Python實(shí)現(xiàn)一個(gè)服務(wù)器監(jiān)聽(tīng)多個(gè)客戶端請(qǐng)求

更新時(shí)間：2018年04月12日 14:39:01 作者：驚瑟

這篇文章主要為大家詳細(xì)介紹了Python如何實(shí)現(xiàn)一個(gè)服務(wù)器監(jiān)聽(tīng)多個(gè)客戶端請(qǐng)求，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

學(xué)習(xí)Python網(wǎng)絡(luò)通信的時(shí)候發(fā)現(xiàn)書(shū)上只有一個(gè)服務(wù)端對(duì)應(yīng)一個(gè)客戶端的情形，于是自己想自己動(dòng)手實(shí)現(xiàn)一個(gè)服務(wù)端響應(yīng)多個(gè)客戶端。

首先建立服務(wù)器的socket來(lái)監(jiān)聽(tīng)客戶端的請(qǐng)求：

tcpSerSock=socket(AF_INET,SOCK_STREAM) 
tcpSerSock.bind(ADDR) 
tcpSerSock.listen(5)

這樣服務(wù)器的監(jiān)聽(tīng)socket就建好了。

接下來(lái)的思路是，如果要監(jiān)聽(tīng)多個(gè)客戶端，則

tcpSerSock.accept() #（accept()是阻塞式的）

必須放進(jìn)一個(gè)while循環(huán)（不放進(jìn)循環(huán)監(jiān)聽(tīng)一次就沒(méi)了）。然而，這里就有問(wèn)題了。如果按照一對(duì)一的那種處理順序，客戶端A連進(jìn)來(lái)后，程序順序向下執(zhí)行，服務(wù)端要再寫(xiě)一個(gè)while循環(huán)，用來(lái)處理客戶端A的請(qǐng)求，如果此時(shí)客戶端B再來(lái)請(qǐng)求，服務(wù)器將接收不到。于是，很自然想到，將監(jiān)聽(tīng)和處理放到不同的線程進(jìn)行處理。我選擇將監(jiān)聽(tīng)放入主線程，將處理放進(jìn)子線程。該服務(wù)器功能為接收到客戶端的數(shù)據(jù)加上時(shí)間戳后返回給客戶端。服務(wù)端完整代碼如下：

#coding=utf-8 
#!/usr/bin/env python 
''''' 
author:Mr.Jing 
created on Fri Sep 22 14:29:03 2017 
platfrom:win10,python2.7 
''' 
 
from socket import * 
from time import ctime 
import threading 
import time 
HOST='' 
PORT=2159 
BUFSIZ=1024 
ADDR = (HOST,PORT) 
 
tcpSerSock=socket(AF_INET,SOCK_STREAM) 
tcpSerSock.bind(ADDR) 
tcpSerSock.listen(5) 
socks=[]        #放每個(gè)客戶端的socket 
 
def handle(): 
 while True: 
  for s in socks: 
   data = s.recv(BUFSIZ) 
   if not data: 
    socks.remove(s) 
    continue 
   s.send('[%s],%s' % (ctime(), data)) #加上時(shí)間戳返回 
 
t = threading.Thread(target=handle)    #子線程 
if __name__ == '__main__': 
 t.start() 
 print u'我在%s線程中 ' % threading.current_thread().name #本身是主線程 
 print 'waiting for connecting...' 
 while True: 
  clientSock,addr = tcpSerSock.accept() 
  print 'connected from:', addr 
  socks.append(clientSock)

兩個(gè)客戶端A和B同時(shí)連接，服務(wù)器輸出：

可以看到服務(wù)端是可以相應(yīng)多個(gè)客戶端的。

客戶端A發(fā)條消息試試？

服務(wù)器返回來(lái)了帶時(shí)間戳的消息，goodjob。

那另一個(gè)呢？

很棒。服務(wù)器都能做出響應(yīng)。

再發(fā)一條試試？

發(fā)現(xiàn)服務(wù)器沒(méi)響應(yīng)了，這是怎么回事呢?

經(jīng)過(guò)仔細(xì)勘察發(fā)現(xiàn)是因?yàn)檫@句：

data = s.recv(BUFSIZ)

因?yàn)閞ecv方法是阻塞的，也就是說(shuō)，當(dāng)輪訓(xùn)到某個(gè)客戶端，比如A，這句等待A發(fā)消息，不發(fā)消息就不往下走，所以此時(shí)B再去發(fā)消息的話服務(wù)器就收不到了。

那該怎么辦呢？

很容易想到，將其設(shè)為非阻塞就好了。但上網(wǎng)找了好久，雖然找到可以用setblocking(0) 將套接字設(shè)為非阻塞，然而具體怎么用卻很少有人講清楚。查資料后終于搞明白，非阻塞的recv方法會(huì)繼續(xù)向下執(zhí)行，若超時(shí)得不到數(shù)據(jù)則會(huì)拋出異常。

修改后的代碼如下：

#coding=utf-8 
#!/usr/bin/env python 
''''' 
author:Mr.Jing 
created on Fri Sep 22 14:29:03 2017 
platfrom:win10,python2.7 
''' 
 
from socket import * 
from time import ctime 
import threading 
import time 
HOST='' 
PORT=2159 
BUFSIZ=1024 
ADDR = (HOST,PORT) 
 
tcpSerSock=socket(AF_INET,SOCK_STREAM) 
tcpSerSock.bind(ADDR) 
tcpSerSock.listen(5) 
socks=[]        #放每個(gè)客戶端的socket 
 
def handle(): 
 while True: 
  for s in socks: 
   try: 
    data = s.recv(BUFSIZ)  #到這里程序繼續(xù)向下執(zhí)行 
   except Exception, e:   
    continue 
   if not data: 
    socks.remove(s) 
    continue 
   s.send('[%s],%s' % (ctime(), data)) 
 
t = threading.Thread(target=handle)    #子線程 
if __name__ == '__main__': 
 t.start() 
 print u'我在%s線程中 ' % threading.current_thread().name #本身是主線程 
 print 'waiting for connecting...' 
 while True: 
  clientSock,addr = tcpSerSock.accept() 
  print 'connected from:', addr 
  clientSock.setblocking(0) 
  socks.append(clientSock)

此時(shí)再去嘗試：