目的是在卫星服务器和集中式注册表数据库之间建立n条ssh隧道。我已经在服务器之间设置了公钥身份验证,因此它们无需密码提示即可直接登录。怎么办 ?我已经尝试过Paramiko。看起来不错,但是即使建立示例隧道也很复杂,尽管代码示例值得赞赏。我尝试过Autossh,它在设置了正常工作的隧道2分钟后就死了,这很奇怪!希望有人可以帮助我提供一个简单的代码段,让我可以使用supervisored或monit进行守护和监视。
最佳答案
这是Alex指向您的script的简化版本。
它仅连接到 192.168.0.8 并将端口 3389 从 192.168.0.6 转发到本地主机
import select
import SocketServer
import sys
import paramiko
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(),))
def main():
client = paramiko.SSHClient()
client.load_system_host_keys()
client.set_missing_host_key_policy(paramiko.WarningPolicy())
client.connect("192.168.0.8")
class SubHandler(Handler):
chain_host = "192.168.0.6"
chain_port = 3389
ssh_transport = client.get_transport()
try:
ForwardServer(('', 3389), SubHandler).serve_forever()
except KeyboardInterrupt:
sys.exit(0)
if __name__ == '__main__':
main()
关于python - 从python发起SSH隧道时出现问题,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/2323471/