欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Python實現(xiàn)一個服務器監(jiān)聽多個客戶端請求

 更新時間:2018年04月12日 14:39:01   作者:驚瑟  
這篇文章主要為大家詳細介紹了Python如何實現(xiàn)一個服務器監(jiān)聽多個客戶端請求,具有一定的參考價值,感興趣的小伙伴們可以參考一下

學習Python網(wǎng)絡通信的時候發(fā)現(xiàn)書上只有一個服務端對應一個客戶端的情形,于是自己想自己動手實現(xiàn)一個服務端響應多個客戶端。

首先建立服務器的socket來監(jiān)聽客戶端的請求:

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

這樣服務器的監(jiān)聽socket就建好了。

接下來的思路是,如果要監(jiān)聽多個客戶端,則

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

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

#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=[]        #放每個客戶端的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)) #加上時間戳返回 
 
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) 

兩個客戶端A和B同時連接,服務器輸出:

可以看到服務端是可以相應多個客戶端的。

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

服務器返回來了帶時間戳的消息,goodjob。

那另一個呢?

很棒。服務器都能做出響應。

再發(fā)一條試試?

發(fā)現(xiàn)服務器沒響應了,這是怎么回事呢?

經(jīng)過仔細勘察發(fā)現(xiàn)是因為這句:

data = s.recv(BUFSIZ) 

因為recv方法是阻塞的,也就是說,當輪訓到某個客戶端,比如A,這句等待A發(fā)消息,不發(fā)消息就不往下走,所以此時B再去發(fā)消息的話服務器就收不到了。

那該怎么辦呢?

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

修改后的代碼如下:

#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=[]        #放每個客戶端的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) 

此時再去嘗試:

客戶端隨便輸都會得到響應。任務達成!

以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。

相關文章

最新評論