Twisted / Amp 网络：响应所有客户，而不仅仅是一个发出请求的客户

Question

我正在尝试了解这些新奇的“工厂”风格网络库。 Twisted 广受好评，但对我来说绝对是一场噩梦，因为我不熟悉 lambda，因此我真的不知道如何遵循演示代码的操作。

演示客户端：

from twisted.internet import reactor, defer
from twisted.internet.protocol import ClientCreator
from twisted.protocols import amp
from ampserver import Sum, Divide


def doMath():
    d1 = ClientCreator(reactor, amp.AMP).connectTCP(
        '127.0.0.1', 1234).addCallback(
            lambda p: p.callRemote(Sum, a=13, b=81)).addCallback(
                lambda result: result['total'])
    def trapZero(result):
        result.trap(ZeroDivisionError)
        print "Divided by zero: returning INF"
        return 1e1000
    d2 = ClientCreator(reactor, amp.AMP).connectTCP(
        '127.0.0.1', 1234).addCallback(
            lambda p: p.callRemote(Divide, numerator=1234,
                                   denominator=0)).addErrback(trapZero)
    def done(result):
        print 'Done with math:', result
    defer.DeferredList([d1, d2]).addCallback(done)

if __name__ == '__main__':
    doMath()
    reactor.run()

演示服务器：

from twisted.protocols import amp

class Sum(amp.Command):
    arguments = [('a', amp.Integer()),
                 ('b', amp.Integer())]
    response = [('total', amp.Integer())]


class Divide(amp.Command):
    arguments = [('numerator', amp.Integer()),
                 ('denominator', amp.Integer())]
    response = [('result', amp.Float())]
    errors = {ZeroDivisionError: 'ZERO_DIVISION'}


class Math(amp.AMP):
    def sum(self, a, b):
        total = a + b
        print 'Did a sum: %d + %d = %d' % (a, b, total)
        return {'total': total}
    Sum.responder(sum)

    def divide(self, numerator, denominator):
        result = float(numerator) / denominator
        print 'Divided: %d / %d = %f' % (numerator, denominator, result)
        return {'result': result}
    Divide.responder(divide)


def main():
    from twisted.internet import reactor
    from twisted.internet.protocol import Factory
    pf = Factory()
    pf.protocol = Math
    reactor.listenTCP(1234, pf)
    print 'started'
    reactor.run()

if __name__ == '__main__':
    main()

据我了解，客户端p.callRemote(Sum, a=13, b=81) 和p.callRemote(Divide, numerator=1234, denominator=0) 部分调用Math.sum(13, 81) 和Math.Divide(1234, 0)，因为工厂对象的protocol 设置为Math 类。不知何故，当客户端收到来自服务器的返回值时，子函数Done(result)被调用，将内容打印到屏幕上。

这很好，但是我的理解力很差，而且每篇文档似乎都已经期望达到这种理解水平了。

我真正想做的是将数据从客户端发送到服务器，然后从服务器发送到连接的多个客户端。此方法似乎在交换结束后立即忘记客户端，reactor.run() 阻塞客户端，阻止其执行任何其他工作。

人们可能每天都希望使用此功能。我怎么理解这个？

编辑：我尝试为客户端调用“签入”功能，但这似乎会使我的服务器淹没在请求中，只是为了响应“没有报告”。此外，它增加了延迟，因为客户端仅在他们请求时才收到新数据，而不是在它实际可用时。工厂 - 反应器布局似乎没有暴露我需要存储的客户信息以便任意响应它们。

Answer 1

你似乎有三个问题：

1. “lambda 在 Python 中是什么意思？”

   这是covered by Python's documentation。如果您仍然难以阅读以这种方式编写的代码，您可以使用 lambda x: y 只是编写 def my_function(x): return y 的快捷方式这一事实。任何你看到lambda的地方，例如，这个：

   def foo(bar):
       return boz().addCallback(lambda result: qux(bar, result))
   

   您可以随时将lambda 提取到它自己的函数中，以便您阅读，如下所示：

   def foo(bar):
       def callback_for_boz(result):
           return qux(bar, result)
       return boz().addCallback(callback_for_boz)
   

2. “How do I make input on one connection result in output on another?”

   这是documented by Twisted's FAQ。

3. “How do I make Twisted talk to multiple clients / connect to multiple servers?”

   这是also a twisted FAQ。这里的总体思路是reactor.run() 的意思是“……然后运行整个程序”。在reactor.run() 之前运行任何代码的唯一原因是设置初始计时器、侦听套接字或第一个连接。您可以调用connectTCP 或listenTCP 多次，无论是在您运行反应器之前还是在您程序中稍后发生的任何回调中。