Twisted Services 与协议工厂有什么关系？

如何解决Twisted Services 与协议工厂有什么关系？

我正在查看 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. twisted reactor 是否会触发对 self.task 的多次调用，而前一个调用仍在执行（如示例中的 deferLater 中的等待）？这对显示的代码安全吗？如果 self.task 被 defer.inlineCallbacks

   包裹，那会改变吗？

4. 有没有办法重写这段代码，使这不是问题。我希望能够在不更改底层 PikaProtocol、PikaFactory 和 PikaService 类的情况下执行此操作。例如，通过使用 TestFactory 创建第二个 TestProtocol，并通过调用 amqp.read_messages 时注册的回调触发。