我使用Python2.7和zeroRPC使客户机和服务器通信。我希望客户端向服务器发送一个请求,我希望服务器发送一个响应以确认它已收到请求。但是我希望服务器对该请求执行一些繁重的计算。这些计算将花费数小时,并且不会产生任何响应,因此客户机不应该一直等待;客户机-服务器连接应该在服务器确认收到请求后立即终止。我该怎么做?在
这是我现在所拥有的(简化)。在
服务器代码:impor time
import zerorpc
class HelloRPC(object):
def hey(self, name):
print 'Hey, %s' % name # just so I can check that the request was received
# send response confirming that request was received
# terminate connection
time.sleep(100000000000000) # some heavy computations
s = zerorpc.Server(HelloRPC())
s.bind('tcp://0.0.0.0:4242')
s.run()
客户代码:
^{pr2}$
它不起作用:我得到zerorpc.exceptions.LostRemote: Lost remote after 10s heartbeat。我知道我可以使用heartbeat参数使连接无限期地持续,但是正如我所说的,计算将花费数小时并且不会产生任何响应,因此我认为我不应该保持连接的有效性。在
我读过gevent,但是我不知道如何使用它来达到这个目的(它甚至是这个工作的正确工具吗?)。我应该使用Python的多处理包生成子进程还是类似的东西?这种事怎么办?在