From de776fd4c7a3516f5f66d5b72146cef7950ead35 Mon Sep 17 00:00:00 2001 From: "lxbpxylps@126.com" Date: Wed, 6 Oct 2021 17:59:54 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E6=88=90=E5=9B=9E=E6=98=BE=E6=9C=8D?= =?UTF-8?q?=E5=8A=A1=E7=AB=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- main.py | 33 +++++++++++++++++++++++++++++++++ 1 file changed, 33 insertions(+) create mode 100644 main.py diff --git a/main.py b/main.py new file mode 100644 index 0000000..43c6564 --- /dev/null +++ b/main.py @@ -0,0 +1,33 @@ +# STM32Player 服务端 + +import asyncio + +from loguru import logger + + +async def handler(reader, writer): + data = await reader.read(100) + message = data.decode('gbk') + addr = writer.get_extra_info('peername') + + logger.info(f"从 {addr!r} 接收：{message!r}") + + logger.info(f"发送：{message!r}") + writer.write(data) + await writer.drain() + + logger.info("关闭连接") + writer.close() + + +async def main(): + server = await asyncio.start_server( + handler, '0.0.0.0', 2333) + + addr = server.sockets[0].getsockname() + logger.info(f"STM32-Player-Server 开始运行：{addr}") + + async with server: + await server.serve_forever() + +asyncio.run(main())