>我有一个perl脚本,它创建一个ssh隧道,并在其上设置一个Perl DBI连接来查询远程主机上的数据库:
1 my $ssh = Net::OpenSSH->new('me@host.com');
2 $pid = $ssh->spawn({ssh_opts => '-L 127.0.0.1:12345:127.0.0.1:3306'}, 'sleep 3');
3 return DBI->connect($dsn, $db_user, $db_pass);
这在大约 80% 到 90% 的时间内有效,但其余时间我在尝试连接到数据库时收到此错误:
mux_client_request_session:从主服务器读取失败:管道损坏
在解决此问题的过程中,我注意到如果我在第 usleep (10000)
2 行之后非常短暂地休眠程序,它会在 100% 的时间内工作。我不确定为什么会这样,但我很好奇知道如何以及如何正确解决问题。
谢谢。
代码中存在争用条件:spawn
运行在后台启动隧道的 ssh
命令,有时该命令connect
启动 TCP 套接字比 DBI 快,有时则不然,因此connect
失败。
无论如何,我通常建议创建隧道的方式是使用控制命令:
$ssh->system({ssh_opts => [-O => 'forward', '-L3066:localhost:3066']})
如果要在建立与数据库的连接后删除隧道:
$ssh->system({ssh_opts => [-O => 'cancel', '-L3066:localhost:3066']});
另外,请注意,只要您想使用 DB 连接,就必须使Net::OpenSSH
对象保持活动状态。
总结:
sub dbi_connect {
my $mysql_port = 3066;
my $local_port = 12345;
my $dsn = "DBI:mysql:database=$database;host=localhost;port=$local_port";
my $tunnel = join ':', $local_port, 'localhost', $mysql_port;
my $ssh = Net::OpenSSH->new($host, ...);
$ssh->system({ssh_opts => [-O => 'forward', "-L$tunnel"]});
my $dbi = DBI->connect($dsn, $db_user, $db_pass);
$ssh->system({ssh_opts => [-O => 'cancel', "-L$tunnel"]});
return ($dbi, $ssh);
}
另请参阅PerlMonks的这篇文章。