Python3 串口两进程同时读写

发布时间：2019-07-23 09:40:11编辑：auto阅读（1425）

通过两个进程分别读写串口，并把发送与接收到的内容记录在blog中，收到q时程序结束并退出

import threading,time
import serial
import string


class SerThread:
    def __init__(self, Port=0):
        #初始化串口、blog文件名称
        self.my_serial = serial.Serial()
        self.my_serial.port=Port
        self.my_serial.baudrate = 9600
        self.my_serial.timeout = 1        
        self.alive = False
        self.waitEnd = None
        fname=time.strftime("%Y%m%d")#blog名称为当前时间
        self.rfname='r'+fname #接收blog名称
        self.sfname='s'+fname #发送blog名称
        self.thread_read= None
        self.thread_send=None      
             

    def waiting(self):
        # 等待event停止标志
        if not self.waitEnd is None:
            self.waitEnd.wait()

    def start(self):
        #开串口以及blog文件 
        self.rfile=open(self.rfname,'w')
        self.sfile=open(self.sfname,'w')
        self.my_serial.open()
             
        if self.my_serial.isOpen():
            self.waitEnd = threading.Event()
            self.alive = True
            
            self.thread_read = threading.Thread(target=self.Reader)
            self.thread_read.setDaemon(True)
            
            self.thread_send=threading.Thread(target=self.Sender)
            self.thread_send.setDaemon(True)
            
            self.thread_read.start()
            self.thread_send.start()
            return True
        else:
            return False

   
    def Reader(self):
        while self.alive:
            try:
                n=self.my_serial.inWaiting()
                data=''
                if n:
                    data= self.my_serial.read(n).decode('utf-8')             
                    print ('recv'+' '+time.strftime("%Y-%m-%d %X")+' '+data.strip())
                    print (time.strftime("%Y-%m-%d %X:")+data.strip(),file=self.rfile)
                    if len(data)==1 and ord(data[len(data)-1])==113: #收到字母q，程序退出
                        break
            except Exception as ex:
                print (ex)
               

        self.waitEnd.set()
        self.alive = False
    
    def Sender(self):
        while self.alive:
            try:
                snddata=input("input data:\n")
                self.my_serial.write(snddata.encode('utf-8'))
                print ('sent'+' '+ time.strftime("%Y-%m-%d %X"))
                print (snddata,file=self.sfile)  
                
            except Exception as ex:
                print (ex)
        
        self.waitEnd.set()
        self.alive = False                   
                
        

    def stop(self):
        self.alive = False
        #self.thread_read.join()
        #self.thread_send.join()
        if self.my_serial.isOpen():
            self.my_serial.close()
        self.rfile.close()
        self.sfile.close()
            

if __name__ == '__main__':    
    
    ser = SerThread('com4')
    try:
        if ser.start():
            ser.waiting()
            ser.stop()
        else:
            pass;            
    except Exception as ex:
        print (ex)

    if ser.alive:
        ser.stop()

    print ('End OK .');
    del ser; 






关键字：