如何通过 SSH 隧道远程执行命令并动态端口转发启动 VNC 会话-Python教程-PHP中文网

如何通过 SSH 隧道远程执行命令并动态端口转发启动 VNC 会话

本文介绍如何在 python 脚本中结合动态端口分配、ssh 隧道建立与远程命令执行，自动化启动远程 x11vnc 服务并通过本地 vncviewer 连接，避免端口冲突，并强调主机密钥验证等安全实践。

本文介绍如何在 python 脚本中结合动态端口分配、ssh 隧道建立与远程命令执行，自动化启动远程 x11vnc 服务并通过本地 vncviewer 连接，避免端口冲突，并强调主机密钥验证等安全实践。

在自动化多台远程主机的 VNC 访问场景中，硬编码本地端口（如 15900）极易引发端口冲突。理想方案需满足：① 动态选取空闲本地端口；② 建立安全的 SSH 隧道；③ 在远程主机上启动 x11vnc（仅绑定 localhost:5900）；④ 本地启动 vncviewer 连接该隧道端口。关键挑战在于：如何复用同一 SSH 连接完成隧道建立 + 远程命令执行？ —— sshtunnel.SSHTunnelForwarder 本身不提供交互式命令通道，但其底层依赖 paramiko，我们完全可复用已建立的 SSH 连接。

✅ 推荐方案：统一使用 `paramiko` 管理连接与隧道

以下完整脚本基于 paramiko 实现单连接复用：先建立带密钥认证和主机密钥校验的 SSH 连接，再并发启动端口转发（Transport.set_keepalive 保活）和远程命令，最后本地调用 vncviewer：

#!/usr/bin/env python3
import socket
import paramiko
import subprocess
import sys
import time
import os

def find_free_port():
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
        s.bind(('127.0.0.1', 0))
        return s.getsockname()[1]

def main():
    if len(sys.argv)  2 else find_free_port()
    print(f"Using local port: {local_port}")

    # 初始化 SSH 客户端（启用主机密钥验证）
    client = paramiko.SSHClient()
    client.load_system_host_keys()  # 自动加载 ~/.ssh/known_hosts
    client.set_missing_host_key_policy(paramiko.RejectPolicy())  # 拒绝未知主机（安全！）

    try:
        client.connect(
            hostname=host,
            username=user,
            look_for_keys=True,      # 尝试 ~/.ssh/id_rsa 等
            timeout=10,
            auth_timeout=10,
        )
        print(f"✓ Connected to {host}")

        # 启动远程 x11vnc（后台运行，-forever 确保持续服务）
        cmd = "x11vnc -xkb -display :0 -localhost -forever -shared -o /tmp/x11vnc.log"
        stdin, stdout, stderr = client.exec_command(cmd, get_pty=False)
        # 检查是否启动成功（非阻塞）
        time.sleep(1.5)
        if stdout.channel.recv_exit_status() != 0:
            err = stderr.read().decode().strip()
            print(f"⚠ Remote x11vnc failed: {err}")
            return

        # 启动本地端口转发（复用同一 Transport）
        transport = client.get_transport()
        transport.request_port_forward('127.0.0.1', local_port)
        print(f"✓ Port forwarding: localhost:{local_port} → {host}:5900")

        # 保持连接活跃（防止超时断开）
        transport.set_keepalive(30)

        # 启动本地 vncviewer（非阻塞）
        vnc_cmd = ['vncviewer', f'localhost::{local_port}']
        print(f"Launching: {' '.join(vnc_cmd)}")
        subprocess.Popen(vnc_cmd)

        # 提示用户：按 Ctrl+C 终止隧道和远程服务
        print("\n? Press Ctrl+C to stop tunnel and kill remote x11vnc.")
        try:
            while True:
                time.sleep(3600)  # 每小时检查一次（实际由用户中断）
        except KeyboardInterrupt:
            print("\n? Cleaning up...")
            # 杀掉远程 x11vnc（简单方式：kill by command name）
            client.exec_command("pkill -f 'x11vnc.*:0'")
            transport.cancel_port_forward('127.0.0.1', local_port)
            print("✓ Tunnel closed & remote x11vnc terminated.")

    except paramiko.AuthenticationException:
        print("❌ Authentication failed. Check SSH keys or password.")
    except paramiko.SSHException as e:
        print(f"❌ SSH error: {e}")
    except socket.timeout:
        print("❌ Connection timed out.")
    except Exception as e:
        print(f"❌ Unexpected error: {e}")
    finally:
        client.close()

if __name__ == '__main__':
    main()

? 安全要点说明

主机密钥强制验证：client.load_system_host_keys() + RejectPolicy() 确保只接受 known_hosts 中已记录的主机，杜绝中间人攻击；
密钥优先认证：look_for_keys=True 自动使用本地 SSH 密钥对，无需密码明文；
远程进程可控：使用 -forever 启动 x11vnc 并在脚本退出时 pkill 清理，避免残留服务；
端口动态分配：find_free_port() 使用 SOCK_STREAM 绑定 0 端口，内核返回真实可用端口。