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

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

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

因?yàn)橹皇菧y(cè)試使用，所以采用多線程的方式，畢竟節(jié)省資源嘛（使用協(xié)程時(shí)會(huì)導(dǎo)致I/O阻塞）

開門見山，直接搬上來了

一、tcp_server_v1.0使用說明：

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

二、代碼邏輯：

指定服務(wù)器運(yùn)行端口為：8125
創(chuàng)建一個(gè)服務(wù)器類
實(shí)例化一個(gè)服務(wù)器對(duì)象
服務(wù)器對(duì)象調(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):
 """初始化對(duì)象"""
 # 創(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è)備連接，則會(huì)生成用于設(shè)備和服務(wù)器通訊的套接字：new_socket
 # 會(huì)獲取到設(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í)，會(huì)收到空的字節(jié)數(shù)據(jù)，判斷設(shè)備已斷開連接
 else:
 print('設(shè)備{0}斷開連接...'.format(client_addr))
 break

 # 關(guān)閉套接字
 new_socket.close()


def main(port):
 """創(chuàng)建一個(gè)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小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

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

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

廣告

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