1. 監(jiān)測(cè)數(shù)據(jù)采集物聯(lián)網(wǎng)應(yīng)用開(kāi)發(fā)步驟(9.1)

TCP/IP Server開(kāi)發(fā)

新建TCP/IP Server線程類com.zxy.tcp.ServerThread.py

#! python3
# -*- coding: utf-8 -
'''
Created on 2017年05月10日
@author: zxyong 13738196011
'''

import socket,threading,time
from com.zxy.tcp.TcpServer import TcpServer
from com.zxy.z_debug import z_debug

#監(jiān)測(cè)數(shù)據(jù)采集物聯(lián)網(wǎng)應(yīng)用--TCP/IP Server線程
class ServerThread(z_debug):

    attDtTimeOut = 60
    attInput = ""
    attNum = ""
    attPort = 0
    attThreadSize = 500
    
    def __init__(self, temInput, temNum, temPort):
        self.attInput = temInput
        self.attNum = temNum
        self.attPort = temPort
    
    def run(self):
        global dServThreadList        
        try:            
            s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            s.bind(('0.0.0.0', self.attPort))
            s.listen(self.attThreadSize)                               
            while True:
                try:
                    sock, addr = s.accept()
                    ckeys = sock.getpeername()[0] + '|' + str(sock.getpeername()[1])             
                    ts = TcpServer(ckeys)
                    t = threading.Thread(target=ts.server_link, args=(sock, addr), name="ServerClient" + ckeys)
                    t.start()
                except Exception as en:
                    if str(type(self)) == "<class 'type'>":
                        self.debug_in(self,repr(en)+"=>"+str(en.__traceback__.tb_lineno))#打印異常信息
                    else:
                        self.debug_in(repr(en)+"=>"+str(en.__traceback__.tb_lineno))#打印異常信息
                finally:
                    time.sleep(0.1)
        except Exception as e:            
            if str(type(self)) == "<class 'type'>":
                self.debug_in(self,repr(e)+"=>"+str(e.__traceback__.tb_lineno))#打印異常信息
            else:
                self.debug_in(repr(e)+"=>"+str(e.__traceback__.tb_lineno))#打印異常信息
            Pass

新建作為TCP Server接收數(shù)據(jù)攔截器插件類com.plugins.usereflect.testServerReflectInClass1.py

#! python3
# -*- coding: utf-8 -
'''
Created on 2017年05月10日
@author: zxyong 13738196011
'''
from com.zxy.z_debug import z_debug

#監(jiān)測(cè)數(shù)據(jù)采集物聯(lián)網(wǎng)應(yīng)用--作為TCP Server接收數(shù)據(jù)攔截器插件,可做設(shè)備反控操作程序
class testServerReflectInClass1(z_debug):
    #接收到數(shù)據(jù)
    strResult        = ""
    #需要發(fā)送到客戶端數(shù)據(jù)
    strSend          = ""
    #是否繼續(xù)執(zhí)行 1:繼續(xù)執(zhí)行 0:中斷執(zhí)行
    strContinue      = "1"     
    #所連接的遠(yuǎn)端IP
    strIP            = ""
    #端口號(hào)            
    strPort          = ""
    
    def __init__(self, params):
        pass
    
    def init_start(self):
        #作為服務(wù)端接收數(shù)據(jù)攔截器
        if self.strResult == "001":
            self.strSend = "#send to client data:client"
        print("AAAA作為服務(wù)端接收數(shù)據(jù)攔截器:"+self.strResult)
        self.strResult = "ok"

新建作為TCP Server接收數(shù)據(jù)攔截器插件類com.plugins.usereflect.testServerReflectInClass2.py

#! python3
# -*- coding: utf-8 -
'''
Created on 2017年05月10日
@author: zxyong 13738196011
'''
from com.zxy.z_debug import z_debug

#監(jiān)測(cè)數(shù)據(jù)采集物聯(lián)網(wǎng)應(yīng)用--作為TCP Server接收數(shù)據(jù)攔截器插件,可做設(shè)備反控操作程序
class testServerReflectInClass2(z_debug):
    #接收到數(shù)據(jù)
    strResult        = ""
    #需要發(fā)送到客戶端數(shù)據(jù)
    strSend          = ""
    #是否繼續(xù)執(zhí)行 1:繼續(xù)執(zhí)行 0:中斷執(zhí)行
    strContinue      = "1"     
    #所連接的遠(yuǎn)端IP
    strIP            = ""
    #端口號(hào)            
    strPort          = ""
    
    def __init__(self, params):
        pass
    
    def init_start(self):
        #作為服務(wù)端接收數(shù)據(jù)攔截器
        if self.strResult == "002":
            self.strSend = "#send to client data:client"
        print("BBB作為服務(wù)端接收數(shù)據(jù)攔截器:"+self.strResult)
        self.strResult = "ok"

在com.zxy.main.Init_Page.py中添加代碼

from com.zxy.tcp.ServerThread import ServerThread

    @staticmethod
    def Start_Server():
        st = ServerThread("", "", int(Com_Para.AccSocketPort))
        # TCP服務(wù)端案例
        t2 = threading.Thread(target=st.run, name="ServerMainThread")
        t2.start()

TCP Server測(cè)試案例MonitorDataCmd.py主文件中編寫：

在????if?__name__ == '__main__':下添加

        #TCP Server接收數(shù)據(jù)攔截器插件
        Com_Para.ServerREFLECT_IN_CLASS = "com.plugins.usereflect.testServerReflectInClass1"
        #TCP Server配置端口參數(shù) 
        Com_Para.AccSocketPort = "8099"
        #TCP/IP Server初始化
        Init_Page.Start_Server()
        #暫停120秒,等待client連接
        time.sleep(120)
        #遍歷已經(jīng)連接到本設(shè)備的tcp client并發(fā)送數(shù)據(jù)包
        for key in Com_Para.dServThreadList.keys():
            temSck = Com_Fun.GetHashTableNone(Com_Para.dServThreadList, key)
            temValue = "Server往Client端發(fā)送數(shù)據(jù)包:"+Com_Fun.GetTimeDef()
            Com_Fun.SendSocket(temValue, temSck)
            print("=>"+key+"=>"+temValue)

運(yùn)行測(cè)試結(jié)果如下圖:

監(jiān)測(cè)數(shù)據(jù)采集物聯(lián)網(wǎng)應(yīng)用開(kāi)發(fā)步驟(10)文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-684937.html

到了這里，關(guān)于13、監(jiān)測(cè)數(shù)據(jù)采集物聯(lián)網(wǎng)應(yīng)用開(kāi)發(fā)步驟(9.2)的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！