基于python socketserver框架全面解析
socketserver框架是一個基本的socket服務器端框架, 使用了threading來處理多個客戶端的連接, 使用seletor模塊來處理高并發(fā)訪問, 是值得一看的python 標準庫的源碼之一
對于select網絡框架的理解可以看 << 基于python select.select模塊通信的實例講解 >>。socketserver框架采用了selector框架來供你選擇相適應的網絡通信框架, 比如select, poll, epoll等。有了這些網絡框架我們就能處理高并發(fā)的網絡訪問了.
先看看示例代碼吧:
# coding: utf-8
import socketserver
class MyTCPHandler(socketserver.BaseRequestHandler):
"""
The request handler class for our server.
It is instantiated once per connection to the server, and must
override the handle() method to implement communication to the
client.
"""
def handle(self):
# self.request is the TCP socket connected to the client
self.data = self.request.recv(1024).strip()
print("{} wrote:".format(self.client_address[0]))
print(self.data)
# just send back the same data, but upper-cased
self.request.sendall(self.data.upper())
if __name__ == "__main__":
HOST, PORT = "localhost", 9999
# Create the server, binding to localhost on port 9999
# 如果子類沒有某個方法或是屬性, 就回去父類中調用
with socketserver.ThreadingTCPServer((HOST, PORT), MyTCPHandler) as server:
# Activate the server; this will keep running until you
# interrupt the program with Ctrl-C
server.serve_forever()
客戶端:
# coding: utf-8
import socket
sk = socket.socket()
sk.connect(("127.0.0.1", 9999)) # 主動初始化與服務器端的連接
while True:
send_data = input("輸入發(fā)送內容:")
sk.sendall(bytes(send_data, encoding="utf8"))
if send_data == "byebye":
break
accept_data = str(sk.recv(1024), encoding="utf8")
print("".join(("接收內容:", accept_data)))
sk.close()
我們創(chuàng)建一個繼承自BaseRequestHandler類的TCP請求處理類, 說白了這個類就是我們自己封裝的基于socket的recv()函數(shù)與send()函數(shù)的類, 而所謂的TCP請求處理類其實就是對socket服務器端的bind, listen, accept等處理的封裝類, 而且這個封裝的并不是簡單的socket, 而是基于select或是epoll等網絡框架的類, 我們調用這個類就能輕易地處理高并發(fā)的網絡訪問. 其實認真閱讀源碼, 你會發(fā)現(xiàn)整體的程序設計是基于事件驅動的, 事件驅動機制的三個要素: 消息(事件)隊列, 消息(事件)觸發(fā), 事件循環(huán)。只不過socketserver框架的事件驅動機制就做到了socket的accept()方法那, 接下來的消息接受(recv)與發(fā)送(send)就沒有在做封裝成相應的事件來進行處理了。
在這里說一個要注意的地方, 我使用了ThreadingTCPServer()類響應多個客戶端的連接, 但是當我閱讀這個類的源碼的時候, 表示很疑惑啊!
class ThreadingTCPServer(ThreadingMixIn, TCPServer): pass
這讓我很疑惑啊,再看看調用:
with socketserver.ThreadingTCPServer((HOST, PORT), MyTCPHandler) as server: # Activate the server; this will keep running until you # interrupt the program with Ctrl-C server.serve_forever()
這更疑惑, ThreadingTCPServer哪來的構造函數(shù), 后來研究了一下, 原來當子類的某個函數(shù)或是屬性發(fā)生調用時, 如果不是重載了父類的方法或是屬性, 而且子類中沒有這個方法或是屬性, 就會去調用父類相對應的方法或是屬性, 于是上面的就是調用了TCPServer的初始化函數(shù)__init__以及serve_forever(), 隨后調用的是子類的Request_handler函數(shù)
程序結果:


以上這篇基于python socketserver框架全面解析就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
pandas dataframe拼接后index重新排序方式
這篇文章主要介紹了pandas dataframe拼接后index重新排序方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-10-10
Python中ModuleNotFoundError錯誤的問題解決
本文主要介紹了Python中ModuleNotFoundError錯誤的問題解決,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2023-02-02
pytorch MSELoss計算平均的實現(xiàn)方法
這篇文章主要介紹了pytorch MSELoss計算平均的實現(xiàn)方法,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2021-05-05
詳解python中DRF框架的數(shù)據(jù)校驗方式
這篇文章主要為大家詳細介紹了python中DRF框架的數(shù)據(jù)校驗方式,文中的示例代碼講解詳細,具有一定的學習價值,感興趣的小伙伴可以跟隨小編一起了解一下2023-10-10
Python大數(shù)據(jù)之從網頁上爬取數(shù)據(jù)的方法詳解
這篇文章主要介紹了Python大數(shù)據(jù)之從網頁上爬取數(shù)據(jù)的方法,結合實例形式詳細分析了Python爬蟲爬取網頁數(shù)據(jù)的相關操作技巧,需要的朋友可以參考下2019-11-11
Python callable()函數(shù)用法實例分析
這篇文章主要介紹了Python callable()函數(shù)用法,結合實例形式分析了Python callable()函數(shù)的功能、使用方法及相關操作注意事項,需要的朋友可以參考下2018-03-03

