我正试图围绕gevent使用的概念来思考。这是来自 gevent 代码存储库的示例。这是一个简单的回声服务器。
from gevent.server import StreamServer
# this handler will be run for each incoming connection in a dedicated greenlet
def echo(socket, address):
print ('New connection from %s:%s' % address)
socket.sendall('Welcome to the echo server! Type quit to exit.\r\n')
# using a makefile because we want to use readline()
fileobj = socket.makefile()
while True:
line = fileobj.readline()
if not line:
print ("client disconnected")
break
if line.strip().lower() == 'quit':
print ("client quit")
break
fileobj.write(line)
fileobj.flush()
print ("echoed %r" % line)
if __name__ == '__main__':
# to make the server use SSL, pass certfile and keyfile arguments to the constructor
server = StreamServer(('0.0.0.0', 6000), echo)
# to start the server asynchronously, use its start() method;
# we use blocking serve_forever() here because we have no other jobs
print ('Starting echo server on port 6000')
server.serve_forever()
这看起来很简单，而且我很有效。但是，正如评论中所说，这serve_forever()是一个阻塞功能。如果我将最后一行更改server.start()为程序将在每行执行一次后停止。我做错了什么，但文档不是很有帮助。
在使用 gevent 实现服务器的文档部分中，它说 usingstart()应该在使用以下代码时为每个新连接生成一个新的 greenlet：
def handle(socket, address):
print 'new connection!'
server = StreamServer(('127.0.0.1', 1234), handle) # creates a new server
server.start() # start accepting new connections
然后在它说The server_forever() method calls start() and then waits until interrupted or until the server is stopped.我应该如何运行服务器以start()使其实际上保持活动状态以捕获第一个连接之后？
还：
start()和 和有什么不一样serve_forever()？- 在什么情况下我应该选择其中之一？
- 使用第一种方法时是否需要调用
gevent.spawn()，gevent.joinall()但不知何故如此明显，以至于它们已被排除在 StreamServer 文档之外？