【Node.js从基础到高级运用】十三、NodeJS中间件高级应用

news2024/9/23 9:26:46

在现代web开发中，Node.js因其高效和灵活性而备受青睐。其中，中间件的概念是构建高效Node.js应用的关键。在这篇博客文章中，我们将深入探讨Node.js中间件的高级应用，包括创建自定义中间件、使用第三方中间件等。我们将从基础讲起，逐步深入，旨在为读者提供全面而深入的指南。

中间件简介

在Node.js中，中间件是一个函数，它可以访问请求对象（req）、响应对象（res）和应用程序的请求/响应循环中的下一个中间件函数。这些函数可以执行以下任务：

  • 执行任何代码。
  • 修改请求和响应对象。
  • 结束请求/响应循环。
  • 调用堆栈中的下一个中间件函数。

如果当前中间件函数没有结束请求/响应循环，它必须调用next()方法将控制权传递给下一个中间件函数，否则请求将被挂起。

中间件的类型

在 Node.js 中，根据用途和功能的不同，中间件大体可以分为以下几类：

  • 应用级中间件： 通过使用 app.use() 和 app.METHOD() 函数加载，并且可以执行任何代码、修改请求和响应对象、结束请求-响应循环、调用下一个中间件。

  • 路由级中间件： 和应用级中间件相似，但它绑定到一个实例上 express.Router()。

  • 错误处理中间件： 用来处理应用中发生的各种错误。这类中间件通常定义了四个参数 (err, req, res, next)。

  • 内置中间件： Express 框架自带的中间件，例如 express.static，用于提供静态资源。

  • 第三方中间件： 由社区开发，需要通过 npm 安装，可以提供额外的功能，比如解析请求体、处理 cookie 等。

创建自定义中间件

自定义中间件是扩展Express应用功能的基石。它允许我们对进入的请求进行预处理、实施安全检查、处理日志等。

示例：追踪请求时间

// 追踪请求处理时间的中间件
function requestTimeLogger(req, res, next) {
    const start = Date.now(); // 请求开始时间
    res.on('finish', () => { // 响应结束时触发
        const duration = Date.now() - start; // 计算处理时长
        console.log(`${req.method} ${req.url} - ${duration}ms`); // 记录请求方法、URL和处理时长
    });
    next(); // 继续处理请求
}

app.use(requestTimeLogger); // 将中间件添加到应用中

运行结果:
结合之前学过的books demo完成测试：
在这里插入图片描述

使用express.static提供静态文件服务

const express = require('express');
app.use(express.static('public')); // `public`目录下的文件现在可以通过Web访问了

创建public文件夹，在该文件夹下创建index.html文件，打开本地服务默认为index页面

使用第三方中间件

第三方中间件大大简化了常见功能的实现，如体解析、Cookie处理等。

示例：使用cors中间件管理跨源请求

const cors = require('cors'); // 引入cors中间件

app.use(cors()); // 应用cors中间件，允许所有跨域请求

这行代码使得我们的Node.js应用可以接受跨域请求，极大地简化了配置过程

响应格式化中间件

// 响应格式化中间件
function responseFormatter(req, res, next) {
    res.apiResponse = (data, error = null) => {
        if (error) {
            res.status(500).json({ success: false, error }); // 发送错误响应
        } else {
            res.status(200).json({ success: true, data }); // 发送成功响应
        }
    };
    next();
}

app.use(responseFormatter);

中间件组合应用

请求时间记录和请求大小限制

这个例子中，我们将使用两个自定义中间件，一个用于记录请求时间，另一个用于限制请求体的大小。

const express = require('express');
const bodyParser = require('body-parser');

const app = express();

// 中间件1: 记录请求时间
app.use((req, res, next) => {
  req.requestTime = Date.now(); // 添加一个新属性来保存请求时间
  next(); // 调用下一个中间件
});

// 中间件2: 限制请求体的大小
app.use(bodyParser.json({ limit: '10kb' })); // 使用body-parser限制请求体大小为10kb

// 路由处理
app.get('/', (req, res) => {
  const responseText = `Requested at: ${req.requestTime}`; // 使用中间件1添加的属性
  res.send(responseText);
});
// 测试限制请求体大小
app.post('/', (req, res) => {
  res.send('Received your request!');
});
// 添加错误处理中间件来观察限制
app.use((err, req, res, next) => {
  if (err instanceof SyntaxError && err.status === 400 && 'body' in err) {
    // 当请求体过大时，body-parser会抛出一个错误
    return res.status(413).send({ message: 'Request entity too large' });
  }
  // 如果不是请求体大小的问题，继续传递错误
  next(err);
});
// 启动服务器
app.listen(3000, () => {
  console.log('Server is running on port 3000');
});

运行结果：
在这里插入图片描述

条件性中间件和资源压缩

在这个例子中，我们将创建一个条件性中间件，用于根据请求的路径决定是否压缩响应。我们还会使用compression中间件来进行资源压缩。

const express = require('express');
const compression = require('compression');

const app = express();

// 条件性中间件: 只有请求路径为"/compress"时才使用compression中间件
app.use((req, res, next) => {
  if (req.path === '/compress') {
    compression()(req, res, next); // 调用compression中间件
  } else {
    next(); // 不需要压缩，直接调用下一个中间件
  }
});

// 路由处理
app.get('/compress', (req, res) => {
  // 发送一个大文本，压缩后传输
  const largeText = '...'; // 假设这里是一个很大的文本内容
  res.send(largeText);
});

app.get('/no-compress', (req, res) => {
  // 发送一个文本，不进行压缩
  res.send('This response is not compressed.');
});

// 启动服务器
app.listen(3000, () => {
  console.log('Server is running on port 3000 with conditional compression');
});

我们要做的是向/compress路由发送一个GET请求，并观察返回的响应头信息。检查响应头中的Content-Encoding是否包含gzip，这表明响应已经被压缩。

运行结果：
响应数据太小，没有达到压缩的阈值：
在这里插入图片描述

足够大的数据响应:

// 路由处理
app.get('/compress', (req, res) => {
  // 发送一个大文本，压缩后传输
  const largeText = '这是一个重复的大文本字符串，用于生成足够大的响应体来触发压缩。'.repeat(1000);
  res.send(largeText);
});

在这里插入图片描述

API速率限制和缓存

在这个例子中，我们将使用express-rate-limit来限制API的调用速率，以及使用简单的内存缓存来存储响应数据，减少重复计算。

mcache.put是memory-cache库中的一个方法，用于将数据存储在内存中。它接受三个参数：
key（字符串）：用于存储和检索缓存值的唯一标识符。
value（任意类型）：要存储在缓存中的数据。
time（毫秒）：缓存数据在内存中存储的时间。超过这个时间后，数据将从缓存中删除。

const express = require('express');
const rateLimit = require('express-rate-limit');
const mcache = require('memory-cache');

const app = express();

// API速率限制中间件
const limiter = rateLimit({
  windowMs: 15 * 60 * 1000, // 15分钟
  max: 100 // 在15分钟内每个IP最多100次请求
});

// 应用API速率限制中间件
app.use('/api', limiter);

// 缓存中间件
const cache = (duration) => {
  return (req, res, next) => {
    let key = '__express__' + req.originalUrl || req.url;
    let cachedBody = mcache.get(key);
    if (cachedBody) {
      res.send(cachedBody);
      return;
    } else {
      res.sendResponse = res.send;
      res.send = (body) => {
        mcache.put(key, body, duration * 1000);// 将响应体存储在缓存中，duration以秒为单位
        res.sendResponse(body);
      };
      next();
    }
  };
};

// 路由处理
app.get('/api/expensive-data', cache(30), (req, res) => {
  // 假设这里有一些计算成本很高的数据生成过程
  const expensiveData = 'Expensive Data';
  res.send(expensiveData);
});

// 启动服务器
app.listen(3000, () => {
  console.log('Server is running on port 3000 with rate limiting and caching');
});
限制API调用速率

为了测试例子3中限制API调用速率的功能，我们可以快速连续发送多个请求到服务器的/api路由。如果超过了限制的数量，服务器应该返回429状态码（Too Many Requests）。
使用curl命令来测试API速率限制：

for i in {1..101}; do curl -X GET http://localhost:3000/api/expensive-data; done

在这里插入图片描述
这个命令会连续发送101个GET请求到/api/expensive-data。由于我们设置了15分钟内每个IP最多100次请求，所以在第101次请求时，将会收到Too many requests, please try again later.

测试内存缓存

为了测试内存缓存的功能，我们可以发送两次请求到同一个路由，并观察响应时间。第一次请求会生成数据并将其缓存，而第二次请求应该会直接从缓存中获取数据，响应时间应该更短。

app.get('/api/cache-data', cache(30), (req, res) => {
  // 假设这里有一些计算成本很高的数据生成过程
  const largeText = '这是一个重复的大文本字符串，用于生成足够大的响应体来触发压缩。'.repeat(1000);
  res.send(largeText);
});

使用curl命令来测试内存缓存：

# 第一次请求
time curl -X GET http://localhost:3000/api/cache-data

# 等待几秒钟

# 第二次请求
time curl -X GET http://localhost:3000/api/cache-data

time命令会显示curl命令执行所需的时间。第二次请求应该比第一次快，因为它应该是从缓存中获取数据。
第一次：
在这里插入图片描述
第二次：
在这里插入图片描述

总结

在上述例子中，我们展示了如何使用Node.js中间件进行请求时间记录、请求大小限制、条件性资源压缩、API速率限制以及简单的内存缓存。这些中间件的组合运用能够帮助你构建更加健壮和高效的Node.js应用程序。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1527038.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

qt vs 编程 字符编码 程序从源码到编译到显示过程中存在的字符编码及隐藏的字符编码转换

qt vs 编程 字符编码 程序从源码到编译到显示过程中存在的字符编码及隐藏的字符编码转换

理解字符编码，请参考：unicode ucs2 utf16 utf8 ansi GBK GB2312 CSDN博客 了解windows字符显示必须了解locale概念 参考：揭密 Windows 上的各种 locale - 知乎 汉字（或者说多字节字符）的存放需求，是计算…
阅读更多...
【CSP试题回顾】202309-2-坐标变换（其二）

【CSP试题回顾】202309-2-坐标变换（其二）

CSP-202309-2-坐标变换&#xff08;其二&#xff09; 解题代码 #include <iostream> #include <vector> #include <cmath> #include <iomanip> using namespace std;struct MyOpt {double k, theta; }; int n, m, opt, s, e; double para, x, y;int …
阅读更多...
Java项目：62 基于ssm的校园驿站管理系统+jsp

Java项目：62 基于ssm的校园驿站管理系统+jsp

作者主页&#xff1a;舒克日记 简介&#xff1a;Java领域优质创作者、Java项目、学习资料、技术互助 文中获取源码 项目介绍 管理员管理快递仓库信息&#xff0c;管理待发货信息&#xff0c;管理已收快递&#xff0c;管理物流以及留言信息&#xff0c;管理员工和用户资料。 员…
阅读更多...
C++——字符串、读写文件、结构体、枚举

C++——字符串、读写文件、结构体、枚举

个人简介 &#x1f440;个人主页&#xff1a; 前端杂货铺 &#x1f64b;‍♂️学习方向&#xff1a; 主攻前端方向&#xff0c;正逐渐往全干发展 &#x1f4c3;个人状态&#xff1a; 研发工程师&#xff0c;现效力于中国工业软件事业 &#x1f680;人生格言&#xff1a; 积跬步…
阅读更多...
【Java】高级篇1：异常处理

【Java】高级篇1：异常处理

异常&#xff1a;程序在执行过程中出现的非正常情况&#xff0c;如果不处理最终会导致JVM的非正常停止。 Java的异常抛出机制 Java异常体系 1、Throwable 2、Error和Exception 异常处理方式 1、try-catch-finally&#xff08;捕获异常&#xff09; 基本结构&#xff1a; 使用…
阅读更多...
B140XW01 V8 +OZ9956B PDF

B140XW01 V8 +OZ9956B PDF

B140XW01 V8 PDF OZ9956B 14B38-COW 18650串联50欧点亮一颗灯珠
阅读更多...
代码随想录算法训练营第11天| 20. 有效的括号，1047. 删除字符串中的所有相邻重复项，150. 逆波兰表达式求值

代码随想录算法训练营第11天| 20. 有效的括号，1047. 删除字符串中的所有相邻重复项，150. 逆波兰表达式求值

系列文章目录 目录 系列文章目录20. 有效的括号利用栈对称匹配将栈中元素弹出与判断栈顶元素是否匹配分开&#xff0c;比较耗时&#xff08;2ms)&#xff1a;若将栈中元素弹出与判断栈顶元素是否匹配放一起&#xff0c;比较节省时间(1ms)&#xff1a; 1047. 删除字符串中的所有…
阅读更多...
探索区块链世界：从加密货币到去中心化应用

探索区块链世界：从加密货币到去中心化应用

相信提到区块链&#xff0c;很多人会想到比特币这样的加密货币&#xff0c;但实际上&#xff0c;区块链技术远不止于此&#xff0c;它正在深刻地改变我们的生活和商业。 首先&#xff0c;让我们来简单了解一下什么是区块链。区块链是一种分布式数据库技术&#xff0c;它通过将…
阅读更多...
MySQL的insert-on-duplicate语句详解

MySQL的insert-on-duplicate语句详解

一、insert-on-duplicate语句语法 注意&#xff1a;ON DUPLICATE KEY UPDATE只是 MySQL的特有语法&#xff0c;并不是SQL标准语法&#xff01; INSERT INTO … ON DUPLICATE KEY UPDATE 是 MySQL 中一种用于插入数据并处理重复键冲突的语法。 这个语法适用于在 insert的时候…
阅读更多...
操作系统核心知识点大梳理

操作系统核心知识点大梳理

计算机结构 现代计算机模型是基于-冯诺依曼计算机模型 计算机在运行时&#xff0c;先从内存中取出第一条指令&#xff0c;通过控制器的译码&#xff0c;按指令的要求&#xff0c;从存储器中取出数据进行指定的运算和逻辑操作等加工&#xff0c;然后再按地址把结果送到内存中去…
阅读更多...
做跨境用哪种代理IP比较好？怎么选到干净的IP？

做跨境用哪种代理IP比较好？怎么选到干净的IP？

代理IP对于做跨境的小伙伴来说&#xff0c;都是必不可少的工具&#xff0c;目前出海的玩法已经是多种多样&#xff0c;开店、账号注册、短视频运营、直播带货、网站SEO等等都是跨境人需要涉及到的业务。而国外代理IP的获取渠道非常多&#xff0c;那么做跨境到底应该用哪种代理I…
阅读更多...
Servlet两种配置

Servlet两种配置

通过xml配置 <servlet><servlet-name>MyServlet</servlet-name><servlet-class>MyServlet</servlet-class> </servlet> <servlet-mapping><servlet-name>MyServlet</servlet-name><url-pattern>/MyServlet</ur…
阅读更多...
Excel数据可视化

Excel数据可视化

饼图 1、选中数据----点击插入----点击饼图 2、更改数据标签&#xff08;修改标题名直接改就行&#xff09; 柱形图 1、选中数据、点击插入二维柱形图 坐标轴问题----切换行和列 如何将横轴变成想要的4、5、6、7月&#xff1f; &#xff08;1&#xff09;右键----选择数据 -…
阅读更多...
传值、传址、空间释放详细图解

传值、传址、空间释放详细图解

目录 前言 一.进程 1.1 进程的映射 1.2 进程的虚拟空间 二.函数传参 2.1 函数传参 2.2 函数传值 2.2.1 函数传值案例1 2.2.2 函数传值案例2 2.2.3 返回值为常量 2.3 函数传送地址 2.3 字符串使用 前言 详细介绍函数传值和传地址区别&#xff1a;进行数据操作的区别&#xff0c…
阅读更多...
08｜记忆：通过Memory记住客户上次买花时的对话细节

08｜记忆：通过Memory记住客户上次买花时的对话细节

无论是LLM还是代理都是无状态的&#xff0c;每次模型的调用都是独立于其他交互的。也就是说&#xff0c;我们每次通过API开始和大语言模型展开一次新的对话&#xff0c;它都不知道你其实昨天或者前天曾经和它聊过天了。 使用ConversationChain from langchain import OpenAI…
阅读更多...
中国国际光伏展

中国国际光伏展

河北省京津冀国际光伏展是一个旨在推动光伏产业发展的展览会。该展览会的举办地点在河北省&#xff0c;也被称为京津冀地区&#xff0c;这个地区是中国重要的经济发展区域之一&#xff0c;拥有丰富的太阳能资源和光伏产业基础。 光伏展览会将展示最新的光伏技术、产品和解决方案…
阅读更多...
ABS210-ASEMI新能源专用整流桥ABS210

ABS210-ASEMI新能源专用整流桥ABS210

编辑&#xff1a;ll ABS210-ASEMI新能源专用整流桥ABS210 型号&#xff1a;ABS210 品牌&#xff1a;ASEMI 封装&#xff1a;ABS-4 正向电流&#xff08;Id&#xff09;&#xff1a;2A 反向耐压&#xff08;VRRM&#xff09;&#xff1a;1000V 正向浪涌电流&#xff1a;3…
阅读更多...
Fabric.js在vue2中使用

Fabric.js在vue2中使用

Fabric.js安装 这里我是基于vue来使用的&#xff0c;先安装上Fabric.js npm install fabric 在main.js中 import fabric from fabric Vue.use(fabric);Fabric 提供了 7 种基础形状&#xff1a; fabric.Circle (圆)fabric.Ellipse (椭圆)fabric.Line (线)fabric.Polyline (多条…
阅读更多...
汽车电子零部件（8）：T_Box

汽车电子零部件（8）：T_Box

前言： 网联汽车（Connected Vehicles ，CV）是一个广泛的概念，四个主要的CV线程已发展起来：互联、自主、共享和电动。这些应用于包括CV在内的垂直领域：汽车、通信、互联网和共享手机服务。中国汽车工程师学会（SAEC）提倡将车载ADAS（高级驾驶员辅助系统）与通信技术相结合…
阅读更多...
概述工业4.0时代的数据采集

概述工业4.0时代的数据采集

在当今全球制造业转型升级的大潮中&#xff0c;工业4.0以其智能化、网络化和个性化的特征&#xff0c;引领了新的工业革命。其中&#xff0c;数据采集作为工业4.0的核心要素&#xff0c;是实现智能制造的关键环节&#xff0c;它的重要性不言而喻。 工业4.0时代的数据采集&#…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023