這篇文章主要介紹“Node與Python雙向通信如何實(shí)現(xiàn)”,在日常操作中,相信很多人在Node與Python雙向通信如何實(shí)現(xiàn)問(wèn)題上存在疑惑,小編查閱了各式資料,整理出簡(jiǎn)單好用的操作方法,希望對(duì)大家解答”Node與Python雙向通信如何實(shí)現(xiàn)”的疑惑有所幫助!接下來(lái),請(qǐng)跟著小編一起來(lái)學(xué)習(xí)吧!
成都創(chuàng)新互聯(lián)公司堅(jiān)持“要么做到,要么別承諾”的工作理念,服務(wù)領(lǐng)域包括:成都做網(wǎng)站、成都網(wǎng)站建設(shè)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣等服務(wù),滿足客戶于互聯(lián)網(wǎng)時(shí)代的榆林網(wǎng)站設(shè)計(jì)、移動(dòng)媒體設(shè)計(jì)的需求,幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴!
第三方數(shù)據(jù)供應(yīng)商把數(shù)據(jù)和Python封裝到一起,只能通過(guò)調(diào)用 Python方法來(lái)實(shí)現(xiàn)數(shù)據(jù)查詢,如果可以通過(guò)Node 簡(jiǎn)單封裝下實(shí)現(xiàn) Python 方法調(diào)用可以快速上線并節(jié)省開(kāi)發(fā)成本。
最簡(jiǎn)單粗暴的通信方式是 Nodejs調(diào)用一下 Python 腳本,然后獲取子進(jìn)程的輸出,但是由于每次 Python 啟動(dòng)并加載數(shù)據(jù)包的過(guò)程比較漫長(zhǎng),所以對(duì)該過(guò)程優(yōu)化。
index.py
# 封裝的 Python 包, 體積巨大 from mb import MB # 從數(shù)據(jù)包中查詢 mbe.get("1.0.1.0")
index.js
const { spawn } = require("child_process"); const ls = spawn("python3", ["index.py"]); ls.stdout.on("data", (data) => { console.log(`stdout: ${data}`); }); ls.stderr.on("data", (data) => { console.error(`stderr: ${data}`); }); ls.on("close", (code) => { console.log(`child process exited with code $[code]`); });
通過(guò)child_process.spawn來(lái)派生 Python 子進(jìn)程,監(jiān)聽(tīng) stdout 輸出。上述方式也是官方文檔中的示例,目前該示例存在兩個(gè)問(wèn)題:
Nodejs 沒(méi)有向 Python 發(fā)送數(shù)據(jù)
Nodejs 調(diào)用完畢后,Python 子進(jìn)程會(huì)退出;下次查詢需要再次調(diào)用Python命令進(jìn)行加載文件,查詢數(shù)據(jù);無(wú)法實(shí)現(xiàn)一次內(nèi)存加載,多次使用。
保證一次數(shù)據(jù)加載,多次使用的前提是 Python 進(jìn)程啟動(dòng)后不能退出。Python 進(jìn)程之所以退出是因?yàn)闊o(wú)事可做,所以常見(jiàn)的手段有循環(huán),sleep,監(jiān)聽(tīng)端口,這些手段可以翻譯成同步阻塞任務(wù),同步非阻塞任務(wù),其中代價(jià)最小的就是同步非阻塞任務(wù),然后可以想到 Linux 的 select,epoll,簡(jiǎn)單搜索了下 Python 的 epoll,好像還有原生的包。
index.py - 通過(guò) epoll 監(jiān)聽(tīng) stdin
import sys import fcntl import select from mb import MB import json mbe = MB("./data") # epoll 模型 fd = sys.stdin.fileno() epoll = select.epoll() epoll.register(fd, select.EPOLLIN) try: while True: events = epoll.poll(10) # 同步非阻塞 data = "" for fileno, event in events: data += sys.stdin.readline() # 通過(guò)標(biāo)準(zhǔn)輸入獲取數(shù)據(jù) if data == "" or data == " ": continue items = xxx # 數(shù)處理過(guò)程 for item in items: result = mbe.get(item) sys.stdout.write(json.dumps(result, ensure_ascii=False) +" ") # 寫入到標(biāo)準(zhǔn)輸出 sys.stdout.flush() # 緩沖區(qū)刷新 finally: epoll.unregister(fd) epoll.close()
index.js - 通過(guò) stdin 發(fā)送數(shù)據(jù)
const child_process = require("child_process"); const child = child_process.spawn("python3", ["./base.py"]); let callbacks = [], chunks=Buffer.alloc(0), chunkArr = [], data = "", onwork = false; // buffer 無(wú)法動(dòng)態(tài)擴(kuò)容 child.stdout.on("data", (chunk) => { chunkArr.push(chunk) if (onwork) return; onwork = true; while(chunkArr.length) { chunks = Buffer.concat([chunks, chunkArr.pop()]); const length = chunks.length; let trunkAt = -1; for(const [k, d] of chunks.entries()) { if (d == "0x0a") { // 0a 結(jié)尾 data += chunks.slice(trunkAt+1, trunkAt=k); const cb = callbacks.shift(); cb(null, data === "null" ? null : data ) data = ""; } } if (trunkAt < length) { chunks = chunks.slice(trunkAt+1) } } onwork = false; }) setInterval(() => { if (callbacks.length) child.stdin.write(` `); // Nodejs端的標(biāo)準(zhǔn)輸入輸出沒(méi)有flush方法,只能 hack, 寫入后python無(wú)法及時(shí)獲取到最新 }, 500) exports.getMsg = function getMsg(ip, cb) { callbacks.push(cb) child.stdin.write(`${ip} `); // 把數(shù)據(jù)寫入到子進(jìn)程的標(biāo)準(zhǔn)輸入 }
Python 與 Nodejs 通過(guò) stdio 實(shí)現(xiàn)通信; Python 通過(guò) epoll 監(jiān)聽(tīng) stdin 實(shí)現(xiàn)駐留內(nèi)存,長(zhǎng)時(shí)間運(yùn)行。
Nodejs 把標(biāo)準(zhǔn)輸出作為執(zhí)行結(jié)果,故 Python 端只能把執(zhí)行結(jié)果寫入標(biāo)準(zhǔn)輸出,不能有額外的打印信息
Nodejs 端標(biāo)準(zhǔn)輸入沒(méi)有 flush 方法,所以 Python 端事件觸發(fā)不夠及時(shí),目前通過(guò)在Nodejs端定時(shí)發(fā)送空信息來(lái) hack 實(shí)現(xiàn)
Buffer 沒(méi)法動(dòng)態(tài)擴(kuò)容,沒(méi)有C語(yǔ)言的指針好用,在解析 stdout 時(shí)寫丑
到此,關(guān)于“Node與Python雙向通信如何實(shí)現(xiàn)”的學(xué)習(xí)就結(jié)束了,希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí),快去試試吧!若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí),請(qǐng)繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站,小編會(huì)繼續(xù)努力為大家?guī)?lái)更多實(shí)用的文章!
分享文章:Node與Python雙向通信如何實(shí)現(xiàn)
本文鏈接:http://muchs.cn/article42/isghec.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供靜態(tài)網(wǎng)站、全網(wǎng)營(yíng)銷推廣、云服務(wù)器、網(wǎng)站排名、網(wǎng)站改版、品牌網(wǎng)站設(shè)計(jì)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)