再讲Python不能做游戏后端开发我揍你嗷！​ Twisted——基于事件驱动的Python网络框架

from twisted.internet import defer
from twisted.python import failure
import sys

d = defer.Deferred()  # 定义defer实例
def printSquare(d):  # 正常处理函数
    print("Square of %d is %d" % (d, d * d))

def processError(f):  # 错误处理函数
    print("Error with process ")
d.addCallback(printSquare)  # 添加正常处理的回调函数
d.addErrback(processError)  # 添加错误处理回调函数
# 开始调用defer
if len(sys.argv) > 1 and sys.argv[1] == 'call_error':
    f = failure.Failure(Exception('my Exception'))
    d.errback(f)  # 调用错误处理函数processError
else:
    d.callback(4)  # 调用正常处理函数printSquare(4)

from twisted.internet import defer

d = defer.Deferred()

def printSquare(d):
    print("Square of %d is %d", (d, d * d))
    return d

def processError(f):
    print("error with process")

def printTwice(d):
    print("Twice of %d is %d", (2 * d))
    return d

d.addCallback(printSquare)
d.addErrback(processError)
d.addCallback(printTwice)

d.callback(5)
# Square of %d is %d (5, 25)
# Twice of %d is %d 10

from twisted.internet import reactor, defer

def printSquare(d):
    print("Square of %d is %d" % (d, d * d))
    return d

def printTwice(d):
    print("Twice of %d is %d", (2 * d))
    return d

def makeDefer():
    d = defer.Deferred()
    d.addCallback(printSquare)
    d.addCallback(printTwice)
    reactor.callLater(2, d.callback, 5)  # 配置延时2s调用

makeDefer()
reactor.run()
# Square of 5 is 25
# Twice of %d is %d 10
# 挂起运行

def callLater(delay, callable, *args, **kw):
  pass

from twisted.internet.protocol import Protocol
from twisted.internet.protocol import Factory
from twisted.internet.endpoints import TCP4ServerEndpoint
from twisted.internet import reactor

clients = []  # 保存所有客户端连接
# Protocol的子类
class Spreader(Protocol):
    def __init__(self, factory):
        self.factory = factory

    def connectionMade(self):
        self.factory.numProtocols = self.factory.numProtocols + 1  # 对连接的客户端进行计数
        self.transport.write(
            (u"欢迎来到Spread Site，您是第%d个客户端用户！\n" %
             (self.factory.numProtocols,).encode('utf8')))
        print(f"new connect {self.factory.numProtocols}")
        clients.append(self)  # 将self保存到clients列表中

    def connectionLost(self, reason):
        clients.remove()
        print(f"lost connect: {self.connect_id}")

    def dataReceived(self, data):
        if data == "close":
            self.transport.loseConnection()
            print(f"{self.connect_id} closed")
        else:
            print(f"spreading message from {self.connect_id, self.data}")
            for client in clients:
                if client != self:
                    # 将收到的数据通过Protocol.transport.write()函数分发给除自己以外的所有客户端
                    client.transport.write(data)
# Factory的子类
class SpreadFactory(Factory):
    def __init__(self):
        self.numProtocols = 0  # 将客户端计数器置0

    def buildProtocol(self, addr):
        return Spreader(self)  # 建立Protocol子类的实例

endpoint = TCP4ServerEndpoint(reactor, 8007)  # 定义服务器监听端口
endpoint.listen(SpreadFactory())  # 指定子类实例
reactor.run()  # 挂起运行

from twisted.internet.protocol import Protocol, ClientFactory
from twisted.internet import reactor
import sys
import datetime

class Echo(Protocol):
    def connectionMade(self):
        print("connect to server!")

    def dataReceived(self, data):
        print("got message: ", data.decode('utf8'))
        reactor.callLater(5, self.say_hello)

    def connectionLost(self, reason):
        print("Disconnected from server!")

    def say_hello(self):
        if self.transport.connected:
            self.transport.write(
                (u"hello, I'm %s %s" % (sys.argv[1], datetime.datetime.now())).encode('utf-8'))

class EchoClientFactory(ClientFactory):
    def __init__(self):
        self.protocol = None

    def startedConnecting(self, connector):
        print("Start to connect.")

    def buildProtocol(self, addr):
        self.protocol = Echo()
        return self.protocol

    def clientConnectionLost(self, connector, reason):
        print("Lost Connection. Reason:", reason)

    def clientConnectionFailed(self, connector, reason):
        print("Connection failed. Reason:", reason)

host = "127.0.0.1"
port =8007
factory = EchoClientFactory()
reactor.connectTCP(host, port, factory)
reactor.run()