5

程序流程为:

  1. 使用 Paramiko 库连接到 Linux 机器上的 OpenSSH 服务器
  2. 打开 X11 会话
  3. 运行 xterm 可执行文件
  4. 通过在终端中输入可执行名称并运行它来运行其他程序(例如 Firefox)。

如果有人可以解释如何使某些可执行文件在使用以下代码打开的终端中运行并提供示例源代码( source ) ,我将不胜感激:

import select
import sys
import paramiko
import Xlib.support.connect as xlib_connect
import os
import socket
import subprocess



# run xming
XmingProc = subprocess.Popen("C:/Program Files (x86)/Xming/Xming.exe :0 -clipboard -multiwindow")
ssh_client = paramiko.SSHClient()
ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh_client.connect(SSHServerIP, SSHServerPort, username=user, password=pwd)
transport = ssh_client.get_transport()
channelOppositeEdges = {}

local_x11_display = xlib_connect.get_display(os.environ['DISPLAY'])
inputSockets = []

def x11_handler(channel, (src_addr, src_port)):
    local_x11_socket = xlib_connect.get_socket(*local_x11_display[:3])
    inputSockets.append(local_x11_socket)
    inputSockets.append(channel)
    channelOppositeEdges[local_x11_socket.fileno()] = channel
    channelOppositeEdges[channel.fileno()] = local_x11_socket
    transport._queue_incoming_channel(channel)

session = transport.open_session()
inputSockets.append(session)
session.request_x11(handler = x11_handler)
session.exec_command('xterm')
transport.accept()

while not session.exit_status_ready():
    readable, writable, exceptional = select.select(inputSockets,[],[])
    if len(transport.server_accepts) > 0:
        transport.accept()
    for sock in readable:
        if sock is session:
            while session.recv_ready():
                sys.stdout.write(session.recv(4096))
            while session.recv_stderr_ready():
                sys.stderr.write(session.recv_stderr(4096))   
        else: 
            try:
                data = sock.recv(4096)
                counterPartSocket  = channelOppositeEdges[sock.fileno()]
                counterPartSocket.sendall(data)
            except socket.error:
                inputSockets.remove(sock)
                inputSockets.remove(counterPartSocket)
                del channelOppositeEdges[sock.fileno()]
                del channelOppositeEdges[counterPartSocket.fileno()]
                sock.close()
                counterPartSocket.close()

print 'Exit status:', session.recv_exit_status()
while session.recv_ready():
    sys.stdout.write(session.recv(4096))
while session.recv_stderr_ready():
    sys.stdout.write(session.recv_stderr(4096))
session.close()
XmingProc.terminate()
XmingProc.wait()

我正在考虑在子线程中运行程序,而运行 xterm 的线程正在等待子线程终止。

4

1 回答 1

2

好吧,这有点小技巧,但是,嘿。

您可以在远程端执行以下操作:在 xterm 中,您运行netcat,侦听从某个端口传入的任何数据,并通过管道传输您进入的任何内容bash。它与直接输入 xterm 不太一样,但几乎和直接输入 bash 一样好,所以我希望它能让你更接近你的目标。如果您真的想直接与 xterm 交互,您可能需要阅读这篇文章

例如:

1号航站楼:

% nc -l 3333 | bash

2 号航站楼(echo hi在此处输入):

% nc localhost 3333
echo hi

现在您应该看到hi从第一个终端弹出。现在用xterm&. 它对我有用。

以下是如何在 Python 中自动执行此操作。您可能想要添加一些代码,使服务器能够在准备好时通知客户端,而不是使用愚蠢time.sleep的 s.

import select
import sys
import paramiko
import Xlib.support.connect as xlib_connect
import os
import socket
import subprocess

# for connecting to netcat running remotely
from multiprocessing import Process
import time

# data
import getpass
SSHServerPort=22
SSHServerIP = "localhost"
# get username/password interactively, or use some other method..
user = getpass.getuser()
pwd = getpass.getpass("enter pw for '" + user + "': ")
NETCAT_PORT = 3333
FIREFOX_CMD="/path/to/firefox &"
#FIREFOX_CMD="xclock&"#or this :)

def run_stuff_in_xterm():
    time.sleep(5)
    s = socket.socket(socket.AF_INET6 if ":" in SSHServerIP else socket.AF_INET, socket.SOCK_STREAM)
    s.connect((SSHServerIP, NETCAT_PORT))
    s.send("echo \"Hello there! Are you watching?\"\n")
    s.send(FIREFOX_CMD + "\n")
    time.sleep(30)
    s.send("echo bye bye\n")
    time.sleep(2)
    s.close()

# run xming
XmingProc = subprocess.Popen("C:/Program Files (x86)/Xming/Xming.exe :0 -clipboard -multiwindow")
ssh_client = paramiko.SSHClient()
ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh_client.connect(SSHServerIP, SSHServerPort, username=user, password=pwd)
transport = ssh_client.get_transport()
channelOppositeEdges = {}

local_x11_display = xlib_connect.get_display(os.environ['DISPLAY'])
inputSockets = []

def x11_handler(channel, (src_addr, src_port)):
    local_x11_socket = xlib_connect.get_socket(*local_x11_display[:3])
    inputSockets.append(local_x11_socket)
    inputSockets.append(channel)
    channelOppositeEdges[local_x11_socket.fileno()] = channel
    channelOppositeEdges[channel.fileno()] = local_x11_socket
    transport._queue_incoming_channel(channel)

session = transport.open_session()
inputSockets.append(session)
session.request_x11(handler = x11_handler)
session.exec_command("xterm -e \"nc -l 0.0.0.0 %d | /bin/bash\"" % NETCAT_PORT)
p = Process(target=run_stuff_in_xterm)
transport.accept()
p.start()

while not session.exit_status_ready():
    readable, writable, exceptional = select.select(inputSockets,[],[])
    if len(transport.server_accepts) > 0:
        transport.accept()
    for sock in readable:
        if sock is session:
            while session.recv_ready():
                sys.stdout.write(session.recv(4096))
            while session.recv_stderr_ready():
                sys.stderr.write(session.recv_stderr(4096))   
        else: 
            try:
                data = sock.recv(4096)
                counterPartSocket  = channelOppositeEdges[sock.fileno()]
                counterPartSocket.sendall(data)
            except socket.error:
                inputSockets.remove(sock)
                inputSockets.remove(counterPartSocket)
                del channelOppositeEdges[sock.fileno()]
                del channelOppositeEdges[counterPartSocket.fileno()]
                sock.close()
                counterPartSocket.close()

p.join()
print 'Exit status:', session.recv_exit_status()
while session.recv_ready():
    sys.stdout.write(session.recv(4096))
while session.recv_stderr_ready():
    sys.stdout.write(session.recv_stderr(4096))
session.close()
XmingProc.terminate()
XmingProc.wait()

XmingProc我在 Mac 上对此进行了测试,因此我将这些位注释掉并/Applications/Firefox.app/Contents/MacOS/firefox用作FIREFOX_CMD(和xclock)。

以上并不是一个完全安全的设置,因为在正确的时间连接到端口的任何人都可以在您的远程服务器上运行任意代码,但听起来您无论如何都打算将其用于测试目的。如果你想提高安全性,你可以让 netcat 绑定到127.0.0.1而不是0.0.0.0,设置一个 ssh 隧道(运行ssh -L3333:localhost:3333 username@remote-host.com将在端口 3333 上本地接收的所有流量隧道到 remote-host.com:3333),然后让 Python 连接到("localhost", 3333).

现在您可以将其与selenium结合使用以实现浏览器自动化:

按照此页面的说明,即下载 selenium 独立服务器 jar 文件,将其放入/path/to/some/place(在服务器上)和pip install -U selenium(再次,在服务器上)。

接下来,将以下代码放入selenium-example.pyin /path/to/some/place

#!/usr/bin/env python
from selenium import webdriver
from selenium.common.exceptions import NoSuchElementException
from selenium.webdriver.common.keys import Keys
import time

browser = webdriver.Firefox() # Get local session of firefox
browser.get("http://www.yahoo.com") # Load page
assert "Yahoo" in browser.title
elem = browser.find_element_by_name("p") # Find the query box
elem.send_keys("seleniumhq" + Keys.RETURN)
time.sleep(0.2) # Let the page load, will be added to the API
try:
    browser.find_element_by_xpath("//a[contains(@href,'http://docs.seleniumhq.org')]")
except NoSuchElementException:
    assert 0, "can't find seleniumhq"
browser.close()

并更改 firefox 命令:

FIREFOX_CMD="cd /path/to/some/place && python selenium-example.py"

并观看 Firefox 进行 Yahoo 搜索。您可能还想增加time.sleep.

如果你想运行更多的程序,你可以在运行 firefox 之前或之后做这样的事情:

# start up xclock, wait for some time to pass, kill it.
s.send("xclock&\n")
time.sleep(1)
s.send("XCLOCK_PID=$!\n")  # stash away the process id (into a bash variable)
time.sleep(30)
s.send("echo \"killing $XCLOCK_PID\"\n")
s.send("kill $XCLOCK_PID\n\n")
time.sleep(5)

如果您想执行一般的 X11 应用程序控制,我认为您可能需要编写类似的“驱动程序应用程序”,尽管使用不同的库。您可能需要搜索“x11 发送 {mouse|keyboard} 事件”以找到更通用的方法。这带来了这些 问题,但我相信还有更多。

如果远程端没有立即响应,您可能想在 Wireshark 中嗅探您的网络流量,并检查 TCP 是否正在对数据进行批处理,而不是逐行发送(\n这里似乎有帮助,但我猜没有保证)。如果是这种情况,您可能会倒霉,但没有什么是不可能的。我希望你不需要走那么远;-)

还有一点需要注意:如果您需要与 CLI 程序的 STDIN/STDOUT 通信,您可能需要查看期望脚本(例如使用pexpect,或者对于简单的情况,您可能可以使用 subprocess.Popen.communicate]( http:// /docs.python.org/2/library/subprocess.html#subprocess.Popen.communicate))。

于 2013-10-14T22:11:16.370 回答