利用Python中SocketServer 實(shí)現(xiàn)客戶端與服務(wù)器間非阻塞通信
利用SocketServer模塊來(lái)實(shí)現(xiàn)網(wǎng)絡(luò)客戶端與服務(wù)器并發(fā)連接非阻塞通信。
首先，先了解下SocketServer模塊中可供使用的類(lèi)：
BaseServer：包含服務(wù)器的核心功能與混合（mix-in）類(lèi)掛鉤；這個(gè)類(lèi)只用于派生，所以不會(huì)生成這個(gè)類(lèi)的實(shí)例；可以考慮使用TCPServer和UDPServer。
TCPServer/UDPServer：基本的網(wǎng)絡(luò)同步TCP/UDP服務(wù)器。
UnixStreamServer/ UnixDatagramServer：基本的基于文件同步TCP/UDP服務(wù)器。
ForkingMixIn/ ThreadingMixIn：實(shí)現(xiàn)了核心的進(jìn)程化或線程化的功能；作為混合類(lèi)，與服務(wù)器類(lèi)一并使用以提供一些異步特性；這個(gè)類(lèi)不會(huì)直接實(shí)例化。
ForkingTCPServer/ ForkingUDPServer：ForkingMixIn和TCPServer/UDPServer的組合。
BaseRequestHandler：包含處理服務(wù)請(qǐng)求的核心功能。這個(gè)類(lèi)只用于派生，所以不會(huì)生成這個(gè)類(lèi)的實(shí)例可以考慮使用StreamRequestHandler或DatagramRequestHandler。
StreamRequestHandler/ DatagramRequestHandler：用于TCP/UDP服務(wù)器的服務(wù)處理工具。
下面我們正式進(jìn)入主題，這里我們采用StreamRequestHandler和ThreadingTCPServer來(lái)實(shí)現(xiàn)客戶端與服務(wù)器并發(fā)連接非阻塞socket。
ThreadingTCPServer派生自ThreadingMixIn，主要實(shí)現(xiàn)核心的進(jìn)程化合線程化功能。
StreamRequestHandler主要用于用于TCP/UDP服務(wù)器的服務(wù)處理工具。
一、創(chuàng)建SocketServerTCP服務(wù)端
[python] view plain copy
#創(chuàng)建SocketServerTCP服務(wù)器：
import SocketServer
from SocketServer import StreamRequestHandler as SRH
from time import ctime
host = 'xxx.xxx.xxx.xxx'
port = 9999
addr = (host,port)
class Servers(SRH):
def handle(self):
print 'got connection from ',self.client_address
self.wfile.write('connection %s:%s at %s succeed!' % (host,port,ctime()))
while True:
data = self.request.recv(1024)
if not data:
break
print data
print "RECV from ", self.client_address[0]
self.request.send(data)
print 'server is running....'
server = SocketServer.ThreadingTCPServer(addr,Servers)
server.serve_forever()
二、創(chuàng)建SocketServerTCP客戶端
[python] view plain copy
from socket import *
host = 'xxx.xxx.xxx.xxx'
port = 9999
bufsize = 1024
addr = (host,port)
client = socket(AF_INET,SOCK_STREAM)
client.connect(addr)
while True:
data = raw_input()
if not data or data=='exit':
break
client.send('%s\r\n' % data)
data = client.recv(bufsize)
if not data:
break
print data.strip()
client.close()
- Python使用socketServer包搭建簡(jiǎn)易服務(wù)器過(guò)程詳解
- python網(wǎng)絡(luò)編程：socketserver的基本使用方法實(shí)例分析
- Python探索之SocketServer詳解
- 基于python socketserver框架全面解析
- Python使用SocketServer模塊編寫(xiě)基本服務(wù)器程序的教程
- 實(shí)例講解Python中SocketServer模塊處理網(wǎng)絡(luò)請(qǐng)求的用法
- python網(wǎng)絡(luò)編程之TCP通信實(shí)例和socketserver框架使用例子
- Python網(wǎng)絡(luò)編程之socket與socketserver
相關(guān)文章
基于PyQt5實(shí)現(xiàn)的Windows定時(shí)關(guān)機(jī)工具
在日常使用電腦的過(guò)程中,我們經(jīng)常會(huì)遇到需要定時(shí)關(guān)機(jī)的場(chǎng)景,雖然 Windows 自帶 shutdown 命令可以定時(shí)關(guān)機(jī),但操作方式較為繁瑣,缺乏可視化界面,因此,本篇文章將帶大家實(shí)現(xiàn)一個(gè)基于 PyQt5 的 Windows 定時(shí)關(guān)機(jī)工具,需要的朋友可以參考下2025-04-04
本文主要介紹了python安裝包site-packages的方法步驟,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2025-01-01
今天小編就為大家分享一篇對(duì)PyQt5中的菜單欄和工具欄實(shí)例詳解，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2019-06-06
Gauss-Seidel迭代算法的Python實(shí)現(xiàn)詳解
這篇文章主要介紹了Gauss-Seidel迭代算法的Python實(shí)現(xiàn)詳解，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-06-06
這篇文章主要介紹了Python中空格的轉(zhuǎn)義字符方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-03-03
Python json模塊與jsonpath模塊區(qū)別詳解
這篇文章主要介紹了Python json模塊與jsonpath模塊區(qū)別詳解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-03-03
如何在Python3中使用telnetlib模塊連接網(wǎng)絡(luò)設(shè)備
這篇文章主要介紹了如何在Python3中使用telnetlib模塊連接網(wǎng)絡(luò)設(shè)備,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-09-09
Python 3.8新特征之a(chǎn)syncio REPL
我最近都在寫(xiě)一些Python 3.8的新功能介紹的文章，在自己的項(xiàng)目中也在提前體驗(yàn)新的Python版本。這篇文章主要介紹了Python 3.8新特征之a(chǎn)syncio REPL,需要的朋友可以參考下2019-05-05
這篇文章主要介紹了OpenCV基本操作之色彩空間，本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-09-09
下面小編就為大家?guī)?lái)一篇python虛擬環(huán)境的安裝配置圖文教程。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-10-10