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


  • 2019-10-19 16:35:45

    Vue.directive使用注意

    首先,Vue.directive要在实例初始化之前,不然会报错,还有,定义的指令不支持驼峰式写法,也会报下面同样的错,虽然在源码中没有找到在哪里统一处理大小写,但是在有关directive的方法中捕捉到的指令命名统一变为小写,所以,还是用'-'或者'_'分割吧。

  • 2019-10-21 08:39:54

    vue slot用法以及使用介绍

    通过上面的内容可以知道,在slot组件中引入了slot的子组件,而且又在子组件标签内添加了新的标签内容,但页面上并没有将子组件标签内的标签内容显示出来,

  • 2019-10-21 15:06:27

    yarn详细入门教程

    Yarn 是 Facebook, Google, Exponent 和 Tilde 开发的一款新的 JavaScript 包管理工具。就像我们可以从官方文档了解那样,它的目的是解决这些团队使用 npm 面临的少数问题,即:

  • 2019-10-23 10:20:48

    php 去掉 头尾 空格 2种方法

    看似很简单的问题,其实还是有点坑的,首先这里 空格转义,不是字符串,直接用trim()是去不掉。

  • 2019-10-23 23:25:22

    PostMapping,GetMapping不固定路径的写法

    PostMapping中的value属性是数组,所以可以定义多个路径,required属性默认是true,不必再写required=true,默认表示该参数是必须要有的,如果写required=false,表示该参数是可选的,可有可无。

  • 2019-10-24 01:14:29

    通过属性搜索商品mysql设计

    属性是可以动态扩展的,问题:属性是搜索条件 问:请展示出 材质为塑料 防水为YES,颜色为绿色的商品详细信息,按照sort_filed排序

  • 2019-10-25 15:18:18

    Vue.use Vue.prototype区别

    1、不是为了vue写的插件(插件内要处理)不支持Vue.use()加载方式 2、非vue官方库不支持new Vue()方式 3、每一个vue组件都是Vue的实例,所以组件内this可以拿到Vue.prototype上添加的属性和方法。