twisted伺服器端用戶端通信（轉載填坑）

版權聲明：本文可能為部落客原創文章，若标明出處可随便轉載。 https://blog.csdn.net/Jailman/article/details/78974644

伺服器端代碼

# -*- coding:UTF-8 -*-

from time import ctime

from twisted.internet import reactor
from twisted.internet.protocol import Protocol, Factory

PORT = 21567


class TSServProtocol(Protocol):
    def connectionMade(self):
        clnt = self.clnt = self.transport.getPeer().host
        print '...connected from :', clnt

    def dataReceived(self, data):
        self.transport.write('[%s] %s' % (ctime(), data))


factory = Factory()
factory.protocol = TSServProtocol
print 'waiting for connection...'
reactor.listenTCP(PORT, factory)
reactor.run()           

用戶端代碼

# -*- coding:UTF-8 -*-
from twisted.internet import reactor
from twisted.internet.protocol import Protocol, ClientFactory

HOST = 'localhost'
PORT = 21567


class TSClntProtocol(Protocol):
    def sendData(self):
        data = raw_input('> ')
        if data:
            print '...sending %s...' % data
            self.transport.write(data)
        else:
            self.transport.loseConnection()

    def connectionMade(self):
        self.sendData()

    def dataReceived(self, data):
        print data
        self.sendData()


class TSClntFactory(ClientFactory):
    protocol = TSClntProtocol
    clientConnectionLost = clientConnectionFailed = \
        lambda self, connector, reason: reactor.stop()


reactor.connectTCP(HOST, PORT, TSClntFactory())
reactor.run()