使用子进程 PIPE 在 Python 脚本之间发送字符串

我想在我的主 python 程序中使用子进程打开一个 Python 脚本。我希望这两个程序能够在运行时相互聊天，这样我就可以监视从属脚本中的活动，即我需要它们在彼此之间发送字符串。

主程序将具有与此类似的功能，它将与从属脚本进行通信并监视：

Script 1

import subprocess
import pickle
import sys
import time
import os

def communicate(clock_speed, channel_number, frequency):
    p = subprocess.Popen(['C:\\Python27\\pythonw','test.py'], stdin=subprocess.PIPE, stdout=subprocess.PIPE)
    data = pickle.dumps([clock_speed, channel_number, frequency]).replace("\n", "\\()")
    print data
    p.stdin.write("Start\n")
    print p.stdout.read()
    p.stdin.write(data + "\n")
    p.poll()
    print p.stdout.readline()
    print "return:" + p.stdout.readline()
    #p.kill()

if __name__ == '__main__':
    print "GO"
    communicate(clock_speed = 400, channel_number = 0, frequency = 5*1e6)

test.py 脚本看起来与此类似：

Script 2

import ctypes
import pickle
import time
import sys

start = raw_input("")
sys.stdout.write("Ready For Data")
data = raw_input("")
data = pickle.loads(data.replace("\\()", "\n"))
sys.stdout.write(str(data))
###BUNCH OF OTHER STUFF###

我希望这些脚本执行以下操作：

1. 脚本 1 使用 Popen 打开脚本 2
2. 脚本 1 发送字符串“Start\n”
3. 脚本 2 读取该字符串并发送字符串“Ready For Data”
4. 脚本 1 读取该字符串并将腌制后的数据发送到脚本 2
5. 那么无论...

主要问题是如何完成第 2-4 部分。然后两个脚本之间的其余通信应该随之而来。到目前为止，我只能在脚本 2 终止后读取它的字符串。

任何帮助是极大的赞赏。

UPDATE:

脚本 1 必须使用 32 位 Python 运行，而脚本 2 必须使用 64 位 Python 运行。

管道的问题在于，如果您调用读取操作并且没有任何内容可读取，则您的代码将陷入停滞，直到对方写入一些内容供您读取。此外，如果您写入太多，您的下一个写入操作可能会阻塞，直到另一方从管道中读取某些内容并释放它为止。

您可以进行“非阻塞调用”，在这些情况下将返回错误而不是阻塞，但您的应用程序仍然需要明智地处理错误。

无论如何，您需要设置某种protocol。想想 HTTP 或您熟悉的任何其他协议：有请求和响应，当您阅读这两个协议中的任何一个时，协议总是会告诉您是否还有其他内容需要阅读。这样您就可以随时就是否等待更多数据做出明智的决定。

这是一个有效的示例。它之所以有效，是因为有以下协议：

• p1 发送一行，以 '\n' 结尾；
• p2 也做同样的事情；
• p1 发送另一行；
• p2 也做同样的事情；
• 两人都很高兴并退出。

为了向管道（任一侧）写入一行并确保它进入管道，我调用write()进而flush().

为了从管道（任一侧）读取一行，但不能再读取一个字节，从而阻塞我的代码，直到该行准备好且不超过该长度，我使用readline().

您还可以进行其他调用和其他协议，包括现成的协议，但单行协议非常适合简单的事情和像这样的演示。

p1.py:

import subprocess

p = subprocess.Popen(['python', 'p2.py'], stdin=subprocess.PIPE, stdout=subprocess.PIPE)
p.stdin.write("Hello\n")
p.stdin.flush()
print 'got', p.stdout.readline().strip()
p.stdin.write("How are you?\n")
p.stdin.flush()
print 'got', p.stdout.readline().strip()

p2.py:

import sys

data = sys.stdin.readline()
sys.stdout.write("Hm.\n")
sys.stdout.flush()
data = sys.stdin.readline()
sys.stdout.write("Whatever.\n")
sys.stdout.flush()