码

import trio
from trio import socket

async def listen(host, port):
   while True:
        fullmsg = ""
        sock = socket.socket()
        await sock.bind((host, port))
        sock.listen()
        print(f'Awaiting Receive On {host}:{port}')
        conn, addr = await sock.accept()
        print(f'Connection Received From {addr[0]}:{addr[1]}')
        while True:
            try:
                msg = await conn.recv(8)
                if len(msg.decode().strip()) > 0:
                    print(f'Received {len(msg.strip())} bytes')
                    fullmsg += msg.decode().strip()
                else:
                    break
            except Exception as e:
                print(f'DEBUG: {e}')
        sock.shutdown(0)
        sock.close()
        print(fullmsg)


# function that runs the listen function:
async def create():
    async with trio.open_nursery() as nursery:
            nursery.start_soon(listen, '127.0.0.1', 6969)


# To run the program
trio.run(create)

我想在每次收到长度为0的消息时或在客户端关闭连接时一遍又一遍地运行该函数，但是当该函数完成第一个while循环的第一次迭代时，它给出OSError表示端口已在正在使用。我在循环结束时关闭并关闭了套接字，但我仍然不知道程序在哪里出错。

程序输出

Awaiting Receive On 127.0.0.1:6969
Connection Received From 127.0.0.1:37122
Received 8 bytes
Received 5 bytes
Hello, World!
Traceback (most recent call last):
  File "./ape.py", line 68, in <module>
    trio.run(create)
  File "/usr/local/lib/python3.8/dist-packages/trio/_core/_run.py", line 1804, in run
    raise runner.main_task_outcome.error
  File "./ape.py", line 59, in create
    nursery.start_soon(listen, '127.0.0.1', 6969)
  File "/usr/local/lib/python3.8/dist-packages/trio/_core/_run.py", line 730, in __aexit__
    raise combined_error_from_nursery
  File "./ape.py", line 15, in listen
    await sock.bind((host, port))
  File "/usr/local/lib/python3.8/dist-packages/trio/_socket.py", line 473, in bind
    return self._sock.bind(address)
OSError: [Errno 98] Address already in use