2. Express 使用指南

www.expressjs.com.cn/

基于 Node.js 平台,快速、开放、极简的 Web 开发框架。提供了一系列强大特性帮助你创建各种Web 应用,和丰富的 HTTP 工具。使用 Express 可以快速地搭建一个完整功能的网站。

Express 框架核心特性:

  • 可以设置中间件来响应HTTP 请求。

  • 定义了路由表用于执行不同的HTTP 请求动作。

  • 可以通过向模板传递参数来动态渲染HTML 页面。

二、安装

通过npm安装:

$ npm i -S express
复制代码

安装完成后,我们可通过如下指令查看express版本号:

$ npm list express
└── express@4.17.1 
复制代码

以下模块是需要与express 框架一起安装的:

  • body-parser : nodeJS中间件,用于处理 JSON, Raw, Text 和 URL 编码的数据。

  • cookie-parser :解析Cookie的工具 。通过req.cookies可以取到传过来的cookie,并把它们转成对象。

  • multer :nodeJS中间件,用于处理 enctype="multipart/form-data"(设置表单的MIME编码)的表单数据。

$ npm i -S body-parser cookie-parser multer
复制代码

三、构建服务器

在项目根目录创建app.js文件

// 1. 导入express
const express = require("express");
// 2. 创建express实例
const app = express();
// 3. 监听 http://127.0.0.1:8081
app.listen(8081, "127.0.0.1");
// 4. 监听GET请求,用户访问路径 /
app.get("/", (req, res) => {
    // req -> request  -> 请求对象
    // res -> response -> 响应对象
  	// 响应,向前端发送数据
    res.send("Hello, express!");
});
// 5. 打印输出提示信息
console.log("server running at http://127.0.0.1:8081");
复制代码

终端执行脚本,运行app.js

$ node app.js
复制代码

在浏览器输入: http://127.0.0.1:8081 ,可看到页面输出“Hello, express!”

注意: listen 方法中的ip地址设置的是哪些ip能访问该服务器,而不是服务器地址,如果允许局域网内的所有设备访问该服务器,在设置 listen 方法的 ip 参数时可以设置为 ”0.0.0.0“,这样,局域网内的其他设备就可以通过服务器所在电脑的 ”ip地址:端口号“ 访问啦。

四、处理跨域

1. 允许所有域名跨域

app.all("*", (req, res, next) => {
    // 设置允许跨域的域名,*代表允许任意域名跨域
    res.header("Access-Control-Allow-Origin","*");
    // 允许的header类型
    res.header("Access-Control-Allow-Headers","content-type");
    // 跨域允许的请求方式 
    res.header("Access-Control-Allow-Methods","DELETE,PUT,POST,GET,OPTIONS");
    if (req.method.toLowerCase() == 'options')
        res.send(200);  // 让options尝试请求快速结束
    else
        next();
});
复制代码

2. 允许指定域名跨域

假定允许 “ http://127.0.0.1:5500 ” 访问:

app.all("*", (req, res, next) => {
    // 设置允许跨域的域名,*代表允许任意域名跨域
    res.header("Access-Control-Allow-Origin","http://127.0.0.1:5500");
    // 允许的header类型
    res.header("Access-Control-Allow-Headers","content-type");
    // 跨域允许的请求方式 
    res.header("Access-Control-Allow-Methods","DELETE,PUT,POST,GET,OPTIONS");
    if (req.method.toLowerCase() == 'options')
        res.send(200);  //让options尝试请求快速结束
    else
        next();
});
复制代码

3. 允许多个域名跨域

app.all("*", (req,res,next) => {
    //定义允许跨域的域名集合
    const origin_list = [
        "http://127.0.0.1:5500",
        "http://127.0.0.1:5501",
        "http://127.0.0.1:5502"
    ];
    if(origin_list.includes(req.headers.origin.toLowerCase())) {
        // 设置允许跨域的域名,*代表允许任意域名跨域
        res.header("Access-Control-Allow-Origin", req.headers.origin);
    }
    // 允许的header类型
    res.header("Access-Control-Allow-Headers","content-type");
    // 跨域允许的请求方式 
    res.header("Access-Control-Allow-Methods","DELETE,PUT,POST,GET,OPTIONS");
    if (req.method.toLowerCase() == 'options')
        res.send(200);  // 让options尝试请求快速结束
    else
        next();
});
复制代码

五、路由

1. 基本操作

路由是指如何定义应用的端点(URIs)以及如何响应客户端的请求。路由是一个由URI、HTTP请求(GET/POST等)和若干个句柄组成,它的语法结构如下:

app.method(path:string, hander:function)
复制代码

语法解读:

app
method
path
hande
// GET请求
// http://127.0.0.1:8081/
app.get("/", (req, res) => {
    console.log("有人通过GET访问:/");
}); 
app.get("/register", (req, res)=>{

})
// POST请求
// http://127.0.0.1:8081/login
app.post("/login", (req, res)  => {
    console.log("有人通过POST访问:/login");
});        
复制代码

2. 模块化配置

将路由定义在app.js文件中,不利于阅读维护,特别是在项目比较大的情况下,所以我们需要将路由模块化。比如项目有用户、和商品功能,那我们就定义2个路由,文件结构如下:

|- proj
   |- routes
  	  |- user.js
  	  |- order.js
|- app.js	
复制代码

路由分析:

- 用户接口 user
> 登录接口:POST /login
参数1 => username:string required
参数2 => password:string required

> 注册接口:POST /register
参数1 => username:string required
参数2 => password:string required
参数3 => tel: string options


- 订单接口 order
> 增 POST /order/add
> 删 GET  /order/delete
> 查 GET  /order/query
> 改 POST /order/modify
复制代码

user.js

// 1. 创建路由实例
const router = require("express").Router();
// 2. 配置路由
router.post("/login", (req, res) => {
    console.log("「登录接口」被调用");
});
router.post("/register", (req, res) => {
    console.log("「注册接口」被调用");
});
// 3. 导出路由
module.exports = router;
复制代码

order.js

// 1. 创建路由实例
const router = require("express").Router();
// 2. 配置路由
router.get("/", (req, res) => {
    console.log("「查询订单接口」被调用");
});
router.post("/add", (req, res) => {
    console.log("「添加订单接口」被调用");
});
router.post("/delete", (req, res) => {
    console.log("「删除订单接口」被调用");
});
router.post("/modify", (req, res) => {
    console.log("「修改订单接口」被调用");
});
// 3. 导出路由
module.exports = router;
复制代码

app.js

// 1. 导入express
const express = require("express")();
// 2. 获取express实例
const app = express();
// 3. 处理跨域
app.all("*", (req, res, next) => {
    // 设置允许跨域的域名,*代表允许任意域名跨域 CROS
    res.header("Access-Control-Allow-Origin","*");
    // 允许的header类型
    res.header("Access-Control-Allow-Headers","content-type");
    // 跨域允许的请求方式 
    res.header("Access-Control-Allow-Methods","DELETE,PUT,POST,GET,OPTIONS");
    if (req.method.toLowerCase() == 'options')
        res.send(200);  // 让options尝试请求快速结束
    else
        next();
});
// 4. 处理路由
const userRouter  = require("./routes/user");
const orderRouter = require("./routes/order");
app.use("/", userRouter);
app.use("/orders", orderRouter);

// 5. 监听 http://127.0.0.1:8081
app.listen(8081, "0.0.0.0");
// 6. 打印输出提示信息
console.log("server running at http://127.0.0.1:8081");
复制代码

六、参数

2.1. GET

通过 req.query 即可获取GET请求参数,而且最终获取的还是已经被转换为对象了的参数,在原生nodeJS实现中,我们还需要使用 queryString 模块来进行显式的转换。

2.2. POST

这里需要使用我们刚才安装的 body-parser 模块,获取POST参数,需注意以下几点:

  • 前端代码需要传递请求头,请求参数需以JSON字符串形式传递。

  • 后端代码需要添加中间件 body-parser牢记

  • 经过中间件的处理,参数会自动的添加到req请求对象上,作为其一个属性body

前端代码:

fetch("http://127.0.0.1:8081/login", {
    method: "post",
    body: JSON.stringify({
        username: "admin",
        password: "123"
    }),
    headers: {
        "Accept": "application/json",
        "Content-Type": "application/json"
    }
})
.then(res => res.json())
.then(res => {
    console.log(res);
});
复制代码

后端代码:

// 4. 中间件
const bodyParser = require("body-parser");
// application/x-www-form-urlencoded 解析
app.use(bodyParser.urlencoded({extended:false}));
// application/json 解析
app.use(bodyParser.json());
// 5. 路由配置
app.post("/login", (req, res) => {
    // 打印参数
    console.log(req.body);
    // 响应数据
    res.send({
        nikename: "木子李",
        tel: "152-2888-5771",
        address: "成都市高新区雅和南四路216号"
    });
});
复制代码

关于body-parser中间件详细内容可参考如下文章:

www.jianshu.com/p/ea0122ad1…

七、请求与响应

  • request :HTTP请求对象,包含了请求查询字符串,参数,内容,HTTP 头部等属性
  • response :HTTP 响应对象,即在接收到请求时向客户端发送的 HTTP 响应数据

在Express中,请求对象与响应对象作为路由处理函数的参数返回,如下所示:

app.get("/", (req, res) => {
   req.body  // => 读取post参数
   req.query // => 读取get参数
   res.send  // => 响应客户端
});
复制代码

关于req、res常用属性和方法,点击上述链接进入API文档查看。

八、静态资源访问

通过Express 提供的内置中间件

express.static

,我们可以实现访问静态资源(如图片、CSS、JavaScript等)的需求。例如,如果将图片、CSS、JavaScript 文件放在 www 目录下,你可以这么写:

app.use(express.static("www"));
复制代码

那我们即可在浏览器中通过” http://127.0.0.1:8081/images/logo.png“访问静态资源了。

服务器端静态资源的文件结构如下:

|- proj
	 └── routes
	 └── app.js
	 └── www
  	 		└── images
  	 		└── javascripts 		
  	 		└── stylesheets
复制代码

总结:

\1. 在最开始处使用express内置的static中间件,来实现静态文件的访问。

\2. 前端访问时,地址栏只需输入服务器地址 + express.static 参数内的路径和文件名称即可。

九、链接数据库

1. 流程

a)、安装mysql模块

$ npm i -S mysql
复制代码

b)、导入mysql模块

const mysql = require("mysql");
复制代码

c)、链接数据库

const connection = mysql.createConnection({
    // 主机名
    host: '127.0.0.1',
    // 端口
    port: '3306',
    // 用户名
    user: 'root',
    // 密码
    password: '1234',
    // 数据库名
    database: 'db_test'
});
connection.connect(); // 启动连接
// 数据库操作...
connection.end(); // 关闭连接
复制代码

更多参数参考: www.npmjs.com/package/mys…

2. 操作

在连接数据库的情况下我们开始操作数据库链接对象:connection。

mysql 数据库heros表中的字段信息:

mysql 数据库heros表中的数据信息:

2.1. 查询数据库信息

-> 语法形式:

connection.query(sql,function (err, sqlRes) {});
复制代码

-> 参数解读:

sql
function(){}

-> 代码示例:

connection.connect();
const sql = "SELECT * FROM heros";
function fn(err, sqlRes) {
    if(err) {
        console.log(err.message);
    }else {
        console.log(sqlRes);
    }
}
connection.query(sql, fn)
connection.end();  // 操作完数据库记得关闭链接
复制代码

-> 注意事项:

1)如果你想通过定时器来循环操作数据库,那么数据库的开启链接语句一定要放在这些语句之外。

2)关闭链接语句要写的话也应该写在定时执行的函数里面,不然定时器执行一次,链接就会关掉,就无法在操作数据库了。

3)关闭链接后,获取数据库链接对象只能重新执行*mysql.createConnection()*方法。

4)不能多次重复调用 .connect() 方法,否则会报错。

5)不能多次重复调用 .end() 方法,否则会报错。

-> 查询结果:

-> 遍历结果:

实际上查询出的结果是一个对象数组,我们可以通过下标与键取出其中详细数据,也能通过循环将其所有值遍历出来

-> 1. 单独取值:

reqRes.[0];
reqRes.[0].name;
复制代码

-> 2. 遍历取值

for(let i = 0, len = reqRes.length; i < len; i++) {
    console.log(reqRes[i]);
}
复制代码

-> 3. 将查询结果返回给前端

可以看到,都不需要做什么处理,直接把查询结果用 JSON.parse(sqlRes) 转换为字符串就可以发到前端了,前端在转换为对象数组就能直接用了

-> 4. 条件查询

-> 5. 预编译写法

其实这里可以写成预编译的方式,可以避免sql注入的问题,所谓预编译就是说对于原本在sql里面写值换成 占位,然后传入一个数组进去补全这个占位符,也就是 connect.query 方法会多一个参数,为一个数组,放入第二个位置。

2.2. 修改数据库信息

-> 语法形式:

connection.query(sql, sqlParams, function (err, sqlRes) {});
复制代码

-> 参数解读:

  • sql :sql指令,如: UPDATE heros SET location=? WHERE name=?
  • sqlParams :sql参数,如: ["上路", "周瑜"]
  • function(){} :执行结果回调函数

-> 代码示例:

提示:我们可通过影响行数 affectedRows 属性判断是否修改成功。

2.3. 添加数据信息

-> 语法形式:

connection.query(sql, sqlParams, function (err, sqlRes) {});
复制代码

-> 参数解读:

  • sql :sql指令,如: INSERT INTO heros (name, skill) VALUES (?, ?)
  • sqlParams :sql参数,如: ["貂蝉", "绽·风华"]
  • function(){} :执行结果回调函数

-> 代码示例:

2.4. 删除数据信息

-> 语法形式:

connection.query(sql, sqlParams, function (err, sqlRes) {});
复制代码

-> 参数解读:

  • sql :sql指令,如: DELETE FROM heros WHERE name=?
  • sqlParams :sql参数,如: ["貂蝉"]
  • function(){} :执行结果回调函数

-> 代码示例:

3. 链接数据库封装

3.1. 概述

在上面我们每次操作数据库都要先连接下数据库,然后才能操作,那么我们是否能够把数据的链接封装起来呢,这样每次直接获取链接对象,来操作数据库即可,会方便不少。

3.2. 示例

const mysql = require("mysql");
const defaultOptions = {
    host: '127.0.0.1',
    port: '3306',
    user: 'root',
    password: '1234',
    database: 'db_test'
}
function getConnection(options = defaultOptions) {
    return mysql.createConnection(options);
}
module.exports = getConnection;
复制代码

使用

const getConnection = require("./mysqlConnection");
const db = getConnection();
app.get("/heros", (req, res) => {
    db.connect();
    const sql = "SELECT * FROM heros";
    function fn(err, sqlRes) {
        if(err) {
            console.log(err.message);
        }else {
            res.end(JSON.stringify(sqlRes));
        }
    }
    db.query(sql, fn)
    db.end();
});
复制代码
我来评几句
登录后评论

已发表评论数()

相关站点

+订阅
热门文章