如何使用Python Paramiko在单个SSH连接中同时运行守护进程与客户端

你用普通exec_command()调用没法实现需求的本质是：Paramiko的exec_command每次调用都会独立fork一个SSH通道执行命令，前后两次调用的会话上下文完全隔离，先启动的守护进程和后启动的客户端根本不在同一个shell进程空间里，自然没法完成本地交互。

全程使用同一个持久化交互式伪终端（PTY）通道完成所有操作，不要拆分多次调用exec_command，实现步骤如下：

• 第一步：建立SSH连接后，调用invoke_shell()申请持久化交互会话，设置合理的终端参数、缓冲区大小和超时时间
• 第二步：在该PTY会话中先启动守护进程，启动时自定义一个就绪标识字符串，读到该标识就证明守护进程已经正常启动、等待请求
• 第三步：在同一会话中启动客户端应用，后续逐次发送1、2、3等输入内容，每次发送后持续读取会话输出，匹配到守护进程的响应结束标识后，再发送下一条输入
• 第四步：所有操作完成后，依次关闭客户端、守护进程，最后关闭PTY通道和SSH连接

import paramiko
import time

# 初始化SSH连接
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(hostname="你的服务器地址", port=22, username="登录用户名", password="登录密码")

# 申请持久化交互式PTY会话，所有操作都在这个通道里完成
channel = ssh.invoke_shell(term="vt100", width=80, height=24, timeout=10)
channel.settimeout(2)

def read_channel_output(stop_mark=None, read_wait=0.5):
    """读取通道输出，读到指定停止标记就返回，避免死等阻塞"""
    output = ""
    while True:
        time.sleep(read_wait)
        if channel.recv_ready():
            chunk = channel.recv(4096).decode("utf-8", errors="ignore")
            output += chunk
            if stop_mark and stop_mark in output:
                break
        else:
            if stop_mark is None:
                break
    return output

# 1. 启动守护进程，示例中用自定义的DAEMON_READY作为就绪标记
# 如果守护进程本身不打印就绪标识，可以用命令格式 ./your_daemon & sleep 1 && echo "DAEMON_READY" && fg
channel.send("cd /你的程序所在路径 && ./your_daemon_process\n")
# 等待守护进程就绪
daemon_start_output = read_channel_output(stop_mark="DAEMON_READY")
print("守护进程启动完成，输出：", daemon_start_output)

# 2. 启动客户端程序，示例中用CLIENT_WAIT_INPUT作为客户端等待输入的标记
channel.send("./your_client_app\n")
read_channel_output(stop_mark="CLIENT_WAIT_INPUT")

# 3. 逐次发送输入，获取响应
test_inputs = ["1", "2", "3"]
for input_item in test_inputs:
    # 发送输入
    channel.send(f"{input_item}\n")
    # 每次响应结束后客户端会回到等待输入状态，用CLIENT_WAIT_INPUT作为响应结束标记
    resp = read_channel_output(stop_mark="CLIENT_WAIT_INPUT")
    print(f"输入{input_item}得到响应：", resp)

# 4. 资源清理：先退出客户端，再杀掉守护进程，最后关连接
channel.send("exit\n") # 退出客户端
channel.send("pkill your_daemon_process\n")
time.sleep(1)
channel.close()
ssh.close()

• 不要拆分多个通道执行命令：所有程序启动、输入发送操作必须在同一个invoke_shell()返回的channel对象上完成，不要额外调用exec_command开新通道
• 自定义标记要足够特殊：守护进程就绪标记、客户端等待输入标记不要和程序正常日志内容重复，避免读取输出时提前截断
• 超时参数按需调整：如果守护进程启动慢、响应耗时长，对应调大settimeout和read_wait的数值，避免读不到完整输出
• 不要随意给守护进程加后台符：在PTY会话里启动的守护进程只要不主动退出，会一直和客户端在同一个会话上下文里，不要直接加&把进程扔到后台后不管，否则可能导致输出丢失读不到响应

内容的提问来源于stack exchange，提问作者user19278984