使用std lib的python中的基本Comet

正如GS所说,保持连接打开。

下面是一个示例wsgi应用程序,每秒向客户端发送当前时间:

import time

def application(environ, start_response):
    start_response('200 OK', [('content-type', 'text/plain')])
    while True:
        time.sleep(1.0)
        yield time.ctime() + '\n'

if __name__ == '__main__':
    from wsgiref.simple_server import make_server
    print "Serving on http://localhost:4000..."
    make_server('localhost', 4000, application).serve_forever()

如果我转到浏览器中的URL,我会看到:

Mon Oct 05 12:21:26 2009
Mon Oct 05 12:21:27 2009
Mon Oct 05 12:21:28 2009
Mon Oct 05 12:21:29 2009
Mon Oct 05 12:21:30 2009
(...a new line appears every second...)

这种方法的问题在于,您不能同时保持许多这样的连接处于打开状态。事实上, wsgiref 服务器是单线程的,所以您在任何时候只能打开一个连接。如果这是一个问题,那么您必须使用多线程(如Cherrypy)或非阻塞服务器(如Twisted、Tornado等)。

这是可能的。只是不要关闭与客户机的连接。

扩展Lost理论所说的,如果您想使用Comet在客户机之间传递消息,那么您需要实现pubsub之类的东西。

对pubsub使用类似tornado的方法要比单线程wsgiref服务器简单得多。