Python實現(xiàn)多線程/多進(jìn)程的TCP服務(wù)器-創(chuàng)新互聯(lián)

多線程的TCP服務(wù)器，供大家參考，具體內(nèi)容如下

專注于為中小企業(yè)提供網(wǎng)站建設(shè)、成都網(wǎng)站設(shè)計服務(wù),電腦端+手機端+微信端的三站合一,更高效的管理,為中小企業(yè)永泰免費做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動了1000多家企業(yè)的穩(wěn)健成長，幫助中小企業(yè)通過網(wǎng)站建設(shè)實現(xiàn)規(guī)模擴充和轉(zhuǎn)變。

背景：同學(xué)公司的傳感器設(shè)備需要將收集的數(shù)據(jù)發(fā)到服務(wù)器上，前期想寫一個簡單的服務(wù)器來測試下使用效果，設(shè)備收集的數(shù)據(jù)非常的重要，所以考慮使用TCP協(xié)議來實現(xiàn)。

因為只是測試使用，所以采用多線程的方式，畢竟節(jié)省資源嘛（使用協(xié)程時會導(dǎo)致I/O阻塞）

開門見山，直接搬上來了

一、tcp_server_v1.0使用說明：

1.運行環(huán)境：python3解釋器，并安裝socket、threading模塊；
2.該版本使用多線程實現(xiàn)的多任務(wù)；
3.支持多臺設(shè)備同時連接，并同時提供服務(wù)。

二、代碼邏輯：

指定服務(wù)器運行端口為：8125
創(chuàng)建一個服務(wù)器類
實例化一個服務(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)閉套接字

代碼實現(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è)備斷開連接時，會收到空的字節(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)

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

網(wǎng)站題目：Python實現(xiàn)多線程/多進(jìn)程的TCP服務(wù)器-創(chuàng)新互聯(lián)
網(wǎng)站URL：http://www.muchs.cn/article8/shoop.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供域名注冊、軟件開發(fā)、App開發(fā)、網(wǎng)站制作、網(wǎng)站設(shè)計公司、網(wǎng)站收錄

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容