• 9、监测数据采集物联网应用开发步骤(7)

    源码将于最后一遍文章给出下载

    监测数据采集物联网应用开发步骤(6)

    串口(COM)通讯开发

    本章节测试使用了 Configure Virtual Serial Port Driver虚拟串口工具和本人自写的串口调试工具，请自行baidu下载对应工具

    在com.zxy.common.Com_Para.py中添加如下内容

    1. #RS232串口通讯列表 串口号,波特率,数据位,索引(A,B,C,D区分),多串口分割符;
    2. ComPortList = ""  #linux参考：/dev/ttyS0,9600,8,0,A;/dev/ttyS1.9600,8,0,B windwows参考:COM1,9600,8,0;COM2,9600,8,2
    3. #串口通讯全局变量hashtable 串口索引---串口对象
    4. htComPort = {}

     在com.zxy.main.Init_Page.py中添加如下内容

    1.     @staticmethod
    2.     def Start_ComPort():
    3.         iIndex = 0
    4.         for temComPort in Com_Para.ComPortList.split(";"):
    5.             iIndex = iIndex + 1
    6.             temComPortInfo = temComPort.split(",")   
    7.             try:
    8.                 if len(temComPortInfo) == 5 and Com_Fun.GetHashTableNone(Com_Para.htComPort, temComPortInfo[4]) is None:
    9.                     temCD = ComDev(temComPortInfo[0], int(temComPortInfo[1]), int(temComPortInfo[2]), int(temComPortInfo[3]), iIndex)
    10.                     temCD.attPortName = temComPortInfo[4]
    11.                     Com_Fun.SetHashTable(Com_Para.htComPort, temComPortInfo[4], temCD)
    12.             except Exception as e:
    13.                 print("com link error:COM"+temComPortInfo[0]+"==>"  + repr(e)+"=>"+str(e.__traceback__.tb_lineno))
    14.             finally:
    15.                 Pass

    创建串口设备管理类com.zxy.comport.ComDev.py

    1. #! python3
    2. # -*- coding: utf-8 -
    3. '''
    4. Created on 2017年05月10日
    5. @author: zxyong 13738196011
    6. '''
    7.  
    8. import datetime,threading,time,serial
    9. from com.zxy.common.Com_Fun import Com_Fun
    10. from com.zxy.adminlog.UsAdmin_Log import UsAdmin_Log
    11. from com.zxy.common import Com_Para
    12. from com.zxy.z_debug import z_debug
    13.  
    14. #监测数据采集物联网应用--串口设备管理
    15. class ComDev(z_debug):    
    16.     attIndex    =   0
    17.     attPort     =   0
    18.     attBaudrate =   9600
    19.     attBytesize =   8
    20.     attSerial   =   None
    21.     #超时时间(秒) 为了验证测试效果，将时间设置为10秒
    22.     attTimeout  =   10
    23.     #返回值
    24.     attReturnValue  = None
    25.     attPortName     = ""
    26.     #特殊插件处理
    27.     attProtocol     = ""
    28.     #回发数据
    29.     attSendValue    = None
    30.     #线程锁
    31.     attLock = threading.Lock()
    32.     
    33.     def __init__(self, inputPort,inputBaudrate,inputBytesize,inputparity,inputIndex):
    34.         self.attPort = inputPort
    35.         self.attBaudrate = inputBaudrate
    36.         self.attBytesize = inputBytesize
    37.         temParity =  "N"
    38.         if str(inputparity) == "0":   #无校验
    39.             temParity =  "N"
    40.         elif str(inputparity) == "1": #偶校验
    41.             temParity =  "E"
    42.         elif str(inputparity) == "2": #奇校验
    43.             temParity =  "O"
    44.         elif str(inputparity) == "3":
    45.             temParity =  "M"
    46.         elif str(inputparity) == "4":
    47.             temParity =  "S"
    48.         self.attSerial = serial.Serial(port=self.attPort,baudrate=self.attBaudrate,bytesize=self.attBytesize,parity=temParity, stopbits=1)
    49.         self.attSerial.timeout = self.attTimeout
    50.         self.attIndex = inputIndex
    51.         self.OpenSeriaPort()
    52.     
    53.     #打开串口
    54.     def OpenSeriaPort(self):
    55.         try: 
    56.             if not self.attSerial.isOpen():  
    57.                 self.attSerial.open()
    58.             t = threading.Thread(target=self.OnDataReceived, name="ComPortTh" + str(self.attIndex))
    59.             t.start()
    60.             
    61.             uL = UsAdmin_Log(Com_Para.ApplicationPath,str("ComPortTh" + str(self.attIndex)))
    62.             uL.SaveFileDaySub("thread")      
    63.             print("Open ComPortTh" + str(self.attIndex)+" COM:"+str(self.attSerial.port)+" "+Com_Fun.GetTimeDef()+" lenThreads:"+str(len(threading.enumerate())))
    64.             return True
    65.         except Exception as e:
    66.             if str(type(self)) == "":
    67.                 self.debug_in(self,repr(e)+"=>"+str(e.__traceback__.tb_lineno))#打印异常信息
    68.             else:
    69.                 self.debug_in(repr(e)+"=>"+str(e.__traceback__.tb_lineno))#打印异常信息
    70.             return False
    71.         finally:
    72.             pass
    73.  
    74.     #关闭串口
    75.     def CloseSeriaPort(self):
    76.         try: 
    77.             if not self.attSerial.isOpen():  
    78.                 self.attSerial.close()
    79.             return True
    80.         except Exception as e:
    81.             if str(type(self)) == "":
    82.                 self.debug_in(self,repr(e)+"=>"+str(e.__traceback__.tb_lineno))#打印异常信息
    83.             else:
    84.                 self.debug_in(repr(e)+"=>"+str(e.__traceback__.tb_lineno))#打印异常信息
    85.             return False
    86.         finally:
    87.             pass
    88.     
    89.     #发送数据无返回 
    90.     def WritePortDataImmed(self,inputByte):
    91.         try: 
    92.             if not self.attSerial.isOpen():  
    93.                 self.OpenSeriaPort()
    94.             if self.attSerial.isOpen() and self.attLock.acquire():                    
    95.                 self.attReturnValue = None
    96.                 temNumber = self.attSerial.write(inputByte)
    97.                 time.sleep(0.2)
    98.                 self.attLock.release()
    99.                 return temNumber
    100.             else:
    101.                 return 0
    102.         except Exception as e:
    103.             if str(type(self)) == "":
    104.                 self.debug_in(self,repr(e)+"=>"+str(e.__traceback__.tb_lineno))#打印异常信息
    105.             else:
    106.                 self.debug_in(repr(e)+"=>"+str(e.__traceback__.tb_lineno))#打印异常信息
    107.             return -1
    108.     
    109.     #返回值为字节,带结束符 
    110.     def WritePortDataFlag(self,inputByte,EndFlag):
    111.         try: 
    112.             if not self.attSerial.isOpen():  
    113.                 self.OpenSeriaPort()
    114.             if self.attSerial.isOpen() and self.attLock.acquire():                    
    115.                 self.attReturnValue = None
    116.                 temNumber = self.attSerial.write(inputByte)    
    117.                 starttime = datetime.datetime.now()    
    118.                 endtime = datetime.datetime.now() + datetime.timedelta(seconds=self.attTimeout)
    119.                 while (self.attReturnValue is None or self.attReturnValue[len(self.attReturnValue) - len(EndFlag):len(self.attReturnValue)] != EndFlag.encode(Com_Para.U_CODE)) and starttime <= endtime:
    120.                     starttime = datetime.datetime.now()
    121.                     time.sleep(0.2)                
    122.                 self.attLock.release()
    123.                 return temNumber
    124.         except Exception as e:
    125.             if str(type(self)) == "":
    126.                 self.debug_in(self,repr(e)+"=>"+str(e.__traceback__.tb_lineno))#打印异常信息
    127.             else:
    128.                 self.debug_in(repr(e)+"=>"+str(e.__traceback__.tb_lineno))#打印异常信息
    129.             return -1
    130.         finally:
    131.             pass
    132.     
    133.     #返回值为字节 
    134.     def WritePortData(self,inputByte):
    135.         try: 
    136.             if not self.attSerial.isOpen():  
    137.                 self.OpenSeriaPort()
    138.             if self.attSerial.isOpen() and self.attLock.acquire():                    
    139.                 self.attReturnValue = None
    140.                 temNumber = self.attSerial.write(inputByte)    
    141.                 starttime = datetime.datetime.now()    
    142.                 endtime = datetime.datetime.now() + datetime.timedelta(seconds=self.attTimeout)
    143.                 while self.attReturnValue is None and starttime <= endtime:
    144.                     starttime = datetime.datetime.now()
    145.                     time.sleep(0.2)                
    146.                 self.attLock.release()
    147.                 return temNumber
    148.         except Exception as e:
    149.             if str(type(self)) == "":
    150.                 self.debug_in(self,repr(e)+"=>"+str(e.__traceback__.tb_lineno))#打印异常信息
    151.             else:
    152.                 self.debug_in(repr(e)+"=>"+str(e.__traceback__.tb_lineno))#打印异常信息
    153.             return -1
    154.         finally:
    155.             pass
    156.     
    157.     #接收数据        
    158.     def OnDataReceived(self):
    159.         try:
    160.             while self.attSerial.isOpen():
    161.                 temNum = self.attSerial.inWaiting()
    162.                 if temNum > 0:
    163.                     if self.attReturnValue is None:
    164.                         self.attReturnValue = self.attSerial.read(temNum)
    165.                     else:
    166.                         self.attReturnValue = self.attReturnValue + self.attSerial.read(temNum)
    167.                 else:
    168.                     time.sleep(1)
    169.         except Exception as e:
    170.             if str(type(self)) == "":
    171.                 self.debug_in(self, repr(e)+"=>"+str(e.__traceback__.tb_lineno))
    172.             else:
    173.                 self.debug_in(repr(e)+"=>"+str(e.__traceback__.tb_lineno))
    174.             self.attReturnValue = None

    串口通讯测试案例MonitorDataCmd.py主文件中编写：

    在该语句下添加

    1.        #串口配置参数
    2.         Com_Para.ComPortList = "COM2,9600,8,0,A;COM4,9600,8,2,B"
    3.         #串口连接初始化
    4.         Init_Page.Start_ComPort()
    5.         #测试串口数据发送和接收
    6.         temCP2 = Com_Fun.GetHashTable(Com_Para.htComPort,"A")#获取串口2对象
    7.         temCP4 = Com_Fun.GetHashTable(Com_Para.htComPort,"B")#获取串口4对象
    8.         temByte1 = ("AABBCCDDVV").encode(Com_Para.U_CODE)   #发送字符串转byte[]
    9.         temByte2 = ("11223344KM").encode(Com_Para.U_CODE)   #发送字符串转byte[]
    10.         
    11.         print("开始发送串口数据")
    12.         temRec1 = temCP2.WritePortData(temByte1)#往串口2发送数据
    13.         print("串口2发送数据长度:"+str(temRec1))
    14.         strRec = ""
    15.         if temCP2.attReturnValue != None:
    16.             strRec = temCP2.attReturnValue.decode(Com_Para.U_CODE)#收到串口数据
    17.         print("串口2收到数据值:"+strRec)
    18.  
    19.         temRec2 = temCP4.WritePortData(temByte2)#往串口4发送数据
    20.         print("串口3发送数据长度:"+str(temRec2))
    21.         strRec = ""
    22.         if temCP4.attReturnValue != None:
    23.             strRec = temCP4.attReturnValue.decode(Com_Para.U_CODE)#收到串口数据
    24.         print("串口4收到数据值:"+strRec)

    串口调试测试结果：

    1. 监测数据采集物联网应用开发步骤(8.1)
  • 相关阅读:
    理解『注意力机制』的本质
    Rust Trait简介
    linux/kali2023.1工具集合()
    13 mysql date/time/datetime/year 的数据存储
    详解Al作画算法原理
    八、线程池
    【UDS】ISO14229之0x3E服务
    搭建PyTorch神经网络进行气温预测
    elasticsearch-7.8.0 集群搭建
    v-model实现父子互传数据
  • 原文地址：https://blog.csdn.net/yong427/article/details/132560022