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

背景：同學(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 進入循環(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 進入循環(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)容，進行業(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)
          

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。