Tornado和subprocess实现和外部程序通信

　　主要涉及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()