python串口协议

importserialimportserial.tools.list_portsclassCommunication():
#初始化def__init__(self,com,bps,timeout):
self.port=comself.bps=bpsself.timeout=timeoutglobalRettry:
# 打开串口，并得到串口对象self.main_engine=serial.Serial(self.port,self.bps,timeout=self.timeout)
# 判断是否打开成功if (self.main_engine.is_open):
Ret=TrueexceptExceptionase:
print("---异常---：", e)
# 打印设备基本信息defPrint_Name(self):
print(self.main_engine.name) #设备名字print(self.main_engine.port)#读或者写端口print(self.main_engine.baudrate)#波特率print(self.main_engine.bytesize)#字节大小print(self.main_engine.parity)#校验位print(self.main_engine.stopbits)#停止位print(self.main_engine.timeout)#读超时设置print(self.main_engine.writeTimeout)#写超时print(self.main_engine.xonxoff)#软件流控print(self.main_engine.rtscts)#软件流控print(self.main_engine.dsrdtr)#硬件流控print(self.main_engine.interCharTimeout)#字符间隔超时#打开串口defOpen_Engine(self):
self.main_engine.open()
#关闭串口defClose_Engine(self):
self.main_engine.close()
print(self.main_engine.is_open)  # 检验串口是否打开# 打印可用串口列表@staticmethoddefPrint_Used_Com():
port_list=list(serial.tools.list_ports.comports())
print(port_list)
#接收指定大小的数据#从串口读size个字节。如果指定超时，则可能在超时后返回较少的字节；如果没有指定超时，则会一直等到收完指定的字节数。defRead_Size(self,size):
returnself.main_engine.read(size=size)
#接收一行数据# 使用readline()时应该注意：打开串口时应该指定超时，否则如果串口没有收到新行，则会一直等待。# 如果没有超时，readline会报异常。defRead_Line(self):
returnself.main_engine.readline()
#发数据defSend_data(self,data):
self.main_engine.write(data)
#更多示例# self.main_engine.write(chr(0x06).encode("utf-8"))  # 十六制发送一个数据# print(self.main_engine.read().hex())  #  # 十六进制的读取读一个字节# print(self.main_engine.read())#读一个字节# print(self.main_engine.read(10).decode("gbk"))#读十个字节# print(self.main_engine.readline().decode("gbk"))#读一行# print(self.main_engine.readlines())#读取多行，返回列表，必须匹配超时（timeout)使用# print(self.main_engine.in_waiting)#获取输入缓冲区的剩余字节数# print(self.main_engine.out_waiting)#获取输出缓冲区的字节数# print(self.main_engine.readall())#读取全部字符。#接收数据#一个整型数据占两个字节#一个字符占一个字节defRecive_data(self,way):
# 循环接收数据，此为死循环，可用线程实现print("开始接收数据：")
whileTrue:
try:
# 一个字节一个字节的接收ifself.main_engine.in_waiting:
if(way==0):
foriinrange(self.main_engine.in_waiting):
print("接收ascii数据："+str(self.Read_Size(1)))
data1=self.Read_Size(1).hex()#转为十六进制data2=int(data1,16)#转为十进制print("收到数据十六进制："+data1+"  收到数据十进制："+str(data2))if(way==1):
#整体接收# data = self.main_engine.read(self.main_engine.in_waiting).decode("utf-8")#方式一data=self.main_engine.read_all()#方式二print("接收ascii数据：", data)exceptExceptionase:
print("异常报错：",e)
Communication.Print_Used_Com()
Ret=False#是否创建成功标志Engine1=Communication("com12",115200,0.5)
if (Ret):
Engine1.Recive_data(0)