让twister服务器占据主动

Question

我有一个扭曲的服务器，实现了 LineReceiver 协议。 当我调用 sendLine 来响应客户端消息时，它会立即将该行写入客户端，正如人们所期望的那样。

但是假设客户端要求服务器进行冗长的计算。我希望服务器定期向客户端发送进度消息。当服务器主动调用 sendLine 而客户端没有请求任何内容时，它似乎会等待客户端向服务器发送消息，然后再发送任何内容。

如何立即从服务器向客户端发送消息，而不需要客户端明确请求？

Answer 1

如果“立即”是指“当客户端连接时”，请尝试在 LineReceiver 子类的 connectionMade 中调用 sendLine。

Answer 2

如果异步执行计算，请使用延迟。
另一种方式，如果它是在单独的线程中进行一些长计算，由 deferrToThread() 开始，请使用reactor.callFromThread()
（我假设我们不在主循环中进行大量计算 - 这是非常非常错误的:)）
小例子：

def some_long_foo(data_array, protocol):
    def send_msg(msg, protocol):
        # It actually looks petter in classes without pushing protocol here and
        # there
        protocol.transport.write(msg)

    for n, chunk in enumerate(data_array):
        do_something_cool(chunk)
        if n and (n % 10 == 0):
            from twisted.internet import reactor
            # here send_msg will be safely executed in main reactor loop
            reactor.callFromThread(send_msg, '10 more chunks processed',
                                   protocol)

# Somwhere in lineReceived we start long calculation
def cb(result):
    self.transport.write('got result: {}'.format(result))
d = threads.deferToThread(some_long_foo, data_array, self)
d.addCallback(cb)

因此现在我们将通知客户端处理每 10 块数据，然后最终向他发送结果。
代码可能有点不正确，它只是例如

docs

UPD：
只是为了澄清：
错过了 sendLine 部分。一般来说没关系，调用它而不是transport.write()

Answer 3

您可以随时使用 sendLine 发送一行，它应该立即到达，但您可能会遇到与服务器阻塞相关的问题。

对 sendLine 的调用会被延迟，因此，如果您在一堆处理过程中进行调用，则可能会在一段时间内没有执行操作，然后在收到消息时 ，反应器中断处理，接收消息，并在返回处理之前获取发送的排队消息。您应该阅读此处的一些其他答案，并确保您的处理不会阻塞您的主线程。