Node.js ssh2隧道保持活动并执行mysql查询

Question

我实施rest api使用node.js使用ssh2 package隧道连接到remote mysql database。这是我用来通过ssh连接并执行的代码query

executeQuery : function(query, callback) {
        var sshConnected = false;
        var connection = require('ssh2').Client();
        var server = require('net').createServer(function(sock) {
            if (!sshConnected) return sock.end();
            connection.forwardOut(
                '127.0.0.1',
                sock.remotePort,
                '127.0.0.1',
                3306,
                function (err, stream) {
                    if (err) return sock.end();
                    stream.pipe(sock).pipe(stream);
                });
        });
        connection.on('ready', function() {
            console.log('Client :: ready');
            sshConnected = true;
            server.listen(3306);
            var sqlconn = require('mysql').createConnection(config.dbOrg);
            sqlconn.connect(function (conError) {
                if (!conError) {
                    console.log(query);
                    sqlconn.query({sql: query.sql, values: query.values}, function (qError, results, fields) {
                        callback(qError, results, fields);
                    });
                } else {
                    callback(response.dbError, null, null);
                }
                server.close();
            });
        }).connect(config.sshConfig);

但是，如您所见，它并不是非常有效。

对于每个新查询，我将再次建立连接，启动TCP Server并在查询后将其停止。每个查询大约需要花时间，3-4s这确实很糟糕。任何使the ssh connection和the tcp serverlive在queries到达时都可以执行的方法将大有帮助。谢谢！

Answer 1

在直接使用数据库驱动程序的情况下，如果您使用mysql2而不是mysql，则实际上可以将ssh转发的流作为要由数据库驱动程序使用的基础连接。这将使您无需创建其他服务器来侦听即将建立的传入连接。因此，您可以执行以下操作：

var mysql = require('mysql2');
var Client = require('ssh2').Client;

var ssh = new Client();
ssh.on('ready', function() {
  ssh.forwardOut(
    '127.0.0.1',
    12345,
    '127.0.0.1',
    3306,
    function (err, stream) {
      if (err) throw err;
      var sql = mysql.createConnection({
        user: 'foo',
        database: 'test',
        stream: stream // <--- this is the important part
      });
      // use sql connection as usual
  });
}).connect({
  // ssh connection config ...
});