首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

python3 tornado开发TCP服务程序,也是666

上一次利用tornado开发了一个http API服务程序,在centos7.4 64位 2C/4G的服务器上进行了一次,很轻松的rps就到10000每秒,利用pyenv安装pypy后,再次测试能达到17000每秒,C10K不再是一个问题。

突发奇想,看看tornado开发TCP服务器怎样,至于TCPServer的源码可以自己阅读,同样采用了异步的设计架构,速度也是很快(开发快,运行速度也快)

先放代码上来:

class MyServer(TCPServer):

def __init__(self, io_loop=None, **kwargs):

TCPServer.__init__(self, io_loop=io_loop, **kwargs)

@gen.coroutine

def handle_stream(self, stream, address):

print('New Client',address)

while True:

try:

data_h = yield stream.read_bytes(1)

if data_h == b'\xFE':

data = yield stream.read_until(b'\xFE')

print(data)

msg = yield self.do_data(data)

yield stream.write(msg)

except StreamClosedError:

logging.warning("Lost client at host %s", address[0])

break

except Exception as e:

print(e)

设计了一个16进制的传输数据包,每帧数据头尾设定为固定标记

@gen.coroutine

def do_data(self,data):

data=bytearray(data)

if data[0]==0x1:

msg='Hello'

elif data[0]==0x2:

msg='你好'

else:

msg='Hi'

data=bytearray(msg.encode())

data.insert(0,0xfe)

data.append(0xfe)

return data

def main():

server = MyServer()

server.bind(8013, '127.0.0.1', backlog=65535, reuse_port=True)

server.start(0) #多进程模式

在windows环境下,部分特性不支持,需要修改如下:

server.bind(8013, '127.0.0.1', backlog=65535, reuse_port=False)

server.start()

ioloop.IOLoop.instance().start()

是不是看着很简单,tornado已经将tcpserver封装好了,只需要重载handle_stream,根据自己的业务需求,稍作改动,已经个简单的TCP服务器就出来了。

  • 发表于:
  • 原文链接http://kuaibao.qq.com/s/20180103G0J34000?refer=cp_1026
  • 腾讯「腾讯云开发者社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 cloudcommunity@tencent.com 删除。

扫码

添加站长 进交流群

领取专属 10元无门槛券

私享最新 技术干货

扫码加入开发者社群
领券