python 初次使用twisted

twisted_check_tcp_port.py
#!/usr/bin/env python
from twisted.internet import reactor, protocol
import sys
class PortCheckerProtocol(protocol.Protocol):
        def __init__(self):
                print "Created a new protocol"
        def connectionMade(self):
                print "Connection made"
                reactor.stop()
class PortCheckerClientFactory(protocol.ClientFactory):
        protocol = PortCheckerProtocol
        def clientConnectionFailed(self, connector, reason):
                print "Connection failed because", reason
                reactor.stop()
if __name__ == '__main__':
        host, port = sys.argv[1].split(':')
        factory = PortCheckerClientFactory()
        print "Testing %s" % sys.argv[1]
        reactor.connectTCP(host, int(port), factory)
        reactor.run()

twisted_perspectiv_broker.py
#!/usr/bin/env python
import os
from twisted.spread import pb
from twisted.internet import reactor
class PBDirLister(pb.Root):
        def remote_ls(self, directory):
                try:
                        return os.listdir(directory)
                except OSError:
                        return []
        def remote_ls_boom(self, directory):
                return os.listdir(directory)
if __name__ == '__main__':
        reactor.listenTCP(9876, pb.PBServerFactory(PBDirLister()))
        reactor.run()

twisted_perspectiv_broker_client.py
#!/usr/bin/python env
from twisted.spread import pb
from twisted.internet import reactor
def handle_err(reason):
        print "an error occurred", reason
        reactor,stop()
def call_ls(def_call_obj):
        return def_call_obj.callRemote('ls', '/usr')
def print_ls(print_result):
        print print_result
        reactor.stop()
if __name__ == '__main__':
        factory = pb.PBClientFactory()
        reactor.connectTCP('localhost', 9876, factory)
        d = factory.getRootObject()
        d.addCallback(call_ls)
        d.addCallback(print_ls)
        d.addErrback(handle_err)
        reactor.run()