标签:__ web python self db tornado import
import sys import os sys.path.append(os.path.dirname(__file__) + os.sep + '../') import json, datetime from tornado.web import RequestHandler, Application from tornado.ioloop import IOLoop from tornado.httpserver import HTTPServer from tornado.options import options from tornado.concurrent import run_on_executor from concurrent.futures import ThreadPoolExecutor import tornado.gen import uuid from redis import Redisredis_db =8 #你redis的db是哪个 conn =Redis(db=redis_db)
#Test class Test(RequestHandler): executor = ThreadPoolExecutor(200) #200连接数 @run_on_executor #并发 def post(self): print(self.request.body) if not self.request.body: return self.write(json.dumps({"status": 1, "message": "no postdata"})) from_data = json.loads(self.request.body) #获取postdata
#HealthCheck class HealthCheck(tornado.web.RequestHandler): @tornado.gen.coroutine def get(self, *args, **kwargs): self.write((json.dumps({"health_check": "Success"})))
class TornadoServer: def handle(self): options.parse_command_line() # 创建一个项目应用,接入web服务器 app = Application([ (r"/health_check", HealthCheck), # 测试 (r"/test", Test), # 获取代理 ], settings={ } ) print('%s--tornado服务启动' % datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')) # 开始监听端口,提供服务 http_server = HTTPServer(app) http_server.bind((8888)) #生成端口 http_server.start() # 默认参数1 启动一个进程 # start(num) num<=0 按照当前os cpu核心数量 进行 进程启动 fork # num>1 表示通过fork 启动多个子进程 # 在启动IOLoop之前通过start函数设置进程数量,如果设置为0表示每个CPU都启动一个进程。 IOLoop.current().start()
if __name__ == '__main__': TornadoServer().handle()
标签:__,web,python,self,db,tornado,import 来源: https://www.cnblogs.com/jingshibilei/p/16185172.html
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。