我正在编写一个 python 脚本,通过已建立的 ssh 隧道经常查询一些远程数据库。我对 paramiko 库相当熟悉,所以这是我选择的路线。我更愿意将其保留在完整的 python 中,这样我就可以使用 paramiko 来处理关键问题,以及使用 python 来启动、控制和关闭 ssh 隧道。
这里有一些关于这个主题的相关问题,但大多数问题的答案似乎都不完整。下面的解决方案是我迄今为止找到的解决方案的组合。
现在的问题是:我可以很容易地创建第一个隧道(在单独的线程中)并执行我的 DB/python 操作,但是当尝试关闭隧道时,本地主机不会释放我绑定到的本地端口。下面,我在整个过程的每个步骤中都包含了我的来源和相关的 netstat 数据。
#!/usr/bin/python
import select
import SocketServer
import sys
import paramiko
from threading import Thread
import time
class ForwardServer(SocketServer.ThreadingTCPServer):
daemon_threads = True
allow_reuse_address = True
class Handler (SocketServer.BaseRequestHandler):
def handle(self):
try:
chan = self.ssh_transport.open_channel('direct-tcpip', (self.chain_host, self.chain_port), self.request.getpeername())
except Exception, e:
print('Incoming request to %s:%d failed: %s' % (self.chain_host, self.chain_port, repr(e)))
return
if chan is None:
print('Incoming request to %s:%d was rejected by the SSH server.' % (self.chain_host, self.chain_port))
return
print('Connected! Tunnel open %r -> %r -> %r' % (self.request.getpeername(), chan.getpeername(), (self.chain_host, self.chain_port)))
while True:
r, w, x = select.select([self.request, chan], [], [])
if self.request in r:
data = self.request.recv(1024)
if len(data) == 0:
break
chan.send(data)
if chan in r:
data = chan.recv(1024)
if len(data) == 0:
break
self.request.send(data)
chan.close()
self.request.close()
print('Tunnel closed from %r' % (self.request.getpeername(),))
class DBTunnel():
def __init__(self,ip):
self.c = paramiko.SSHClient()
self.c.load_system_host_keys()
self.c.set_missing_host_key_policy(paramiko.AutoAddPolicy())
self.c.connect(ip, username='someuser')
self.trans = self.c.get_transport()
def startTunnel(self):
class SubHandler(Handler):
chain_host = '127.0.0.1'
chain_port = 5432
ssh_transport = self.c.get_transport()
def ThreadTunnel():
global t
t = ForwardServer(('', 3333), SubHandler)
t.serve_forever()
Thread(target=ThreadTunnel).start()
def stopTunnel(self):
t.shutdown()
self.trans.close()
self.c.close()
虽然我最终将使用 stopTunnel() 类型的方法,但我意识到代码并不完全正确,但更多的是尝试让隧道正确关闭并测试我的结果的实验。
当我第一次调用创建 DBTunnel 对象并调用 startTunnel() 时,netstat 产生以下结果:
tcp4 0 0 *.3333 *.* LISTEN
tcp4 0 0 MYIP.36316 REMOTE_HOST.22 ESTABLISHED
tcp4 0 0 127.0.0.1.5432 *.* LISTEN
一旦我调用 stopTunnel(),或者甚至删除 DBTunnel 对象本身..我会保留此连接,直到我一起退出 python,并且我认为垃圾收集器会处理它:
tcp4 0 0 *.3333 *.* LISTEN
如果能弄清楚为什么这个打开的套接字独立于 DBConnect 对象而挂起,以及如何从我的脚本中正确关闭它,那就太好了。如果我在完全退出python之前尝试使用相同的本地端口将不同的连接绑定到不同的IP(time_wait不是问题),那么我会得到臭名昭著的bind err 48地址。提前致谢 :)