读取/写入 Popen() 子进程

Question

我正在尝试使用 python subprocess.Popen() 调用与子进程交谈。在我的真实代码中，我正在实现一种 IPC，所以我想写入一些数据、读取响应、写入更多数据、读取响应等等。因此，我不能使用 Popen.communicate()，否则它适用于简单的情况。

这段代码显示了我的问题。它甚至从来没有得到第一个响应，挂在第一个“阅读结果”上。为什么？我怎样才能按预期完成这项工作？

import subprocess
p = subprocess.Popen(["sed", 's/a/x/g'],
                     stdout = subprocess.PIPE,
                     stdin = subprocess.PIPE)

p.stdin.write("abc\n")
print "Reading result:"
print p.stdout.readline()

p.stdin.write("cat\n")
print "Reading result:"
print p.stdout.readline()

Answer 1

sed 的输出被缓冲，仅在累积足够多或输入流耗尽并关闭之前才输出其数据。

试试这个：

import subprocess
p = subprocess.Popen(["sed", 's/a/x/g'],
                     stdout = subprocess.PIPE,
                     stdin = subprocess.PIPE)

p.stdin.write("abc\n")
p.stdin.write("cat\n")
p.stdin.close()

print "Reading result 1:"
print p.stdout.readline()

print "Reading result 2:"
print p.stdout.readline()

请注意，一旦缓冲区已满，写入stdin 的大量数据将无法可靠地完成此操作。最好的方法是使用communicate()。

Answer 2

如果可以的话，我会尝试使用Popen().communicate()，因为它为你做了很多好事，但是如果你需要完全按照你的描述使用Popen()，你需要设置sed来刷新它的缓冲区在带有 -l 选项的换行符之后：

p = subprocess.Popen(['sed', '-l', 's/a/x/g'],
                     stdout=subprocess.PIPE,
                     stdin=subprocess.PIPE)

你的代码应该可以正常工作