Python 3.4.2 异步错误答案

【问题标题】：Python 3.4.2 Asyncio BugPython 3.4.2 异步错误
【发布时间】：2014-11-20 04:02:44
【问题描述】：

我在 Debian 7 服务器上的 Python 3.4.2 下遇到了一个奇怪的问题。我正在尝试从客户端读取以检测它们是否断开连接，网络上的大多数示例都使用这种方法，如果您读取响应并且它是空的，则您会中断循环并关闭连接。

然而，恰好在 9 次迭代之后，脚本将在读取行中终止，我什至尝试只在每 10 次迭代时进行读取，然后它会在 90 次迭代后终止。如果我不尝试检测客户端断开连接，脚本将愉快地永远运行而不会出现问题。

原始代码基于此要点的服务器： https://gist.github.com/dbehnke/9627160

任何想法可能导致这种情况？

（脚本已完成，您可以运行它自己查看）

import asyncio
import logging

import json
import time

log = logging.getLogger(__name__)

clients = {}

def accept_client(client_reader, client_writer):
    task = asyncio.Task(handle_client(client_reader, client_writer))
    clients[task] = (client_writer)

    def client_done(task):
        del clients[task]
        client_writer.close()
        log.info("End Connection")

    log.info("New Connection")
    task.add_done_callback(client_done)


@asyncio.coroutine
def handle_client(client_reader, client_writer):
    data = {'result':{'status':'Connection Ready'}}
    postmessage(data,client_writer)
    count = 0
    while True:
        data = (yield from asyncio.wait_for(client_reader.readline(),timeout=1.0))
        if not data: #client disconnected
            break

        data = yield from asyncio.wait_for(test1(),timeout=1.0)
        yield from postmessage(data,client_writer)

        data = yield from asyncio.wait_for(test2(),timeout=1.0)
        yield from postmessage(data,client_writer)

@asyncio.coroutine
def postmessage(data, client_writer):
        mimetype=('text/event-stream')
        response = ('data: {0}\n\n'.format(data).encode('utf-8'))
        client_writer.write(response)
        client_writer.drain()

@asyncio.coroutine
def test1():
        data = {'result':{
                        'test1':{ }
                    }
                }
        data = json.dumps(data)
        return data

@asyncio.coroutine
def test2():
        data = {'result':{ 
                    'test2':{ }
                    }
                }
        data = json.dumps(data)
        return data 

def main():
    loop = asyncio.get_event_loop()
    f = asyncio.start_server(accept_client, host=None, port=2991)
    loop.run_until_complete(f)
    loop.run_forever()

if __name__ == '__main__':
    log = logging.getLogger("")
    formatter = logging.Formatter("%(asctime)s %(levelname)s " +
                                  "[%(module)s:%(lineno)d] %(message)s")
    # log the things
    log.setLevel(logging.DEBUG)
    ch = logging.StreamHandler()
    ch.setLevel(logging.DEBUG)

    ch.setFormatter(formatter)
    log.addHandler(ch)
    main()

【问题讨论】：

你的客户端脚本是什么样的？
客户端是使用 SSE 库的 Web 应用或移动应用。我只需要从此脚本广播而不接收，因此 readline() 调用很快就会用完标头来读取然后超时。我只是在阅读以尝试检测客户端断开连接，如果有一种更清洁的方法来处理这种情况，那就太好了。
根据this question 的更新，您似乎找到了这种行为的原因。这个问题应该结束吗？

标签： python python-3.x python-asyncio

【解决方案1】：

您应该在调试模式下运行程序以检测明显的异步错误。您忘记了代码中不同位置的“yield from”。

https://docs.python.org/dev/library/asyncio-dev.html#debug-mode-of-asyncio

【讨论】：