from twisted.internet.protocol import Factory,Protocol
from twisted.internet import reactorclass gameSocket(Protocol):#有新用户连接至服务器def connectionMade(self):print 'New Client'#客户端断开连接def connectionLost(self,reason):print 'Lost Client'#收到客户端发送数据def dataReceived(self, data):print 'Get data:' + str(data)#向该客户端发送数据self.transport.write('bingo!i got your msg:'+ str(data))if __name__=='__main__':f = Factory()f.protocol = gameSocketreactor.listenTCP(5200,f)print 'server started...'reactor.run()

import socket,stackless
sockIndex = 1def connToServer ():global sockIndex#创建一个socket连接到127.0.0.1:5200，并发送内容conn = socket.socket(socket.AF_INET, socket.SOCK_STREAM)conn.connect(("127.0.0.1", 5200))conn.send("hi,I'm NO."+ str(sockIndex))print sockIndexsockIndex = sockIndex + 1while True:#等待服务端返回数据，并输出rev = conn.recv(1024)print 'get server msg:' + str(rev)stackless.schedule()#先来500个并发试试
for i in range(0,500):stackless.tasklet(connToServer)()stackless.run()

from twisted.internet import iocpreactor
iocpreactor.install()

from twisted.internet import epollreactor
epollreactor.install()

import os
if os.name!='nt':from twisted.internet import epollreactorepollreactor.install()
else:from twisted.internet import iocpreactoriocpreactor.install()
from twisted.internet.protocol import Factory,Protocol
from twisted.internet import reactorclass gameSocket(Protocol):#有新用户连接至服务器def connectionMade(self):print 'New Client'#客户端断开连接def connectionLost(self,reason):print 'Lost Client'#收到客户端发送数据def dataReceived(self, data):print 'Get data:' + str(data)#向该客户端发送数据self.transport.write('bingo!i got your msg:'+ str(data))if __name__=='__main__':f = Factory()f.protocol = gameSocketreactor.listenTCP(5200,f)print 'server started...'reactor.run()

#本文由刺鸟原创，欢迎转载，但请保留出处，也欢迎对本文感兴趣的同学多多交流。#