python subprocess模塊調用外部exe控制台程序並實時進行交互

前記：sreach all web source，I can‘t find the example for python control external .exe procedure and chat with it Real-time. and now,the good new is I share with you;

Prepare:

1.一個一直能一直運行的exe控制台程序；

它的code如下，需編譯為console程序；

#include <iostream>
#include<windows.h>

int main(int argc, char* argv[])
{
    char xx[233];
    while (1) {
        std::cin >> xx;
        std::cout << xx << std::endl;
    }
    
       
    return 0;
     
}

編譯后運行效果如下；輸入什么回車就返回什么，除非x掉它；

 

 

 

NOW：python code with it;

import subprocess
import time
import threading
import random
import os
def rrun(ojj):
    print("in")
    while True:
        # time.sleep(1)
        fet_t = ojj.stdout.readline().decode("GBK")
        if fet_t:
            print(fet_t)
            if fet_t == 'iin9\r\n':
                exit(0)\\條件終止
\\博客園：戳人痛處      
p= subprocess.Popen("D:\\data\\test\\5.exe",shell=True,stdin=subprocess.PIPE,stdout=subprocess.PIPE)
\\博客園：戳人痛處
rt= threading.Thread(target=rrun,args=(p,))
rt.start()
while True:
    time.sleep(0.5)
    xi=random.randint(0,10)\\博客園:戳人痛處
    print("發送字節數:{}".format(p.stdin.write("iin{}\n".format(xi).encode("GBK"))))
    p.stdin.flush()
    if xi==9:
        print('kill?')
        exit(0)\\條件終止

line 16:創建控制台程序5.exe的子進程並設置參數標准輸入輸出stdin=subprocess.PIPE,stdout=subprocess.PIPE，此參數為開啟流；

line 6:多線程處理接收部分，不為空即打印，windows 有\r\n換行 ！

line 23:remember 轉換多字節和換行；

line 24:對輸入緩沖區進行刷新；

now，運行結果如下；

 ---[優化版本1如下，解決子進程殘留]

1.  "5.exe" code如下

#include <iostream>
#include<windows.h>

int main(int argc, char* argv[])
{
    char xx[233];
    while (1) {
        std::cin >> xx;
        std::cout << "輸入的：" << xx ;
    }
    
       
    return 0;
     
}

運行效果：

 

 

2. python code 如下；

import subprocess
import threading
import os
def rrun(ojj:subprocess.Popen):
    print("in")#崩析：bili
    while True:
        fet_t = ojj.stdout.readline().decode("GBK")
        if fet_t:#戳人痛處
            print(fet_t)
def run():                
    p= subprocess.Popen("D:\\data\\test\\5.exe",shell=True,stdin=subprocess.PIPE,stdout=subprocess.PIPE)
    rt= threading.Thread(target=rrun,args=(p,))
    rt.start()#崩析：bili
    while True:
        xi=input("input:---:")#by:博客園-戳人痛處
        print("發送字節數:{}".format(p.stdin.write("{}\n".format(xi).encode("GBK"))))
        p.stdin.flush()#by:博客園-戳人痛處
        if xi=='9':      #設定的結束子進程的條件
            os.kill(p.pid,1)#結束子進程
            print('kill?')
            break           #退出循環
if __name__=='__main__':
    run()

運行效果如下；