最近在做一个个人项目，数据库尝试使用了mongodb、sqlite和mysql。分享一下关于mysql的连接池用法。项目部署于appfog，项目中我使用连接池链接数据库，本地测试一切正常。上线以后，经过几次请求两个数据接口总是报503。一直不明就里，今天经过一番排查终于顺利解决了。
1.mysql 链接普通模式

[javascript] view plain copy

  1. var mysql = require(‘mysql’),
  2. 　　　　env = {
  3. 　　　　　　host : ‘localhost’,
  4. 　　　　　　user : ‘root’,
  5. 　　　　　　password : ‘2212’,
  6. 　　　　　　database : ‘image_marker’
  7. 　　　　};
  9. 　　db = mysql.createConnection(env);
  10. 　　db.connect();
  12.   exports.do = function (sql, callback) {
  14.   　　db.query(sql, callback);
  16.   }

 

MySQL中有一个名叫wait_timeout的变量，表示操作超时时间，当连接超过一定时间没有活动后，会自动关闭该连接，这个值默认为28800（即8小时）。对于这种普通连接的方式，在正式线上可能会遇到连接丢失的问题(No reconnection after connection lost错误日志)，上github上看了下文档和issues，上面说到连接丢失后不会自动重新连接，会触发error事件。 所以可以使用下面这种方法来避免连接对视问题：

[javascript] view plain copy

  1. function handleError (err) {
  2.   if (err) {
  3.     // 如果是连接断开，自动重新连接
  4.     if (err.code === ‘PROTOCOL_CONNECTION_LOST’) {
  5.       connect();
  6.     } else {
  7.       console.error(err.stack || err);
  8.     }
  9.   }
  10. }
  12. // 连接数据库
  13. function connect () {
  14.   db = mysql.createConnection(config);
  15.   db.connect(handleError);
  16.   db.on(‘error’, handleError);
  17. }
  19. var db;
  20. connect();

2.使用连接池

对于丢失连接的问题，可以使用连接池(最新版mysql模块，用mysql.createPool()来创建的pool，当触发了connection的error事件时，会把该connection对象从连接池中移除。)

[javascript] view plain copy

  1. var mysql = require(‘mysql’);
  2. var pool  = mysql.createPool(config);
  4. pool.getConnection(function(err, connection) {
  5.   // Use the connection
  6.   connection.query( ‘SELECT something FROM sometable’, function(err, rows) {
  7.     // And done with the connection.
  8.     connection.end();
  10.     // Don’t use the connection here, it has been returned to the pool.
  11.   });
  12. });

参考：https://cnodejs.org/topic/51cd3bcc73c638f3705998f5

使用了连接池后，有网友说每一次请求都用pool创建一个connection，改进我的代码如下连接：

http://www.2cto.com/kf/201404/292016.html

 

转载