初始koa
koa是一个新的web框架，基于nodejs平台，koa没有捆绑任何中间件，而是提供了一套优雅的函数库，帮助您快速而愉快的编写服务端应用程序。
一个demo带你了解koa😆
1、不用koa时的写法
let http = require('http'); //node 中的api
let server = http.createServer((req, res) => {
res.end('hello world')
})
server.listen(4000)
2、用koa之后的写法
const Koa = require('koa');
const app = new Koa();
app.use((ctx, next) => {
ctx.body = 'Hello World';
});
app.listen(3000);
对比发现，相对原生，koa多了两个实例上的use、listen方法，和use回调中的ctx、next两个参数。这四个不同，几乎就是koa的全部了，也是这四个不同让koa如此强大。
安装
1.确保已安装node,npm
node -v
npm -v
2.安装koa脚手架koa-generator
cnpm install koa-generator --save -g
3.生成koa2项目
koa2
4.安装依赖包
cnpm install
5.启动服务
cnpm start
6.打开浏览器：：http://localhost:3000/看到'Hello Koa2!'就表示访问成功了！
DEMO
1、用koa脚手架生成的目录结构
durian/（项目名称）
|---- bin
|---- www （启动文件）
|---- node_modules
|---- 安装的各种依赖
|---- public
|---- image
|---- style
|---- javascript
|---- router
|---- index.js （路由）
|---- users.js
|---- view
|---- layout.jade（.jade 源于 Node.js 的 HTML 模板引擎，类似于.ejs模板 )
|---- index.jade
|---- error.jade
|---- app.js
|---- package.json
2、连接mysql取数据
- 安装mysql
cnpm install mysql --save -g
- 连接mysql，新建root.js文件（注意：我这里连接的是我本机的mysql）
var mysql = require('mysql');
var connection = mysql.createConnection({
host: 'localhost', // 连接的本地mysql
user: 'root', // 用户名
password: '***', // 密码
port: '3306', // 端口号
database: 'test' // 表名
});
connection.connect(); // 建立链接
var sql = 'select * from test'; // 查询的表名
connection.query(sql, function (err, result) {
if (err) {
console.log('error', err.message);
return;
}
console.log('--------------------------SELECT----------------------------');
console.log(result);
});
connection.end();
- 输出sql语句查询的结果
node root.js
至此，一个简单的sql查询就结束了，接下来咱们修改下脚手架目录，开始开发咱们所需要的api接口；
项目实操
1、改造之后的项目目录长这样，如下：
durian/（项目名称）
|---- bin
|---- www （启动文件）
|---- dal
|---- logger.js （打印logger）
|---- logs
|---- xxx （logger输出地址）
|---- mysql
|---- config.js （连接的数据库配置）
|---- mysql.js （sql查询等方法封装）
|---- pool.js （创建链接数据库）
|---- node_modules
|---- 安装的各种依赖
|---- public
|---- image
|---- style
|---- javascript
|---- router
|---- index.js （接口路由）
|---- users.js
|---- server
|---- index.js （sql语句）
|---- view
|---- layout.html
|---- app.js
|---- package.json
2、在server目录中输入咱们要查询的sql语句，然后把查询到的内容return出去
test: async () => { // 如果函数没使用async 函数内部不可以使用await;
//async 确保了返回值是一个promise
//await 不能再顶部作用域，等待await后面的内容返回之后才会执行下面的操作
const task_countSql = mysql.getSql("select * from test", []);
let data = await mysql.operateDB(task_countSql, []);
console.log(data);
return {
code: 0,
message: '成功',
list: data
};
},
3、在router目录中写接口名称并把数据赋值给body
import testService from '../../../service/test/index'
export const test = {
'path': '/test.do',
'type': 'get',
'control': async (ctx) => {
const data = await testService.test();
ctx.body = { data }
}
}
4、浏览器访问接口，看输出内容
{
"data": [
{
"id": 1,
"name": "nodejs in action test!!"
}
]
}
5、在页面中请求接口
<tr>
<td><a href="/api/test.do?a=1">/api/test.do</a></td>
<td>测试页面访问接口:</td>
</tr>
6、访问页面地址看输出
127.0.0.1:3000/page/
//输出内容
{
"data": [
{
"id": 1,
"name": "nodejs in action test!!"
}
]
}
7、大功告成，下一步用pm2发布到服务器就行啦~
