无法通过 SSH 连接到 MySQL

Question

我在我的 OS X 机器上本地运行一个 node Express 网站。

我需要通过 ssh 连接到远程 mysql 数据库，以便开始编写查询。

现在我可以通过我的 OS X Yosemite 终端 ssh 到云端的远程服务器（运行 mysql 数据库）。

但我没有成功尝试在代码中使用 node-mysql 和 tunnel-ssh 节点中间件。

在 Webstorm 中调试我的 express 应用程序时，我的代码运行但除了我的 GET 之外并没有真正出错。

一些事实：

• 我可以使用以下命令从 OS X SSH 进入 mySQL：

  ssh -L 3306:127.0.0.1:3306 ourCloudServerName.net MyUserNameHere

• 然后我可以使用以下命令连接到 mySQL：

  mysql -h localhost -p -u myUserNameHere

1234563 p>

• 我正在通过 Webstorm 10.0.3 进行调试 这意味着我正在调试我的 Node Express 应用程序，它的开头是这样的：

  var 端口 = 3000;

  app.set('port', 端口);

  app.listen(app.get('port'), function(){ console.log('Express Web 服务器正在监听端口' + app.get('port')); })

  • 我可以在 Chrome 中通过 localhost:3000 运行我的 express 应用

现在这是我第一次尝试同时使用 node-mysql 和 tunnel-ssh

mysqlConfig.js

var databaseConfig = module.exports = function(){};

 module.exports = {

    mySQLConfig: {
       host: '127.0.0.1',
       username: 'root',
       password: 'rootPassword',
       database: 'SomeDatabaseName',
       port: 3306,
       timeout: 100000
    },

    sshTunnelConfig: {
       username: 'myusername',
       password: 'mypassword',
       host: 'ourCloudServerName\.net',
       port: 22,
       //localPort: 3306, //4370
       //port: 3333,
       //localPort: 4370,
       dstPort: 3306,
       srcHost: 'localhost',
       dstHost: 'localhost',
       localHost: 'localhost'
    }
 };

connection.js

 var mysql = require('mysql'),
    config = require('./mysqlConfig'),
    tunnel = require('tunnel-ssh');


var connection = module.exports = function(){};

createDBConnection = function(){
    var mysqlConnection = mysql.createConnection({
        host: config.mySQLConfig.host,
        user: config.mySQLConfig.username,
        password: config.mySQLConfig.password,
        database: config.mySQLConfig.database,
        connectTimeout: config.mySQLConfig.timeout
    });

    return mysqlConnection;
};


connection.invokeQuery = function(sqlQuery){

    var data = undefined;

    var sshTunnel = tunnel(config.sshTunnelConfig, function(error, result) {

        var sqlConnection = createDBConnection();

        sqlConnection.connect(function (err) {
            console.log(err.code);
        });
        sqlConnection.on('error', function (err) {
            console.log(err.code);
        });

        data = sqlConnection.query({
            sql: sqlQuery,
            timeout: config.mySQLConfig.timeout
        }, function (err, rows) {

            if (err && err.code) {
                console.log("error code: " + err.code)
            }
            if (err) {
                console.error("error stack: " + err.stack)
            }
            ;

            if (rows) {
                console.log("We have Rows!!!!!!")
            }
        });

        sqlConnection.destroy();
    });

    return data;
};

路由器/index.js

var connection = require('../config/database/connection');
var express = require('express');
var router = express.Router();

router.get('/', function(req, res) {
    var sqlStatement = "Select top 10 from someTable";

    var rows = connection.invokeQuery(sqlStatement);
});

module.exports = router;

所以我尝试在 Webstorm 中进行调试，但我要么从来没有真正得到一个好的错误打印到控制台，要么如果我这样做了，这是一个通用的节点错误。我可能有一个基本的代码问题和/或只是没有正确设置值或没有正确使用中间件，我只是不知道，在调试期间它并没有告诉我太多。我只知道：

1) 我没有通过 ssh 连接到服务器。调试期间连接在 ssh 服务器对象中显示为 0

2) mysql连接对象显示断开，从未连接

3) 我在 Webstorm 中也遇到了这个节点错误，同时运行 express 网站并没有告诉我 jack：

什么连接被拒绝，我正在通过 localhost 端口 3000 运行这个网站。这是说它无法连接到 ssh 吗？我不知道这里。这并不总是出现或发生，它是一个间歇性错误，可能只是一个 webstorm 调试问题，我只需要再次运行调试并且通常会消失......但可能是相互关联的，没有线索。

这就是我在调试期间检查配置对象时的内容

在 tunnel-ssh/index.js 的第 70 行，它返回它尝试创建的服务器，我看到没有 ssh 连接：

更新 - 根据答案的建议

Answer 1

如果您需要做的只是从应用程序内部建立 MySQL 连接，这实际上可以简化。 mysql2 模块（更好地）支持传递自定义流以用作数据库连接，这意味着您不必启动本地 TCP 服务器并监听连接以通过隧道。

这是一个使用mysql2 和ssh2 的示例：

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

var sshConf = {
  host: 'ourCloudServerName.net',
  port: 22,
  username: 'myusername',
  password: 'mypassword',
};
var sqlConf = {
  user: 'root',
  password: 'rootPassword',
  database: 'SomeDatabaseName',
  timeout: 100000
};

var ssh = new SSH2Client();
ssh.on('ready', function() {
  ssh.forwardOut(
    // source IP the connection would have came from. this can be anything since we
    // are connecting in-process
    '127.0.0.1',
    // source port. again this can be randomized and technically should be unique
    24000,
    // destination IP on the remote server
    '127.0.0.1',
    // destination port at the destination IP
    3306,
    function(err, stream) {
      // you will probably want to handle this better,
      // in case the tunnel couldn't be created due to server restrictions
      if (err) throw err;

      // if you use `sqlConf` elsewhere, be aware that the following will
      // mutate that object by adding the stream object for simplification purposes
      sqlConf.stream = stream;
      var db = mysql2.createConnection(sqlConf);

      // now use `db` to make your queries
    }
  );
});
ssh.connect(sshConf);

当然，您将希望扩展此示例，在 ssh 和 mysql 级别添加错误处理，以防由于某种原因（例如 TCP 连接被切断或 ssh/mysql 服务停止）而消失。通常，您只需为ssh 和db 添加error 事件处理程序即可处理大多数情况，尽管您可能也想监听end 事件以了解何时需要重新建立@987654332 中的一个/两个@ 和 db 连接。

此外，在 ssh 和 mysql 级别配置 keepalive 可能是明智的。 ssh2 有几个 keepalive options 的行为就像 OpenSSH 客户端的 keepalive 选项一样。 对于mysql2，通常我所做的只是每隔一段时间调用db.ping()。您可以传入一个回调，该回调将在服务器响应 ping 时被调用，因此您可以使用一个额外的计时器，该计时器在回调执行时被清除。这样如果回调没有执行，你可以尝试重新连接。

Answer 2

这是 SELinux 问题，您的 httpd / webserver 不允许通过网络连接，您的问题的答案是以下命令：

setsebool -P httpd_can_network_connect 1

那么它应该可以正常工作。我相信您使用的是 apache？