是否可以从分离的子进程写入输入/读取输出？

Question

我正在尝试通过 Python 模块管理游戏服务器（供玩家加入的服务器，我没有创建游戏）。但是，我注意到，当 Python 脚本停止请求输入（来自 input()）时，服务器停止了。有没有办法解决这个问题？

服务器作为子进程运行： server = subprocess.Popen("D:\Windows\System32\cmd.exe", stdin=subprocess.PIPE, stdout=subprocess.PIPE) 后跟 server.stdin.write 调用以运行服务器 exe 文件

如果在没有标准输出管道的情况下运行，服务器似乎工作正常，但如果可能的话，我仍然需要从它接收输出而不停止它。 对于这个模糊的问题和我缺乏 Python 知识，我深表歉意。

Answer 1

听起来你想做两件事：

• 服务子进程的标准输出。
• 在input 上等待用户输入。

而且你需要同时进行它们，并且几乎是实时的——当你阻止从子进程读取时，用户不能输入任何命令，而当你阻止从用户输入读取时，子进程会挂起管道堵塞。

---

最简单的方法是为每个线程使用一个线程。

没有看到任何代码，很难展示一个好的例子，但是像这样：

def service_proc_stdout(proc):
    while True:
        buf = proc.stdout.read()
        do_proc_stuff(buf)

proc = subprocess.Popen(…)
t = threading.Thread(target=service_proc_stdout, args=(proc,))
t.start()

while True:
    command = input()
    do_command_stuff(command)

---

听起来您的do_command_stuff 正在写信给proc.stdin。这可能行得通，但如果您将输入推入它的速度过快，proc.stdin 可能会阻塞，从而阻止您读取用户输入。如果您需要解决这个问题，只需启动第三个线程：

def service_proc_stdin(q, proc):
    while True:
        msg = q.get()
        proc.stdin.write(msg)

q = queue.Queue()
tstdin = threading.Thread(target=service_proc_stdin, args=(q, proc))
tstdin.start()

...现在，您不再直接调用proc.stdin.write(…)，而是调用q.put(…)。

---

线程不是这里处理并发的唯一方式。例如，您可以使用asyncio 事件循环，或手动selectors 循环围绕非阻塞管道。但这可能是最简单的更改，至少如果您不需要在线程之间共享或传递除了推送到队列的消息之外的任何内容。