做外贸的网站要多少钱,宜宾seo快速排名,深圳龙华鸿宇大厦网站建设,电子商务网站建设指导书源码将于最后一遍文章给出下载
监测数据采集物联网应用开发步骤(6)
串口(COM)通讯开发
本章节测试使用了 Configure Virtual Serial Port Driver虚拟串口工具和本人自写的串口调试工具#xff0c;请自行baidu下载对应工具 在com.zxy.common.Com_Para.py中添加如下内容
#RS…源码将于最后一遍文章给出下载
监测数据采集物联网应用开发步骤(6)
串口(COM)通讯开发
本章节测试使用了 Configure Virtual Serial Port Driver虚拟串口工具和本人自写的串口调试工具请自行baidu下载对应工具 在com.zxy.common.Com_Para.py中添加如下内容
#RS232串口通讯列表 串口号,波特率,数据位,索引(A,B,C,D区分),多串口分割符;
ComPortList #linux参考/dev/ttyS0,9600,8,0,A;/dev/ttyS1.9600,8,0,B windwows参考:COM1,9600,8,0;COM2,9600,8,2
#串口通讯全局变量hashtable String, seria串口索引---串口对象
htComPort {} 在com.zxy.main.Init_Page.py中添加如下内容 staticmethoddef Start_ComPort():iIndex 0for temComPort in Com_Para.ComPortList.split(;):iIndex iIndex 1temComPortInfo temComPort.split(,) try:if len(temComPortInfo) 5 and Com_Fun.GetHashTableNone(Com_Para.htComPort, temComPortInfo[4]) is None:temCD ComDev(temComPortInfo[0], int(temComPortInfo[1]), int(temComPortInfo[2]), int(temComPortInfo[3]), iIndex)temCD.attPortName temComPortInfo[4]Com_Fun.SetHashTable(Com_Para.htComPort, temComPortInfo[4], temCD)except Exception as e:print(com link error:COMtemComPortInfo[0] repr(e)str(e.__traceback__.tb_lineno))finally:Pass
创建串口设备管理类com.zxy.comport.ComDev.py
#! python3
# -*- coding: utf-8 -Created on 2017年05月10日
author: zxyong 13738196011
import datetime,threading,time,serial
from com.zxy.common.Com_Fun import Com_Fun
from com.zxy.adminlog.UsAdmin_Log import UsAdmin_Log
from com.zxy.common import Com_Para
from com.zxy.z_debug import z_debug#监测数据采集物联网应用--串口设备管理
class ComDev(z_debug): attIndex 0attPort 0attBaudrate 9600attBytesize 8attSerial None#超时时间(秒) 为了验证测试效果将时间设置为10秒attTimeout 10#返回值attReturnValue NoneattPortName #特殊插件处理attProtocol #回发数据attSendValue None#线程锁attLock threading.Lock()def __init__(self, inputPort,inputBaudrate,inputBytesize,inputparity,inputIndex):self.attPort inputPortself.attBaudrate inputBaudrateself.attBytesize inputBytesizetemParity Nif str(inputparity) 0: #无校验temParity Nelif str(inputparity) 1: #偶校验temParity Eelif str(inputparity) 2: #奇校验temParity Oelif str(inputparity) 3:temParity Melif str(inputparity) 4:temParity Sself.attSerial serial.Serial(portself.attPort,baudrateself.attBaudrate,bytesizeself.attBytesize,paritytemParity, stopbits1)self.attSerial.timeout self.attTimeoutself.attIndex inputIndexself.OpenSeriaPort()#打开串口def OpenSeriaPort(self):try: if not self.attSerial.isOpen(): self.attSerial.open()t threading.Thread(targetself.OnDataReceived, nameComPortTh str(self.attIndex))t.start()uL UsAdmin_Log(Com_Para.ApplicationPath,str(ComPortTh str(self.attIndex)))uL.SaveFileDaySub(thread) print(Open ComPortTh str(self.attIndex) COM:str(self.attSerial.port) Com_Fun.GetTimeDef() lenThreads:str(len(threading.enumerate())))return Trueexcept 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))#打印异常信息return Falsefinally:pass#关闭串口def CloseSeriaPort(self):try: if not self.attSerial.isOpen(): self.attSerial.close()return Trueexcept 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))#打印异常信息return Falsefinally:pass#发送数据无返回 def WritePortDataImmed(self,inputByte):try: if not self.attSerial.isOpen(): self.OpenSeriaPort()if self.attSerial.isOpen() and self.attLock.acquire(): self.attReturnValue NonetemNumber self.attSerial.write(inputByte)time.sleep(0.2)self.attLock.release()return temNumberelse:return 0except 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))#打印异常信息return -1#返回值为字节,带结束符 def WritePortDataFlag(self,inputByte,EndFlag):try: if not self.attSerial.isOpen(): self.OpenSeriaPort()if self.attSerial.isOpen() and self.attLock.acquire(): self.attReturnValue NonetemNumber self.attSerial.write(inputByte) starttime datetime.datetime.now() endtime datetime.datetime.now() datetime.timedelta(secondsself.attTimeout)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:starttime datetime.datetime.now()time.sleep(0.2) self.attLock.release()return temNumberexcept 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))#打印异常信息return -1finally:pass#返回值为字节 def WritePortData(self,inputByte):try: if not self.attSerial.isOpen(): self.OpenSeriaPort()if self.attSerial.isOpen() and self.attLock.acquire(): self.attReturnValue NonetemNumber self.attSerial.write(inputByte) starttime datetime.datetime.now() endtime datetime.datetime.now() datetime.timedelta(secondsself.attTimeout)while self.attReturnValue is None and starttime endtime:starttime datetime.datetime.now()time.sleep(0.2) self.attLock.release()return temNumberexcept 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))#打印异常信息return -1finally:pass#接收数据 def OnDataReceived(self):try:while self.attSerial.isOpen():temNum self.attSerial.inWaiting()if temNum 0:if self.attReturnValue is None:self.attReturnValue self.attSerial.read(temNum)else:self.attReturnValue self.attReturnValue self.attSerial.read(temNum)else:time.sleep(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))self.attReturnValue None
串口通讯测试案例MonitorDataCmd.py主文件中编写
在该语句下添加 #串口配置参数Com_Para.ComPortList COM2,9600,8,0,A;COM4,9600,8,2,B#串口连接初始化Init_Page.Start_ComPort()#测试串口数据发送和接收temCP2 Com_Fun.GetHashTable(Com_Para.htComPort,A)#获取串口2对象temCP4 Com_Fun.GetHashTable(Com_Para.htComPort,B)#获取串口4对象temByte1 (AABBCCDDVV).encode(Com_Para.U_CODE) #发送字符串转byte[]temByte2 (11223344KM).encode(Com_Para.U_CODE) #发送字符串转byte[]print(开始发送串口数据)temRec1 temCP2.WritePortData(temByte1)#往串口2发送数据print(串口2发送数据长度:str(temRec1))strRec if temCP2.attReturnValue ! None:strRec temCP2.attReturnValue.decode(Com_Para.U_CODE)#收到串口数据print(串口2收到数据值:strRec)temRec2 temCP4.WritePortData(temByte2)#往串口4发送数据print(串口3发送数据长度:str(temRec2))strRec if temCP4.attReturnValue ! None:strRec temCP4.attReturnValue.decode(Com_Para.U_CODE)#收到串口数据print(串口4收到数据值:strRec)串口调试测试结果 监测数据采集物联网应用开发步骤(8.1)
