多線程的TCP服務器，供大家參考，具體內容如下
背景：同學公司的傳感器設備需要將收集的數據發到服務器上，前期想寫一個簡單的服務器來測試下使用效果，設備收集的數據非常的重要，所以考慮使用TCP協議來實現。
因為只是測試使用，所以采用多線程的方式，畢竟節省資源嘛（使用協程時會導致I/O阻塞）
開門見山，直接搬上來了
一、tcp_server_v1.0使用說明：
1.運行環境：python3解釋器，并安裝socket、threading模塊；
2.該版本使用多線程實現的多任務；
3.支持多臺設備同時連接，并同時提供服務。
二、代碼邏輯：
指定服務器運行端口為：8125
創建一個服務器類
實例化一個服務器對象
服務器對象調用類中的方法
1 初始化服務器屬性(def __init__)
1.1 創建套接字
1.2 解決程序端口占用問題
1.3 綁定本地ip地址
1.4 將套接字變為監聽套接字，最大連接數量為100
2 定義設備連接方法(def run_forever)
2.1 進入循環
2.2 等待設備連接...
?????2.2.1 當設備連接，打印設備的 ip 和 port
?????2.2.2 創建線程，調用業務處理方法，為該設備提供服務
3 業務處理方法(def service_machine)
3.1 進入循環
3.2 等待接收設備發送數據...?
3.2.1 當服務器接收到數據
3.2.2 判斷數據是否為空
??????????否：打印數據內容，進行業務處理，將處理后的數據結果返回給設備
??????????是：打印設備斷開連接，退出循環，關閉套接字
代碼實現如下：
#!C:\Python3.6.5\python.exe
# -*- coding: gbk -*-
import socket
import threading
class WSGIServer(object):
def __init__(self, port):
"""初始化對象"""
# 創建套接字
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))
# 將套接字變為監聽套接字，最大連接數量為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.創建線程處理設備的需求
t1 = threading.Thread(target=self.service_machine, args=(new_socket, client_addr))
t1.start()
def service_machine(self, new_socket, client_addr):
"""業務處理"""
while True:
# 3.接收設備發送的數據，單次最大1024字節，按‘gbk'格式解碼
receive_data = new_socket.recv(1024).decode("gbk")
# 4.如果設備發送的數據不為空
if receive_data:
# 4.1 打印接收的數據，這里可以將設備發送的數據寫入到文件中
# 獲取設備的ID信息
print(receive_data)
if receive_data[0:6] == "report":
response = "SET OK:" + receive_data
else:
receive_data = receive_data[6:].split(",")[0]
# 拼接響應數據
response = "alarm=" + receive_data + ",Switch:clear"
print(response)
# 4.2 返回原數據作為應答，按‘utf-8'格式編碼
new_socket.send(response.encode("utf-8"))
# 5.當設備斷開連接時，會收到空的字節數據，判斷設備已斷開連接
else:
print('設備{0}斷開連接...'.format(client_addr))
break
# 關閉套接字
new_socket.close()
def main(port):
"""創建一個WEB服務器"""
wsgi_server = WSGIServer(port)
print("服務器已開啟")
wsgi_server.run_forever()
if __name__ == '__main__':
port = 8125 # 指定端口
main(8125)
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
