nodejs解决mysql和连接池(pool)自动断开问题

2017-07-14 13:53:02

  最近在做一个个人项目,数据库尝试使用了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.     };  

  8.   

  9.   db = mysql.createConnection(env);  

  10.   db.connect();  

  11.   

  12.   exports.do = function (sql, callback) {  

  13.   

  14.     db.query(sql, callback);  

  15.   

  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. }  

  11.   

  12. // 连接数据库  

  13. function connect () {  

  14.   db = mysql.createConnection(config);  

  15.   db.connect(handleError);  

  16.   db.on('error', handleError);  

  17. }  

  18.   

  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);  

  3.   

  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();  

  9.   

  10.     // Don't use the connection here, it has been returned to the pool.  

  11.   });  

  12. });  


  • 2018-11-26 17:03:59

    有些 where 条件会导致索引无效

    在查询中,WHERE 条件也是一个比较重要的因素,尽量少并且是合理的 where 条件是徆重要的,尽量在多个条件的时候,把会提取尽量少数据量的条件放在前 面,减少后一个 where 条件的查询时间。

  • 2018-11-26 17:05:47

    sql查询调优之where条件排序字段以及limit使用索引的奥秘

    看起来匪夷所思,其实搞清楚mysql查询的原理之后,其实很简单 我们来看这2条sql查询,都用到了where order by limit 当有limit存在时,查询的顺序就有可能发生变化,这时并不是从数据库中先通过where过滤再排序再limit 因为如果这样的话,从500万数据中通过where过滤就不会是5s了。

  • 2018-11-26 21:46:28

    TextView设置行间距、行高,以及字间距

    Android系统中TextView有默认行间距,但是比较窄有的时候需要我们设置每行行间距。 TextView为我们提供了相关设置属性android:lineSpacingExtra或android:lineSpacingMultiplier。

  • 2018-11-26 21:47:55

    Drawable一个有趣的属性:tileMode

    tileMode是drawable 资源文件 bitmap的一个属性, 翻译的意思是平铺模式。用法如下: 在drawable目录下新建一个资源文件 tile_mode_demo.xml

  • 2018-11-28 09:55:53

    android radiogroup样式(设置切换背景与文字颜色)

    RadioButton(单选按钮)在Android开发中应用的非常广泛,比如一些选择项的时候,会用到单选按钮。它是一种单选框双状态的按钮,可以选择或不选择。在RadioButton没有被选中时,用户能够按下或点击来选中它。

  • 2018-12-01 00:27:12

    批量kill mysql processlist进程

    如果大批量的操作能够通过一系列的select语句产生,那么理论上就能对这些结果批量处理。 但是mysql并没用提供eval这样的对结果集进行分析操作的功能。所以只能现将select结果保存到临时文件中,然后再执行临时文件中的指令。