Tornado和subprocess實現(xiàn)和外部程序通信-創(chuàng)新互聯(lián)

主要涉及subprocess的使用，簡單點(diǎn)，直接上代碼吧，只是做一下記錄。

創(chuàng)新互聯(lián)是一家集網(wǎng)站建設(shè),揚(yáng)中企業(yè)網(wǎng)站建設(shè),揚(yáng)中品牌網(wǎng)站建設(shè),網(wǎng)站定制,揚(yáng)中網(wǎng)站建設(shè)報價,網(wǎng)絡(luò)營銷,網(wǎng)絡(luò)優(yōu)化,揚(yáng)中網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競爭力?？沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時我們時刻保持專業(yè)、時尚、前沿，時刻以成就客戶成長自我，堅持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網(wǎng)站。

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

# 功能：文件上傳、代碼提交、執(zhí)行代碼、停止代碼

# 路由：ip:8000/

# 演示功能：打開上傳文件或者上傳文件的瀏覽器界面，點(diǎn)及上傳或者提交代碼

# 路由：ip:8000/upload

# post上傳文件的接口，將所選的文件中的內(nèi)容轉(zhuǎn)儲到服務(wù)器中的/tmp/new_code.py文件中

# 路由：ip:8000/send

# post提交代碼的接口，代碼作為字符串形式提交

# 路由：ip:8000/run/start

# 啟動服務(wù)器中文件名為new_code.py的代碼文件，新建線程執(zhí)行

# 路由：ip:8000/run/stop

# 停止服務(wù)器中文件名為new_code.py所開啟的線程

# 設(shè)置服務(wù)的端口

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

# 靜態(tài)資源配置

settings = {

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

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

}

# 設(shè)置允許跨域請求的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發(fā)送

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!")

# 發(fā)送代碼字符串的類(帶隱式格式)

class SendHandler(BaseHandler):

# 用URL的get的方式發(fā)送

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("參數(shù)為空!")

# 用form表單或者ajax等的post加密方式發(fā)送

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("參數(shù)為空!")

# 存放線程對象

class G:

p = None

# 執(zhí)行代碼文件的類

class SsHandler(BaseHandler):

def get(self, cmd):

'''

cmd: 接收前端的正則表達(dá)式字符串

'''

print("Command:%s" % cmd)

if cmd == 'start':無錫婦科醫(yī)院排行 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() #獲取子進(jìn)程的狀態(tài)

if poll==0:

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

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

print("程序執(zhí)行完畢!不需要手動結(jié)束!")

elif poll is None:

print("程序正在執(zhí)行!馬上退出...")

# 獲取子進(jìn)程的pid

pid = G.p.pid

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

# 殺死進(jìn)程

G.p.kill()

print("killed.")

else:

print("狀態(tài)碼：{}".format(poll))

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

else:

print("p is nothing")

else:

print("Command is not right!")

print("Done!")

# 沒用

def post(self):

self.write("post-StartHandler")

# 定義路由設(shè)置

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函數(shù)入口

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()

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點(diǎn)與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

分享名稱：Tornado和subprocess實現(xiàn)和外部程序通信-創(chuàng)新互聯(lián)
鏈接分享：http://muchs.cn/article0/dcjhio.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供動態(tài)網(wǎng)站、網(wǎng)站建設(shè)、網(wǎng)站導(dǎo)航、搜索引擎優(yōu)化、網(wǎng)站排名、用戶體驗

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容