import serial
import serial.tools.list_ports
 
# 獲取所有串口設(shè)備實(shí)例。

port_list = list(serial.tools.list_ports.comports())
def show_all_com():
    # 如果找到串口設(shè)備，則依次輸出每個(gè)設(shè)備對(duì)應(yīng)的串口號(hào)和描述信息。
    port_list_name = []
    if len(port_list) <= 0:
        print("the serial port can't find!")
    else:
        for itms in port_list:
            print(list(itms)[0], list(itms)[1])
            port_list_name.append(itms.device)

    return port_list_name

import serial
 
# 打開(kāi) COM3，將波特率配置為115200，數(shù)據(jù)位為7，停止位為2，無(wú)校驗(yàn)位，讀超時(shí)時(shí)間為0.5秒。
ser = serial.Serial(port="COM3",
                    baudrate=115200,
                    bytesize=serial.SEVENBITS,
                    parity=serial.PARITY_NONE,
                    stopbits=serial.STOPBITS_TWO,
                    timeout=0.5) 

import serial
from time import sleep
import queue
import time
from datetime import datetime

q = queue.Queue()

class SerialPort:
    def __init__(self, port, buand):
        self.port = serial.Serial(port, buand)
        self.port.close()
        if not self.port.isOpen():
            self.port.open()

    def port_open(self):
        if not self.port.isOpen():
            self.port.open()

    def port_close(self):
        self.port.close()

    #發(fā)送數(shù)據(jù)
    def send_data(self):
        """
        #write() 方法只能發(fā)送 bytes 類型的數(shù)據(jù)，所以需要對(duì)字符串進(jìn)行 encode 編碼。
        # write() 方法執(zhí)行完成后，會(huì)將發(fā)送的字節(jié)數(shù)作為返回值。
        """
        while True:   # 循環(huán)發(fā)送數(shù)據(jù)
            date = datetime.now().strftime('%H:%M:%S.%f')[:-3]
            print("send:", date)
            self.port.write(date.encode())
            time.sleep(1)

    # 讀取數(shù)據(jù)
    def read_data(self):
        """
        #  read()方法默認(rèn)一次讀取一個(gè)字節(jié)，可以通過(guò)傳入?yún)?shù)指定每次讀取的字節(jié)數(shù)；
        read() 方法會(huì)將讀取的內(nèi)容作為返回值，類型為 bytes。
        """
        while True:
            count = self.port.inWaiting()
            if count != 0:
                recv = self.port.read(count)
                self.port.flushInput()
                q.put(recv.decode())
                print("receive:",recv.decode())
            sleep(0.5)

    #解析保存數(shù)據(jù)
    def save_json(self):
        while True:
            if q.empty():
                pass
            else:
                print("隊(duì)列長(zhǎng)度",q.qsize())
                data = q.get()
                print(data)
            sleep(0.1)

from tools.LoRaSerial import SerialPort
import threading
from time import sleep

if __name__=='__main__':
    baunRate = 115200
    serialPort_w = "COM3"
    mSerial_w = SerialPort(serialPort_w, baunRate)
    t1 = threading.Thread(target=mSerial_w.send_data)
    t1.daemon = True
    t1.start()

    while True:
        sleep(10)

from tools.LoRaSerial import SerialPort
import threading
from time import sleep

if __name__=='__main__':
    threads=[]
    baunRate = 115200

    serialPort_r = "COM4"
    mSerial_r = SerialPort(serialPort_r, baunRate)

    t2 = threading.Thread(target=mSerial_r.read_data)
    threads.append(t2)

    t3 = threading.Thread(target=mSerial_r.save_json)
    threads.append(t3)

    for t in threads:
        t.start()

    while True:
        sleep(10)