Python實(shí)現(xiàn)多線程/多進(jìn)程的TCP服務(wù)器
多線程的TCP服務(wù)器,供大家參考,具體內(nèi)容如下
背景:同學(xué)公司的傳感器設(shè)備需要將收集的數(shù)據(jù)發(fā)到服務(wù)器上,前期想寫一個簡單的服務(wù)器來測試下使用效果,設(shè)備收集的數(shù)據(jù)非常的重要,所以考慮使用TCP協(xié)議來實(shí)現(xiàn)。
因?yàn)橹皇菧y試使用,所以采用多線程的方式,畢竟節(jié)省資源嘛(使用協(xié)程時(shí)會導(dǎo)致I/O阻塞)
開門見山,直接搬上來了
一、tcp_server_v1.0使用說明:
1.運(yùn)行環(huán)境:python3解釋器,并安裝socket、threading模塊;
2.該版本使用多線程實(shí)現(xiàn)的多任務(wù);
3.支持多臺設(shè)備同時(shí)連接,并同時(shí)提供服務(wù)。
二、代碼邏輯:
指定服務(wù)器運(yùn)行端口為:8125
創(chuàng)建一個服務(wù)器類
實(shí)例化一個服務(wù)器對象
服務(wù)器對象調(diào)用類中的方法
1 初始化服務(wù)器屬性(def __init__)
1.1 創(chuàng)建套接字
1.2 解決程序端口占用問題
1.3 綁定本地ip地址
1.4 將套接字變?yōu)楸O(jiān)聽套接字,最大連接數(shù)量為100
2 定義設(shè)備連接方法(def run_forever)
2.1 進(jìn)入循環(huán)
2.2 等待設(shè)備連接...
2.2.1 當(dāng)設(shè)備連接,打印設(shè)備的 ip 和 port
2.2.2 創(chuàng)建線程,調(diào)用業(yè)務(wù)處理方法,為該設(shè)備提供服務(wù)
3 業(yè)務(wù)處理方法(def service_machine)
3.1 進(jìn)入循環(huán)
3.2 等待接收設(shè)備發(fā)送數(shù)據(jù)...
3.2.1 當(dāng)服務(wù)器接收到數(shù)據(jù)
3.2.2 判斷數(shù)據(jù)是否為空
否:打印數(shù)據(jù)內(nèi)容,進(jìn)行業(yè)務(wù)處理,將處理后的數(shù)據(jù)結(jié)果返回給設(shè)備
是:打印設(shè)備斷開連接,退出循環(huán),關(guān)閉套接字
代碼實(shí)現(xiàn)如下:
#!C:\Python3.6.5\python.exe # -*- coding: gbk -*- import socket import threading class WSGIServer(object): def __init__(self, port): """初始化對象""" # 創(chuàng)建套接字 self.tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 解決程序端口占用問題 self.tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) # 綁定本地ip地址 self.tcp_server_socket.bind(("", port)) # 將套接字變?yōu)楸O(jiān)聽套接字,最大連接數(shù)量為100 self.tcp_server_socket.listen(100) def run_forever(self): """設(shè)備連接""" while True: # 1.等待設(shè)備連接(通過ip地址和端口建立tcp連接) # 如果有設(shè)備連接,則會生成用于設(shè)備和服務(wù)器通訊的套接字:new_socket # 會獲取到設(shè)備的ip地址和端口 new_socket, client_addr = self.tcp_server_socket.accept() print("設(shè)備{0}已連接".format(client_addr)) # 2.創(chuàng)建線程處理設(shè)備的需求 t1 = threading.Thread(target=self.service_machine, args=(new_socket, client_addr)) t1.start() def service_machine(self, new_socket, client_addr): """業(yè)務(wù)處理""" while True: # 3.接收設(shè)備發(fā)送的數(shù)據(jù),單次最大1024字節(jié),按‘gbk'格式解碼 receive_data = new_socket.recv(1024).decode("gbk") # 4.如果設(shè)備發(fā)送的數(shù)據(jù)不為空 if receive_data: # 4.1 打印接收的數(shù)據(jù),這里可以將設(shè)備發(fā)送的數(shù)據(jù)寫入到文件中 # 獲取設(shè)備的ID信息 print(receive_data) if receive_data[0:6] == "report": response = "SET OK:" + receive_data else: receive_data = receive_data[6:].split(",")[0] # 拼接響應(yīng)數(shù)據(jù) response = "alarm=" + receive_data + ",Switch:clear" print(response) # 4.2 返回原數(shù)據(jù)作為應(yīng)答,按‘utf-8'格式編碼 new_socket.send(response.encode("utf-8")) # 5.當(dāng)設(shè)備斷開連接時(shí),會收到空的字節(jié)數(shù)據(jù),判斷設(shè)備已斷開連接 else: print('設(shè)備{0}斷開連接...'.format(client_addr)) break # 關(guān)閉套接字 new_socket.close() def main(port): """創(chuàng)建一個WEB服務(wù)器""" wsgi_server = WSGIServer(port) print("服務(wù)器已開啟") wsgi_server.run_forever() if __name__ == '__main__': port = 8125 # 指定端口 main(8125)
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
- python 多進(jìn)程和多線程使用詳解
- Python全局鎖中如何合理運(yùn)用多線程(多進(jìn)程)
- python線程安全及多進(jìn)程多線程實(shí)現(xiàn)方法詳解
- python多線程與多進(jìn)程及其區(qū)別詳解
- Python實(shí)現(xiàn)的服務(wù)器示例小結(jié)【單進(jìn)程、多進(jìn)程、多線程、非阻塞式】
- Python中單線程、多線程和多進(jìn)程的效率對比實(shí)驗(yàn)實(shí)例
- Python多線程處理實(shí)例詳解【單進(jìn)程/多進(jìn)程】
- Python并發(fā):多線程與多進(jìn)程的詳解
- Python實(shí)現(xiàn)的多進(jìn)程和多線程功能示例
- Python多線程與多進(jìn)程相關(guān)知識總結(jié)
相關(guān)文章
Python使用Turtle圖形函數(shù)畫圖顏色填充實(shí)例
這篇文章主要介紹了Python使用Turtle圖形函數(shù)畫圖顏色填充實(shí)例,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-08-08python 生成不重復(fù)的隨機(jī)數(shù)的代碼
用的是篩選法,網(wǎng)上有解釋,簡單的說 就是先隨機(jī)生成一串?dāng)?shù)字,之后用下標(biāo)來判斷這些數(shù)字有沒有重復(fù),重復(fù)的就篩去2011-05-05python+pytest接口自動化之token關(guān)聯(lián)登錄的實(shí)現(xiàn)
公司某管理后臺系統(tǒng),登錄后返回token,接著去請求其他接口時(shí)請求頭中都需要加上這個token,否則提示請先登錄,今天通過本文給大家介紹下python+pytest接口自動化之token關(guān)聯(lián)登錄的實(shí)現(xiàn),感興趣的朋友一起看看吧2022-04-04