python:读串口拿数据websocket发送

之前我在前端读串口拿数据，最近有个需求，需要将读串口的功能放到python里本地测试，然后发给前端，我查到python里用到的是websocket，好像python里读串口要开新线程有阻塞的啥问题，但因为我是web端开发，不太懂python，磕磕绊绊给写出来的，功能是实现了，但是总感觉代码不对劲， 担心长时间开着会不会卡顿哈，我是用vscode写的，我ctrl+c关不掉,必须清掉，清掉后再开启报串口被占用，再重新开启才能跑程序，请教一下python方面的佬帮忙优化一下

img

该回答引用GPTᴼᴾᴱᴺᴬᴵ
你好，根据你提供的代码，我发现有一些问题需要修复。首先，你在主函数main中开启了一个新线程t1来执行readLoop函数，但是这个线程是没有被关闭的，也就是说当你按下Ctrl + C结束程序时，这个线程还在运行，所以需要在程序结束时手动关闭这个线程。其次，asyncio.sleep(random.random() * 1)这句代码中的sleep函数应该是异步的，也就是应该使用await asyncio.sleep(random.random() * 1)来等待一段时间。最后，由于读取串口数据的函数readLine是阻塞的，所以应该使用异步的方式读取串口数据。

下面是我根据你的代码做的修改，建议你可以参考一下：

import asyncio
import random
import serial
import websockets
from threading import Thread

global newValue, oldValue
newValue = 'a'
oldValue = ''

# 读串口
async def readLoop():
    global newValue
    print('开始读串口')
    port = "COM3" # 修改为自己的串口
    bps = 9600
    bytesize = 8
    ser = serial.Serial(port, int(bps), int(bytesize), timeout=-1, parity=serial.PARITY_NONE, stopbits=1)
    while True:
        buffer = await asyncio.to_thread(ser.readline) # 异步读取串口数据
        buffer = buffer.decode().strip()
        print(buffer)
        if buffer == '':
            continue
        if buffer == 'a':
            newValue = 'a'
        elif buffer == 'b':
            newValue = 'b'

# WebSocket 服务器
async def time(websocket, path):
    global newValue, oldValue
    while True:
        if newValue != oldValue:
            await websocket.send(newValue)
            oldValue = newValue
        else:
            await asyncio.sleep(random.random() * 1)

# 主函数
def main():
    t1 = Thread(target=lambda: asyncio.run(readLoop())) # 在新线程中异步执行readLoop函数
    t1.start()
    start_server = websockets.serve(time, "127.0.0.1", 5678)
    print('Websocket 服务器已启动')
    try:
        asyncio.get_event_loop().run_until_complete(start_server)
        asyncio.get_event_loop().run_forever()
    except KeyboardInterrupt:
        print('程序已结束')
        t1.join() # 关闭线程

if __name__ == '__main__':
    main()

你可以将上面的代码保存为一个.py文件，然后在命令行中运行该文件。当你想要结束程序时，按下Ctrl + C即可。