from twisted.internet.protocol import Protocolclients = [] # 保存所有客户端连接class Spreader (Protocol):  # 继承Protocol，实现需要重载的方法def __init__(self, factory):self.factory = factorydef connectionMade(self): # 对连接的客户端计数，并保存到clients列表中self.factory.numProtocols = self.factory.numProtocols + 1self.transport.write (("欢迎来到Spread site,你是第%d 个客户端用户！\n" % (self.factory.numProtocols)).encode ('utf8'))print ("新连接: %d" % self.factory.numProtocols)clients.append (self)def connectionLost(self, reason): # 执行反向操作self.factory.numProtocols = self.factory.numProtocols - 1clients.remove (self)print ("关闭连接：%d" % self.factory.numProtocols)def dataReceived(self, data):  # 循环当前clients列表中的所有客户端，将受到的数据，分发给自己之外的所有客户端if data == 'close':  # 如果受到客户端发来的数据‘close’ ，则主动关闭与该客户端的链接
            self.transport.lostConnection ()for client in clients:if client != self:client.transport.write (data)

from twisted.internet.protocol import Factoryfrom twisted.internet.endpoints import TCP4ServerEndpoint
from twisted.internet import reactorclass SpreaderFactory(Factory):def __init__(self):self.numProtocols = 0def buildProtocol(self, addr):return Spreader(self)# 8007是本服务器的监听端口
endpoint = TCP4ServerEndpoint(reactor,8007)
endpoint.listen(SpreaderFactory())reactor.run() # 挂起运行

from twisted.internet.protocol import Protocol, ClientFactoryfrom twisted.internet import reactor
import threading
import fileinput
import time
import sys
import datetimeclass Echo (Protocol):  # Protocol子类，此处进行通信逻辑开发def __init__(self):self.connected = False  # 在函数routine中使用该状态决定是否向服务器发送消息def connectionMade(self):self.connected = Truedef connectionLost(self, reason):self.connected = Falsedef dataReceived(self, data):print (data.decode ('utf8'))class EchoClientFactory (ClientFactory):  # Factory子类，管理链接关系def __init__(self):self.protocol = Nonedef startedConnecting(self, connector):print ("开始链接")def buildProtocol(self, addr):print ('已连接')self.protocol = Echo ()return self.protocoldef clientConnectionLost(self, connector, reason):print ("链接丢失，原因是：", reason)def clientConnectionFailed(self, connector, reason):print ('链接失败，原因是：', reason)bStop = Falsedef routine(factory):   # 每隔5秒向服务器发送消息while not bStop:if factory.protocol and factory.protocol.connected:factory.protocol.transport.write(('hello,i am xx %s' % (datetime.datetime.now())).encode('utf8'))time.sleep(5)host = '127.0.0.1'
port = 8007
factory = EchoClientFactory()
reactor.connectTCP(host,port,factory)
threading.Thread(target=routine,args=(factory,)).start()   # 启动县城运行routine()函数
reactor.run()  # 挂起运行
bStop = True # 通知routine线程退出