一、Node异步
Node.js 异步编程的直接体现就是回调。
有了异步方法,我们可以一边操作数据库,一边执行其他命令,在数据库操作完成后,我们将查询数据作为回调函数的参数返回。这样在执行代码时就没有阻塞或等待 I/O的 操作。这就大大提高了 服务器运行 的性能,可以更容易的处理大量的并发请求。
二、Mysql数据库连接
1.package.json下添加mysql依赖,cmd命令行中找到项目目录执行 npm install(或者webstorm中 package.json 右键 >> Run 'npm update')
建立目录:
conf >> localmysql.js:
module.exports = {
mysql: {
host: 'localhost',
user: 'root',
password: '3721',
database:'weixin',
port: 3306
}
};
model>> usermodel.js:
const user = {
queryUserByCity:'SELECT nickname FROM userinfo WHERE city = ? ',
};
module.exports = user;
dao >>userDao.js :
const mysql = require('mysql');
const conf = require('../conf/localmysql');
const sql = require('../model/usermodel');
//使用连接池
const pool = mysql.createPool(conf.mysql);
module.exports = {
queryCallBackByCity:(city,callback)=>{
pool.getConnection((err,con)=>{
con.query(sql.queryUserByCity,city,(err,result)=>{
if(err){
callback(err);
}
else {
callback(err,result);
}
})
})
}
};
这里建议确定下来不需要动态变更的变量使用const定义 (阮一峰-const 命令)
三、CallBack 回调写法
在router里定义路由
router.get('/queryuser', (req, res, next)=> {
let data = [];
userDao.queryCallBackByCity('Xuzhou',(err,result)=>{
data.push(result);
});
data.push('哈哈哈');
res.json(data);
});
执行以后发现页面只输出‘哈哈哈’(res.json 输出json格式数据);
改为:
router.get('/queryuser', (req, res, next)=> {
let data = [];
userDao.queryCallBackByCity('Xuzhou',(err,result)=>{
data.push(result);
data.push('哈哈哈');
res.json(data);
});
});
则按着想要的顺序输出了输出正常
因为异步读取,Node会将任务交给地下的线程池操作,线程池操作完成后会发起回调函数触发,所以顺序执行的方法是一层前一层 callback hell(地狱回调);
如果多次读取就会写成:
可以想象复杂的业务逻辑
随意后来有了解决方案2 Promise:
四、Prmoise写法
首先定义userModel:
可以看出来 callback变成 return new Promise 执行成功执行 resovle 执行失败 reject
router调用,在调用函数后面加 调用成功then,调用失败catch:
router.get('/queryuser3', (req, res, next)=> {
let data = [];
userDao.queryPromiseByCity('Changzhou').then((r)=>{
data.push(r);
res.json(data);
}).catch(err=>{
return console.log(err);
})
});
这样,就可以写出链式回调写法,虽然依旧恶心,但至少美观了不少,并且错误处理只需要一个catch就可以
五、终极解决方案:Async
async需要node 7.X版本支持
如小于7.X版本可以选择使用Bable或者升级,windows下升级可以看我的这篇博客
使用 async/await 调用Promise对象可以直接当作同步来写,但是目前7.X未出稳定版,es2017还未正式发布,谨慎使用。
如图,两种方法,async可以在路由里定义async函数 (需要加括号表名作用域)下
或者定义在执行函数里,上