是什么导致我的 Deferred 触发，除了添加回调、启动反应器并连接端点外什么也没做？

Question

我正在使用 if 语句来决定是否触发 Deferred。然而，它甚至在检查运行之前就已经被解雇了。从输出来看，Deferred 似乎是在运行 reactor.run() 后立即触发的。难道不需要触发回调才能发生这种情况吗？

相关代码片段：

class OutpostBurrowNew(amp.AMP, Protocol):
    protocol = OutpostGopher
    ...
    def rfidTest(self):
        print('Checking for tag - Deferred called: %s' % str(self.defer.called))
        (status,TagType) = MIFAREReader.MFRC522_Request(MIFAREReader.PICC_REQIDL)
        if status == MIFAREReader.MI_OK:
            status,uid = self.verify_card()
            cardid = '-'.join([str(x) for x in uid])
            print('Card detected: %s' % str(cardid))
            self.defer.callback()

def main3():
    ''' main3() is for testing reactor usage of RFID-card reading '''
    burrow = OutpostBurrowNew('client')
    burrow.protocol = OutpostGopher
    burrow.connectEndpoint()  # A deferred is created, set on burrow.defer
    def printerCallback(proto):
        # This gets passed the OutpostGopher protocol
        print('main3.printerCallback() - %s ' % str(time.time()))
    burrow.defer.addCallback(printerCallback)
    looper = LoopingCall(burrow.rfidTest)
    loopdefer = looper.start(1, now=False)
    print('Deferred just created, status: %s' % str(burrow.defer.called))
    reactor.run()

输出：

(env)pi@raspi ~/zenithproject/zenith $ sudo python indev/rfidread_remote.py 
Deferred just created, status: False
Gopher.connectionMade() called.
main3.printerCallback() - 1426884127.26
Checking tag - Deferred called: True
Checking tag - Deferred called: True
Checking tag - Deferred called: True
^CCtrl+C captured, ending read.

Answer 1

注意输出：

...
main3.printerCallback() - 1426884127.26
...

回到您的 main，我们看到 printerCallback 是 burrow.defer 的回调。我们知道它是运行，因为它的输出是打印出来的。所以你应该找出是谁在调用它。一种方法是在 printerCallback 中引发异常，即

def printerCallback(proto):
    print('main3.printerCallback() - %s ' % str(time.time()))
    raise Exception

如果您需要更具体的追踪，您可以使用 inspect 模块。

Answer 2

我发现当一个 Twisted 端点（在本例中是 TCP4ClientEndpoint）连接到另一个端点（这里是 TCP4ServerEndpoint）时，Deferred立即触发连接（即当连接时自动调用 Protocol.connectionMade()）。

这是通过在需要触发 Deferred 之前不建立连接来解决的（或者，我想我可以创建另一个 Deferred 来使用），就像这样：

class OutpostBurrowNew(amp.AMP, Protocol):
    protocol = OutpostGopher
    #...
    def rfidTest(self):
        #print("Checking tag - Deferred called: %s" % str(self.defer.called))
        print('Tag check')
        (status,TagType) = MIFAREReader.MFRC522_Request(MIFAREReader.PICC_REQIDL)
        if status == MIFAREReader.MI_OK:
            # print "Card detected"
            status,uid = self.verifyCard()
            cardid = '-'.join([str(x) for x in uid])
            print('Card detected: %s' % str(cardid))
            #self.defer.callback()
            self.connectEndpoint()

def main3():
    ''' main3() is for testing reactor usage of RFID-card reading '''
    burrow = OutpostBurrowNew('client')
    burrow.protocol = OutpostGopher
    #burrow.connectEndpoint()  # A deferred is created, set on burrow.defer
    looper = LoopingCall(burrow.rfidTest)
    loopdef = looper.start(1, now=False)
    reactor.run()

结果如下：

(env)pi@raspi ~/zenithproject/zenith $ sudo python indev/rfidread_remote.py 
Tag check
Tag check
Card detected: 133-197-223-29-130
Gopher.connectionMade() called.
Tag check
Tag check

是什么导致我的 Deferred 触发，除了添加回调、启动反应器并连接端点外什么也没做？

What is causing my Deferred to fire, having done nothing but add a callback, start the reactor, and connected an endpoint?

python

twisted