Tornado和subprocess实现和外部程序通信
admin
2023-07-03 21:25:07
0次

  主要涉及subprocess的使用,简单点,直接上代码吧,只是做一下记录。

  import tornado.ioloop, os, random

  import urllib, time

  import tornado.web

  import tornado.httpserver

  import tornado.options

  import subprocess

  from tornado.options import options, define

  from tornado.web import url, RequestHandler, MissingArgumentError

  from tornado.escape import json_encode

  ##

  # 功能:文件上传、代码提交、执行代码、停止代码

  #

  # 路由:ip:8000/

  # 演示功能:打开上传文件或者上传文件的浏览器界面,点及上传或者提交代码

  # 路由:ip:8000/upload

  # post上传文件的接口,将所选的文件中的内容转储到服务器中的/tmp/new_code.py文件中

  # 路由:ip:8000/send

  # post提交代码的接口,代码作为字符串形式提交

  # 路由:ip:8000/run/start

  # 启动服务器中文件名为new_code.py的代码文件,新建线程执行

  # 路由:ip:8000/run/stop

  # 停止服务器中文件名为new_code.py所开启的线程

  ##

  # 设置服务的端口

  define("port", default=8000, type=int, help="run server on the given port.")

  # 静态资源配置

  settings = {

  "static_path": os.path.join(os.path.dirname(__file__), "static"),

  "template_path": os.path.join(os.path.dirname(__file__), "views"),

  }

  ##

  # 设置允许跨域请求的base类

  class BaseHandler(tornado.web.RequestHandler):

  def set_default_headers(self):

  self.set_header("Access-Control-Allow-Origin", "*");

  self.set_header("Access-Control-Allow-Headers", "*");

  self.set_header("Access-Control-Allow-Methods", "POST, GET, OPTIONS, DELETE"); #请求允许的方法

  self.set_header("Access-Control-Max-Age", "3600");

  #处理OPTIONS请求

  def options(self):

  #返回方法1

  #self.set_status(204)

  #self.finish()

  #返回方法2

  self.write('{"errorCode":"00","errorMessage","success"}')

  ##

  # localhost:8000/ 打开浏览器输入,

  class MainHandler(BaseHandler):

  def get(self):

  self.write('

  self.write('') #

  #

  # 文件上传的类,使用post发送

  class UploadHandler(BaseHandler):

  def get(self):

  # a3_url = self.reverse_url("a3_url")

  # self.write('this is a3' % a3_url)

  self.write("get code:

  ")

  def post(self):

  files = self.request.files["fff"]

  if files:

  pyf = files[0]["body"]

  # pyfname = files[0]["filename"]

  # self.write(pyfname)

  with open("/tmp/new_code.py", 'wb+') as up:

  up.write(pyf)

  self.write("OK")

  else:

  self.write("Error!")

  # 发送代码字符串的类(带隐式格式)

  class SendHandler(BaseHandler):

  # 用URL的get的方式发送

  def get(self):

  code = self.get_argument("code")

  if code:

  with open("/tmp/new_code.py", 'w+') as up:

  up.write(code)

  else:

  self.write("参数为空!")

  # 用form表单或者ajax等的post加密方式发送

  def post(self):

  # URL编码

  code = urllib.parse.quote(self.request.arguments["code"][0].decode("UTF-8"))

  if code:

  # name = str(random.randint(0,1000))+".py"

  with open("/tmp/new_code.py", 'w+') as up:

  # URL解码

  up.write(urllib.parse.unquote(code))

  # 回显到控制台

  with open("/tmp/new_code.py", 'r') as r:

  rs = r.readlines();

  for x in rs:

  print(x, end="")

  else:

  self.write("参数为空!")

  # 存放线程对象

  class G:

  p = None

  ##

  # 执行代码文件的类

  class SsHandler(BaseHandler):

  def get(self, cmd):

  '''

  cmd: 接收前端的正则表达式字符串

  '''

  print("Command:%s" % cmd)

  if cmd == 'start':无锡妇科医院排行 http://www.0510bhyy.com/

  # 将文件名修改

  G.p = subprocess.Popen(["python","/tmp/new_code.py"], shell=False, stdout=subprocess.PIPE, stderr = subprocess.PIPE)

  # this is a test server used to see whether it is running or not

  # print("tornado l_server running at http://localhost:8001/a1")

  print(type(G.p))

  print(G.p)

  # 会阻塞

  # returncode = G.p.wait()

  # print(returncode)

  elif cmd == 'stop':

  if G.p is not None:

  poll = G.p.poll() #获取子进程的状态

  if poll==0:

  # print(G.p.stdout.read())

  # print(G.p.stderr.read())

  print("程序执行完毕!不需要手动结束!")

  elif poll is None:

  print("程序正在执行!马上退出...")

  # 获取子进程的pid

  pid = G.p.pid

  print("pid: {}".format(pid))

  # 杀死进程

  G.p.kill()

  print("killed.")

  else:

  print("状态码:{}".format(poll))

  print("程序异常退出!")

  else:

  print("p is nothing")

  else:

  print("Command is not right!")

  print("Done!")

  # 没用

  def post(self):

  self.write("post-StartHandler")

  # 定义路由设置

  def make_app():

  return tornado.web.Application([

  (r"/", MainHandler),

  # (r"/get", ItcastHandler, {"subject":"sub"}),

  (r"/upload", UploadHandler),

  (r"/send", SendHandler),

  (r"/run/(\w*)", SsHandler),

  (r"/(apple-touch-icon\.png)", tornado.web.StaticFileHandler,

  dict(path=settings['static_path'])),

  ], **settings)

  ##

  # main函数入口

  if __name__ == "__main__":

  tornado.options.parse_command_line()

  app = make_app()

  app.listen(options.port)

  print("tornado server running at http://localhost:8000")

  tornado.ioloop.IOLoop.current().start()


相关内容

热门资讯

空调连续工作多久需要停机休息 空调连续工作的时间取决于多个因素,包括空调的型号、功率、使用环境和维护情况等。一般来说,空调可以连续...
空调哪个符号是除湿的 空调除湿功能通常用一个水滴形状的符号表示。不同品牌和型号的空调遥控器可能会有所差异,但一般来说,除湿...
格力空调多长时间加一次氟利昂 1、一般情况下,空调对氟利昂的使用量是非常小的,所以在空调使用了四年左右的时候再考虑加也没问题。2、...
空调用多长时间需要加氟一次 一般情况下是五年。当出现以下这几种情况时,空调才需要加氟。1、空调的室内机和室外机各有两个接口,当接...
格调生活·C标思享荟:卡萨帝在... 9月12日的郑州龙湖金融岛,夜风轻拂,灯光璀璨。“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑...
品牌价值破千亿、高端份额持续领... 9月12日,“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑州站”在郑州龙湖金融岛举办。2026...
空调主板坏了修800还是换新的 空调主板坏了是修还是换新,需要考虑多个因素,以下是一些建议:1. 维修成本:如果维修费用较低,比如 ...
空调开多久需要休息多长时间 问题:空调开多久需要休息多长时间回答:1、在使用空调的过程中,一般空调开7~8个小时左右需要休息2~...
中央空调多长时间清洗一次 1、一般空调开机前清洗一次即可,空调开机中间时段再清洗一次,空调关机时清洗一次,这样比较合理。2、空...
中央空调氟利昂多久加一次 看空调制热和制冷程度,很多人的观点认为氟利昂必须一年放一次,其实这个观点是错误的,理解上面有点偏差,...