31.用python中的serial向串口發送和接收數據（案例一）

代碼功能說明：1.向串口助手發送十六進制數據：0X01,0X03,0X00,0X00,0X00,0X01,0X84,0X0A；

　　　　　　　2.用串口助手向代碼發送數據，並將發送過來的數據保存在數據庫中，按數據和保存數據形式保存到數據庫中。

代碼如下：

 

import serial,pymysql,threading,time
x=serial.Serial('com1',9600,timeout=1)
def faSong():   # 發送函數
    while True: # 循環發送數據
        time.sleep(3)   # 設置發送間隔時間
        myinput=bytes([0X01,0X03,0X00,0X00,0X00,0X01,0X84,0X0A])    # 需要發送的十六進制數據
        x.write(myinput)    # 用write函數向串口發送數據

def jieShou():  # 接收函數
    while True: # 循環接收數據
        while x.inWaiting()>0:  # 當接收緩沖區中的數據不為零時，執行下面的代碼
            myout=x.read(7) # 提取接收緩沖區中的前7個字節數
            print(myout.decode('gbk'))
            # 以下是用到三目運算符、map函數和lambda函數，
            # 代碼作用是將接收到的數據每一個轉換成十六進制，中間用/x分割，便於后面分割
            datas=''.join(map(lambda x:('/x' if len(hex(x))>=4 else '/x0')+hex(x)[2:],myout))
            print(datas)
            new_datas=datas[2:].split('/x') # 由於datas變量中的數據前兩個是/x，所以用到切片工具
            need=''.join(new_datas) # 將前面的列表中的數據連接起來
            saveSql(need)

def saveSql(a):  # 保存接收的數據
    # time.time返回當前時間的時間戳,即1234892919.655932這種類型
    sql = "INSERT INTO VOC_DATA(value,create_time) VALUES (" + str(a) + "," + str(int(time.time())) + ")"
    cursor.execute(sql)
    db.commit()
    x.flushInput()

if __name__ == '__main__':
    # 打開數據庫連接
    db=pymysql.connect(host='localhost', user='root', password='root',
                 database='xwl_test', port=3306, )
    # 使用sursor()方法創建一個游標對象cursor
    cursor=db.cursor()
    t1=threading.Thread(target=jieShou)　　# 創建一個線程1：不斷的去請求數據
    t2=threading.Thread(target=faSong)　　# 創建一個線程2：不斷的去發送數據
    t2.start()　　# 開啟線程2
    t1.start()　　# 開啟線程1

 

完成上面代碼后運行：

 

 

 

 

 

 以上就完成了本代碼的運行操作。

如有問題，可關注微信公眾號進行咨詢！