python asyncio服务器模块如何获取连接。
时间: 2024-05-11 19:17:08 浏览: 161
要建立连接,可以使用 Python 内置的 asyncio 库来创建一个异步服务器。使用 asyncio 的时候,可以通过 asyncio.create_server() 函数创建一个协程,用于接受来自客户端的连接请求。以下是一个简单的示例代码:
```
import asyncio
async def handle_client(reader, writer):
data = await reader.read(1024)
message = data.decode()
print(f'Received data: {message!r}')
writer.write('Hello from server!'.encode())
await writer.drain()
writer.close()
async def main():
server = await asyncio.create_server(
handle_client, '127.0.0.1', 8080)
async with server:
await server.serve_forever()
asyncio.run(main())
```
在这个示例中,使用`asyncio.create_server()`函数创建了一个 TCP 服务器,它将在`127.0.0.1:8080`上接受连接。
`handle_client()`函数用于处理每个客户端连接。它通过接收来自客户端的数据,然后将它发送回去,以此实现发送和接收操作。
在`main()`函数中,使用`async with server:`在异步上下文管理器中启动服务器。然后使用`await server.serve_forever()`来启动服务器。
阅读全文