twisted-异步网络

from twisted.internet import reactor, defer, protocol



class CallbackAndDisconnectProtocol(protocol.Protocol):

    def connectionMade(self):

        self.factory.deferred.callback("Connected!")

        self.transport.loseConnection( )



class ConnectionTestFactory(protocol.ClientFactory):

    protocol = CallbackAndDisconnectProtocol



    def _ _init_ _(self):

        self.deferred = defer.Deferred( )



    def clientConnectionFailed(self, connector, reason):

        self.deferred.errback(reason)



def testConnect(host, port):

    testFactory = ConnectionTestFactory( )

    reactor.connectTCP(host, port, testFactory)

    return testFactory.deferred



def handleSuccess(result, port):

    print "Connected to port %i" % port

    reactor.stop( )



def handleFailure(failure, port):

    print "Error connecting to port %i: %s" % (

        port, failure.getErrorMessage( ))

    reactor.stop( )



if __name__ == "_ _main_ _":

    import sys

    if not len(sys.argv) == 3:

        print "Usage: connectiontest.py host port"

        sys.exit(1)



    host = sys.argv[1]

    port = int(sys.argv[2])

    connecting = testConnect(host, port)

    connecting.addCallback(handleSuccess, port)

    connecting.addErrback(handleFailure, port)

    reactor.run( )

 

 

E:\test>python test.py www.hao123.com 80
Connected to port 80