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