verdrehter Client-Aufruf von einer Bibliotheksfunktion

Question

Ich versuche, eine Funktion zu implementieren, die als Twisted-Client fungiert. Es heißt Code, über den ich keine Kontrolle habe. Ich habe versucht, so etwas wie (das aus dem pbsimpleclient.py Beispielcode genommen):

# Copyright (c) Twisted Matrix Laboratories. 
# See LICENSE for details. 


from twisted.spread import pb 
from twisted.internet import reactor 
from twisted.python import util 

def remcall(**kw): 
    factory = pb.PBClientFactory() 
    reactor.connectTCP("localhost", 8789, factory) 
    d = factory.getRootObject() 
    # kw here is what's passed in via remcall 
    d.addCallback(lambda object: object.callRemote("echo", kw)) 
    d.addCallback(lambda echo: 'server echoed: '+repr(echo)) 
    d.addErrback(lambda reason: 'error: '+str(reason.value)) 
    d.addCallback(util.println) 
    d.addCallback(lambda _: reactor.stop()) 
    reactor.run() 

Und der Anrufer würde ein Anruf wie machen:

remcall(hello=1, world=2) 
remcall(hi=3, there=4) 

Aber wie Sie schon erraten kann, gibt es eine " twisted.internet.error.ReactorNotRestartable "Fehler.

Was ist der beste Weg, dies zu tun? Ich bin nicht so besorgt um eine Antwort von der Remote-Ende, aber ich sollte wissen, ob es scheitert und warum.

Answer 1

Die Antwort ist zu häkeln.

# Copyright (c) Twisted Matrix Laboratories. 
# See LICENSE for details. 

## Add these two lines 
from crochet import setup, wait_for 
setup() 

from twisted.spread import pb 
from twisted.internet import reactor 
from twisted.python import util 

## Add a wait_for decorator 
@wait_for(timeout=5.0) 
def remcall(**kw): 
    factory = pb.PBClientFactory() 
    reactor.connectTCP("localhost", 8789, factory) 
    d = factory.getRootObject() 
    # kw here is what's passed in via remcall 
    d.addCallback(lambda object: object.callRemote("echo", kw)) 
    d.addCallback(lambda echo: 'server echoed: '+repr(echo)) 
    d.addErrback(lambda reason: 'error: '+str(reason.value)) 
    d.addCallback(util.println) 
## Get rid of the reactor calls, and return d 
# d.addCallback(lambda _: reactor.stop()) 
# reactor.run() 
    return d 

Dann wird der Anrufer ruft nur

remcall(hello=1, world=2) 
remcall(hi=3, there=4) 

und Häkeln des @wait_for Griffe remcall im Inneren des Reaktors Thread ausgeführt wird.

Answer 2

Entfernen Sie reactor.run() von der remcall Funktion und fügen Sie sie am Ende an. Auch entfernen d.addCallback(lambda _: reactor.stop())

def remcall(**kw): 
    factory = pb.PBClientFactory() 
    reactor.connectTCP("localhost", 8789, factory) 
    d = factory.getRootObject() 
    # kw here is what's passed in via remcall 
    d.addCallback(lambda object: object.callRemote("echo", kw)) 
    d.addCallback(lambda echo: 'server echoed: '+repr(echo)) 
    d.addErrback(lambda reason: 'error: '+str(reason.value)) 
    d.addCallback(util.println) 


remcall(hello=1, world=2) 
remcall(hi=3, there=3) 
reactor.run() # this should be the last thing to run 

Der Reaktor kann nur einmal ausgeführt werden. reactor.stop() Funktion wird ausgeführt und es sollte nicht, es sei denn, Ihre Anwendung muss nicht mehr vollständig ausgeführt werden. Aus diesem Grund erhalten Sie die Ausnahme ReactorNotRestartable.