1

我正在尝试了解这些新奇的“工厂”风格网络库。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)and Math.Divide(1234, 0)，因为工厂对象protocol设置为Math类。不知何故，当客户端从服务器接收到返回值时，子函数Done(result)被调用，它将内容打印到屏幕上。

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

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

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

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

4

1 回答 1

1

你似乎有三个问题：

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

    Python 的文档涵盖了这一点。但是，如果您仍然难以阅读以这种方式编写的代码，则可以使用这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. “我如何在一个连接上进行输入导致另一个连接上的输出？ ”

    Twisted 的 FAQ 记录了这一点。

  3. “如何让 Twisted 与多个客户端对话/连接到多个服务器？ ”

    这也是一个扭曲的常见问题解答。这里的一般想法是这reactor.run()意味着“......然后运行整个程序”。您之前运行任何代码的唯一原因reactor.run()是设置初始计时器、侦听套接字或您的第一个连接。您可以在运行反应器之前或在程序中稍后发生的任何回调中调用或任意次数connectTCP。listenTCP

于 2012-10-24T21:37:55.823 回答