无法使用与Python 3.5 Asyncio的每个插座连接的异步子进程创建

Question

我正在尝试使用asyncio创建套接字服务器，在此我会在其中ersynchronous收听连接并获取每个连接不断启动消息。howe，我无法正常工作。

这是我的服务器代码：

import asyncio
import socket, sys
from concurrent.futures import ProcessPoolExecutor
def print_output(csock, loop):
    while 1:
        print('gotcha')
        msg = csock.recv(1024)
        if not msg:
            pass
        else:
            print ("Client send: " + msg)

def s_listen(loop):
    while True:
        (csock, adr) = sock.accept()
        print('start another process')
        asyncio.ensure_future(loop.run_in_executor(executor, print_output, csock, loop))
        print('done')
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) #reuse tcp
sock.bind(('', 12345))
sock.listen(5)
executor = ProcessPoolExecutor()
loop = asyncio.get_event_loop()
listener = asyncio.ensure_future(loop.run_in_executor(executor,s_listen,loop))
print('here')

这是我的客户代码

import socket, sys
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(('', 12345))
sock.send(b"Hello I'm Client.rn")

我可以在异步运行的函数" s_listen"，但代码被" print_output"函数阻止。

我是Asyncio的新手，有人可以帮忙吗？谢谢！

Answer 1

asyncio提供了一个基于Coroutine的API，称为流式的API来管理插座客户端和服务器。这是从用户文档中的TCP回波服务器的修改版本：

import asyncio
# Client handler
async def handle_echo(reader, writer):
    while not reader.at_eof():
        data = await reader.read(100)
        message = data.decode().strip()
        print('Client sent: ' + message)
    writer.close()
# Start the server
loop = asyncio.get_event_loop()
coro = asyncio.start_server(handle_echo, '', 12345, loop=loop)
server = loop.run_until_complete(coro)
# Serve requests until Ctrl+C is pressed
print('Serving on {}'.format(server.sockets[0].getsockname()))
try:
    loop.run_forever()
except KeyboardInterrupt:
    pass
# Close the server
server.close()
loop.run_until_complete(server.wait_closed())
loop.close()

您可以使用NetCat客户端测试此示例：

# Client
$ ncat localhost 12345
hello,
world!
# Server
$ python3.5 server.py
Serving on ('0.0.0.0', 12345)
Client sent: hello,
Client sent: world!