14

我正在尝试使用 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()
4

2 回答 2

6

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

于 2012-04-28T13:27:22.147 回答
5

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

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

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

于 2012-04-28T15:27:35.397 回答