调用quit后不能排队握手

在这里,我正在做,可以提出一些基本的错误,一般来说,我已经实现了这样的代码:

module.exports = { getDataFromUserGps: function(callback) { connection.connect(); connection.query("SELECT * FROM usergps", function(err, results, fields) { if (err) return callback(err, null); return callback(null, results); } ); connection.end(); }, loginUser: function(login, pass, callback) { connection.connect(); connection.query( "SELECT id FROM users WHERE login = ? AND pass = ?", [login, pass], function(err, results, fields) { if (err) return callback(err, null); return callback(null, results); } ); connection.end(); }, getUserDetails: function(userid, callback) { connection.connect(); connection.query( "SELECT * FROM userProfilDetails LEFT JOIN tags ON userProfilDetails.userId = tags.userId WHERE userProfilDetails.userid = ?", [userid], function(err, results, fields) { if (err) return callback(err, null); return callback(null, results); } ); connection.end(); }, addTags: function(userId, tags) { connection.connect(); connection.query( "INSERT INTO tag (userId, tag) VALUES (?, ?)", [userId, tags], function(err, results, fields) { if (err) throw err; } ) connection.end(); } } 

而一切都很好,但只有第一次,如果我想第二次“使用”查询,我收到他的错误:

调用quit后不能排队握手

我试过不要.end()连接,但它没有帮助
提前致谢
拉德克

如果使用node-mysql模块,只需删除.connect和.end。 刚才自己解决了这个问题。 显然他们在最后一次迭代中插入了不必要的代码,这个代码也被窃听了。 如果您已经运行createConnection调用,则不需要连接

根据:

TL; DR您需要在每次断开连接后调用createConnection方法来build立新的连接。

注意:如果您正在提供Web请求,那么您不应该在每个请求中都结束连接。 只需在服务器启动时创build一个连接,并使用连接/客户端对象来查询所有的时间。 您可以侦听错误事件来处理服务器断开连接和重新连接的目的。 完整代码在这里 。


从:

它说:

服务器断开连接

由于networking问题,服务器计时或服务器崩溃,您可能会失去与MySQL服务器的连接。 所有这些事件被认为是致命的错误,并将有err.code = 'PROTOCOL_CONNECTION_LOST' 。 有关更多信息,请参阅error handling部分。

处理这种意外断开的最佳方式如下所示:

 function handleDisconnect(connection) { connection.on('error', function(err) { if (!err.fatal) { return; } if (err.code !== 'PROTOCOL_CONNECTION_LOST') { throw err; } console.log('Re-connecting lost connection: ' + err.stack); connection = mysql.createConnection(connection.config); handleDisconnect(connection); connection.connect(); }); } handleDisconnect(connection); 

正如你在上面的例子中看到的,通过build立一个新的连接重新连接一个连接。 一旦终止,现有的连接对象不能通过devise重新连接。

使用Pool时,断开的连接将从池中移除,释放空间,以便在下一次getConnection调用时创build新连接。


我调整了函数,使得每次需要连接时,初始化函数自动添加处理程序:

 function initializeConnection(config) { function addDisconnectHandler(connection) { connection.on("error", function (error) { if (error instanceof Error) { if (error.code === "PROTOCOL_CONNECTION_LOST") { console.error(error.stack); console.log("Lost connection. Reconnecting..."); initializeConnection(connection.config); } else if (error.fatal) { throw error; } } }); } var connection = mysql.createConnection(config); // Add handlers. addDisconnectHandler(connection); connection.connect(); return connection; } 

初始化连接:

 var connection = initializeConnection({ host: "localhost", user: "user", password: "password" }); 

小build议:这可能不适用于每个人,但我遇到了涉及范围的小问题。 如果OP觉得这个编辑是不必要的,那么他/她可以select删除它。 对我来说,我不得不在initializeConnection更改一行,这是var connection = mysql.createConnection(config); 只是简单而已

 connection = mysql.createConnection(config); 

原因是如果connection是程序中的一个全局variables,那么之前的问题就是在处理一个错误信号时你正在创build一个新的connectionvariables。 但是在我的nodejs代码中,我一直使用相同的全局connectionvariables来运行查询,因此新connection将会在initalizeConnection方法的本地范围内丢失。 但是在修改中,它确保全局connectionvariables被重置。这可能是相关的,如果遇到问题已知

致命错误后无法排队查询

尝试执行查询失去连接后,然后成功重新连接。 这可能是OP的一个错字,但我只是想澄清一下。

我遇到了同样的问题,Google在这里引导我。 我同意@Ata,只是删除end()是不正确的。 进一步谷歌search后,我认为使用pooling是一个更好的方法。

关于池的node-mysql文档

就像这样:

 var mysql = require('mysql'); var pool = mysql.createPool(...); pool.getConnection(function(err, connection) { connection.query( 'bla bla', function(err, rows) { connection.release(); }); }); 

我觉得这个问题和我的相似:

  1. 连接到MySQL
  2. 结束MySQL服务(不应该退出节点脚本)
  3. 启动MySQL服务,Node重新连接到MySQL
  4. 查询DB – > FAIL(致命错误后无法排队查询)

我通过使用promises(q)重新创build一个新的连接来解决这个问题。

MySQL的-con.js

 'use strict'; var config = require('./../config.js'); var colors = require('colors'); var mysql = require('mysql'); var q = require('q'); var MySQLConnection = {}; MySQLConnection.connect = function(){ var d = q.defer(); MySQLConnection.connection = mysql.createConnection({ host : 'localhost', user : 'root', password : 'password', database : 'database' }); MySQLConnection.connection.connect(function (err) { if(err) { console.log('Not connected '.red, err.toString().red, ' RETRYING...'.blue); d.reject(); } else { console.log('Connected to Mysql. Exporting..'.blue); d.resolve(MySQLConnection.connection); } }); return d.promise; }; module.exports = MySQLConnection; 

mysqlAPI.js

 var colors = require('colors'); var mysqlCon = require('./mysql-con.js'); mysqlCon.connect().then(function(con){ console.log('connected!'); mysql = con; mysql.on('error', function (err, result) { console.log('error occurred. Reconneting...'.purple); mysqlAPI.reconnect(); }); mysql.query('SELECT 1 + 1 AS solution', function (err, results) { if(err) console.log('err',err); console.log('Works bro ',results); }); }); mysqlAPI.reconnect = function(){ mysqlCon.connect().then(function(con){ console.log("connected. getting new reference"); mysql = con; mysql.on('error', function (err, result) { mysqlAPI.reconnect(); }); }, function (error) { console.log("try again"); setTimeout(mysqlAPI.reconnect, 2000); }); }; 

我希望这有帮助。

不要在函数内部连接()和结束()。 这将导致重复调用该函数的问题。 只做连接

 var connection = mysql.createConnection({ host: 'localhost', user: 'node', password: 'node', database: 'node_project' }) connection.connect(function(err) { if (err) throw err }); 

一次并重新使用该连接。

里面的function

 function insertData(name,id) { connection.query('INSERT INTO members (name, id) VALUES (?, ?)', [name,id], function(err,result) { if(err) throw err }); }