背景说明
HTTP模块，一个轻量的，基于异步I/O的，以及事件驱动的 Web 服务器。
url模块，用于生成和解析URL，使用前，先加载。
querystring模块，http请求数据进行解析，提供4个方法：1、querystring.parse，将一个字符串反序列化为一个对象；2、querystring.stringify，将一个对象序列化成一个字符串，与querystring.parse是相对的；3、querystring.escape，escape可使传入的字符串进行编码；4、querystring.unescape，unescape方法可将含有%的字符串进行解码。
util模块，promisify()，Node.js内置的util模块的promisify()方法，将基于回调的函数转换为基于Promise的函数。可以将Promise链和async/await与基于回调的API结合使用。
工程结构
工程 │ app.js │ package.json │ ├─data │ user.json │ ├─router │ index.js │ ├─static │ login.html工程代码
app.js
const http = require('http'); const url = require('url'); const router = require('./router/index'); const app = http.createServer((req, res) => { // 当前请求方法 const method = req.method.toUpperCase(); console.log("当前请求方法：" + method); // 当前请求路径 const { pathname } = url.parse(req.url); console.log("当前请求方法：" + pathname); // GET处理 if (method === 'GET') { switch (pathname) { case '/': router.index(req, res) break; case '/index': router.index(req, res) break; case '/json': router.json(req, res) break; case '/query': router.query(req, res) break; } } // POST处理 if (method === 'POST') { switch (pathname) { case '/login': router.login(req, res) break; case '/register': router.register(req, res) break; } } }); app.listen(3000, () => { console.log('服务3000已启动.') });package.json
{ "name": "demo", "version": "1.0.0", "description": "", "main": "app.js", "scripts": { "start":"node app.js", "test": "echo \"Error: no test specified\" && exit 1" }, "keywords": [], "author": "", "license": "ISC" } router/index.js
const url = require('url'); const path = require('path'); const fs = require('fs'); const qs = require('querystring'); const { promisify } = require('util'); const readFile = promisify(fs.readFile); const writeFile = promisify(fs.writeFile); module.exports = { // 首页 index(req, res) { let appDir = path.dirname(require.main.filename); console.log("appDir=" + appDir + ", __dirname=" + __dirname); //读取静态文件并生成流 fs.readFile(appDir + '/static/login.html', function (err, data) { if (err) { res.writeHead(404, { 'Content-Type': 'text/html;charset=utf-8' }); res.write("页面不存在！404"); res.end(); } else { res.writeHead(200, { 'Content-Type': 'text/html;charset=utf-8' }); res.write(data.toString()); res.end(); } }); }, json(req, res) { res.status = 200; res.setHeader('Content-Type', 'application/json'); // res.writeHead(200, { 'Content-Type': 'application/json;charset=utf-8' }); res.end(JSON.stringify({ msg: 'json' })); }, // 查询 query(req, res) { const { query } = url.parse(req.url, true); res.status = 200 res.setHeader('Content-Type', 'application/json') res.end(JSON.stringify(query || {})) }, // 登录页面 login(req, res) { let array = []; req.on('data', (chunk) => { array.push(chunk); }) req.on('end', async () => { let params = Buffer.concat(array).toString(); params = qs.unescape(params); console.log("params>>>>>>" + params); let paramArray = params.split("&"); let loginData = {}; if (paramArray && paramArray.length > 0) { paramArray.forEach((item, index) => { let strs = item.split("="); if (strs.length >= 2) { loginData[strs[0]] = strs[1]; } }); } console.log("loginData>>>>>>" + loginData); try { const appDir = path.dirname(require.main.filename); const jsonPath = appDir + "/data/user.json"; let jsonData = await readFile(jsonPath, { encoding: 'utf8' }); console.log("jsonData>>>>>>" + jsonData); console.log("jsonData>>>>>>" + JSON.parse(jsonData || '[]')); let result = JSON.parse(jsonData || '[]').some(item => { console.log("loginData.username=" + loginData.username); console.log("item.username=" + item.username); console.log("loginData.password=" + loginData.password); console.log("item.password=" + item.password); return item.username === loginData.username && item.password === loginData.password }) if (result) { res.status = 200; res.setHeader('Content-Type', 'application/json') res.end(JSON.stringify({ msg: '登录成功' })) } else { res.status = 400; res.setHeader('Content-Type', 'application/json') res.end(JSON.stringify({ msg: '登录失败' })) } } catch (e) { res.status = 500; res.setHeader('Content-Type', 'application/json') res.end(JSON.stringify({ msg: '登录错误', err: e.message })) } }) }, register(req, res) { let array = []; req.on('data', (chunk) => { array.push(chunk); }) req.on('end', async () => { console.log("array.length", array.length); console.log("array", array); let params = Buffer.concat(array).toString(); // params username=%E7%94%A8%E6%88%B7&password=mima console.log("params", params); // params username=用户&password=mima params = qs.unescape(params) console.log("params", params); // let paramArray = params.split("&"); let objectArray = []; if (paramArray && paramArray.length > 0) { paramArray.forEach((item, index) => { let strs = item.split("="); if (strs.length >= 2) { let obj = {}; obj[strs[0]] = strs[1]; objectArray.push(obj); } }); } console.log("objectArray", objectArray); // 注册成功 res.status = 200; res.setHeader('Content-Type', 'application/json') res.end(JSON.stringify({ msg: '注册成功', data: objectArray })); }); } }static/login.html
<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>用户登录</title> <script src="https://cdn.bootcdn.net/ajax/libs/jquery/3.6.0/jquery.min.js"></script> <link href="https://cdn.bootcdn.net/ajax/libs/twitter-bootstrap/4.6.1/css/bootstrap.min.css" rel="stylesheet"> </head> <body> <div class="container " style="width:600px;"> <span> <h1>用户登录</h1> </span> <form method="post" action="/login"> <div class="form-group"> <label for="username">用户名:</label> <input id="username" name="username" type="text" class="form-control" value="" /> </div> <div class="form-group"> <label for="password">密码:</label> <input id="password" name="password" type="password" class="form-control" value="" /> </div> <button type="reset" class="btn btn-secondary">取消</button> <button type="submit" class="btn btn-danger">登录</button> </form> </div> </body> </html>data/user.json
[ { "id": "1", "username": "admin", "password": "admin123", "mobile": null, "email": null, "jobNumber": null, "nickname": null, "portraitId": null, "portraitAddress": null, "workPost": null, "workRole": null, "sorted": 1, "status": 1, "type": "1", "name": "用户", "idNumber": null, "remarks": null, "lockType": 1, "startTime": null, "expireTime": null, "orgId": "1501744401741774848", "orgName": "所属机构", "deptId": "1526411740659580928", "deptName": "所属部门", "orgLevel": 3, "orgTree": "1497055230288723968,1501744401741774848,1526411740659580928", "domainId": "1497055230288723968", "roleId": null, "hisUserId": null, "version": 0, "createUid": 0, "belongOrg": { "id": "1501744401741774848", "name": "所属机构", "code": "S2333", "type": 1, "status": 1, "parentId": "1497055230288723968", "treeLevel": 2, "parentFullPath": "1497055230288723968", "sorted": 1, "remarks": "", "belongOrgId": "1497055230288723968", "domainId": "1497055230288723968", "logicalDeleted": 0, "createUid": "1", "createUser": "super", "createTime": "2022-03-10T02:19:01.000+00:00", "modifiedUser": null, "modifiedTime": null, "deletedUser": null, "deletedTime": null, "children": null, "parentOrg": null, "fullPath": "1497055230288723968,1501744401741774848" }, "belongDept": { "id": "1526411740659580928", "name": "所属部门", "code": "B121212", "type": 4, "status": 1, "parentId": "1501744401741774848", "treeLevel": 3, "parentFullPath": "1497055230288723968,1501744401741774848", "sorted": 2, "remarks": "", "belongOrgId": "1501744401741774848", "domainId": "1497055230288723968", "logicalDeleted": 0, "createUid": "1", "createUser": "super", "createTime": "2022-05-17T03:58:13.000+00:00", "modifiedUser": null, "modifiedTime": null, "deletedUser": null, "deletedTime": null, "children": null, "parentOrg": null, "fullPath": "1497055230288723968,1501744401741774848,1526411740659580928" } } ]