station是一个通过客户机和服务器实现跨TCP网络传输Python生成器的协议。
pyf.station的Python项目详细描述
简介:PYF.Station是一种客户端和服务器通过TCP网络传输Python生成器的协议。生成器中的项必须是pyf.transport.packet实例。
需要tgscheduler(生成任务,传递生成器)和twisted。
如果不是i%50:
打印i,item
打印“流的结束…”
client.success(“done”)
reactor.listentcp(8000,factory)
reactor.run()
或者用户定义的类:
=client
def handle廑data(self):
此方法将由flowserver调用
header=self.flow.next()
打印header
对于i,枚举中的项(self.flow):
如果不是i%50:
打印i,item
打印“流程结束…”
self.client.success(“done”)
reactor.listentcp(8000,factory)
reactor.run()
另一个示例,如果您在一个已经线程化的env(如wsgi服务器)中,请执行以下操作:从twisted.internet导入reactor
从pyf.station导入flowserver
从pyf.transport导入packet
header=flow.next()
print header
for i,item in enumerate(flow):
打印i,item
我们向客户端发送消息
客户端消息(packet({'type':'info',
'message':'hello!(%s)“%i}”)
打印“流的结束…”
客户端成功(“完成”)
reactor.listentcp(8000,工厂)
调度程序。添加单个任务(reactor.run,
kw=dict(installsignalhandlers=0),
initialdelay=0)
导入数据包
client=stationclient('127.0.0.1',8000,正确)
def message_handler(message_packet):
消息处理程序)
l(
flow,
header=dict(authtkt=”My False Auth Token:)”,
action=”My廑action'))
这里的值要么是“true”(表示消息传递良好),要么是从服务器返回的数据包。
对于i,枚举中的值(值):
如果不是i%5000:
打印i
需要tgscheduler(生成任务,传递生成器)和twisted。
如果不是i%50:
打印i,item
打印“流的结束…”
client.success(“done”)
reactor.run()
或者用户定义的类:
=client
def handle廑data(self):
此方法将由flowserver调用
header=self.flow.next()
打印header
对于i,枚举中的项(self.flow):
如果不是i%50:
打印i,item
打印“流程结束…”
self.client.success(“done”)
reactor.run()
另一个示例,如果您在一个已经线程化的env(如wsgi服务器)中,请执行以下操作:从twisted.internet导入reactor
从pyf.station导入flowserver
从pyf.transport导入packet
print header
for i,item in enumerate(flow):
打印i,item
我们向客户端发送消息
客户端消息(packet({'type':'info',
'message':'hello!(%s)“%i}”)
打印“流的结束…”
客户端成功(“完成”)
调度程序。添加单个任务(reactor.run,
kw=dict(installsignalhandlers=0),
initialdelay=0)
导入数据包
client=stationclient('127.0.0.1',8000,正确)
def message_handler(message_packet):
消息处理程序)
l(
flow,
header=dict(authtkt=”My False Auth Token:)”,
action=”My廑action'))
这里的值要么是“true”(表示消息传递良好),要么是从服务器返回的数据包。
对于i,枚举中的值(值):
如果不是i%5000:
打印i