0

我正在查看提供扭曲集成的示例 pika（RabbitMQ python 库）。（https://github.com/pika/pika/blob/master/examples/twisted_service.py）

我发现自己对服务（twisted.application.service.Service）和扭曲的协议/工厂之间的关系感到困惑。大多数扭曲的文档和示例实际上只谈论协议和工厂，这无济于事。

是否有我遗漏的概述显示每个实体之间的关系？

具体来说，在这种情况下我试图回答的问题与示例中的以下代码有关：

class TestService(service.Service):

    def __init__(self):
        super().__init__()
        self.amqp = None

    def task(self, _msg): # pylint: disable=R0201
        """
        Method for a time consuming task.
        This function must return a deferred. If it is successfull,
        a `basic.ack` will be sent to AMQP. If the task was not completed a
        `basic.nack` will be sent. In this example it will always return
        successfully after a 2 second pause.
        """
        return task.deferLater(reactor, 2, lambda: log.msg("task completed"))

     def startService(self):
        amqp_service = self.parent.getServiceNamed("amqp") # pylint: disable=E1111,E1121
        self.amqp = amqp_service.getFactory()
        self.amqp.read_messages("foobar", "task", self.task)

这里amqp_service是一个单独的服务（在完整示例中显示），它有自己的协议和协议工厂。当请求进来时amqp.read_messages触发回调。self.task

  1. 我对协议工厂的理解是，协议的副本本质上是为每个连接/客户端创建的。这个对吗？

  2. 鉴于此类是服务而不是协议工厂，如何确保self.task安全运行，因为没有先验保证它是可重入的。

  3. 扭曲反应器会触发多次调用self.task，而前一个仍在执行（如在示例中的 deferLater 内等待）？这对显示的代码安全吗？如果self.task包裹着，那会改变吗defer.inlineCallbacks

  4. 有没有办法重写这段代码，这样这不是问题。我希望能够在不更改底层 PikaProtocol、PikaFactory 和 PikaService 类的情况下做到这一点。例如，通过使用 TestFactory 创建第二个 TestProtocol，并通过调用amqp.read_messages.

4

0 回答 0