只需4步使用Redis缓存优化Node.js应用

介绍

通过API获取数据时，会向服务器发出网络请求，收到响应数据。但是，此过程可能非常耗时，并且可能会导致程序响应时间变慢。

我们使用缓存来解决这个问题，客户端程序首先向API发送请求，将返回的数据存储在缓存中，之后的请求都从缓存中查找数据，而不是向API发送请求。

在本文中，使用 Redis做为缓存， 在 Node.js 的程序中通过4步实现数据缓存的机制。

第 1 步 — 设置项目

在此步骤中，我们将安装该项目所需的依赖项并启动 Express 服务器。

首先，为项目创建目录mkdir：

mkdir app

进入目录：

cd app

初始化项目：

npm init -y

它将创建package.json包含以下内容的文件：

{"name": "app","version": "1.0.0","description": "","main": "index.js","scripts": {"test": ""},"keywords": [],"author": "","license":"ISC"
}

接下来，使用以下命令安装express，redis，axios库：

npm install express redis axios

完成后，app目录结构如下：

app
--node_modules
--package-lock.json
--package.json

创建index.js文件，并输入以下代码：

const express = require("express"); 
const app = express();  
const port = process.env.PORT || 3000;  app.listen(port, () => { console.log(`App listening on port ${port}`);
});

保存并运行以下命令：

node index.js

输出如下：

image.png

步骤 2 — 通过API获取数据

在刚才的index.js中增加从API获取数据的部分：

const express = require("express"); 
const app = express();  
const port = process.env.PORT || 3000;  async function fetchDataFromApi(userId) {let apiUrl = 'https://xxxx/api';if (characterId) {apiUrl = `${apiUrl}/user/${userId}`;} else {apiUrl = `${apiUrl}/user`;}const apiResponse = await axios.get(apiUrl);console.log("发送API请求");return apiResponse.data;
}app.get("/user/:id", async (req, res) => {try {const character = await fetchDataFromApi(req.params.id);if (!character.length) {throw new Error("请求异常");}return res.status(200).send({fromCache: false,data: character,});} catch (error) {console.log(error);res.status(404).send("请求异常");}
});app.get("/user", async (req, res) => {try {const characters = await fetchDataFromApi();if (!characters.length) {throw new Error("请求异常");}return res.status(200).send({fromCache: false,data: characters,});} catch (error) {console.log(error);res.status(404).send("请求异常");}
});app.listen(port, () => { console.log(`App listening on port ${port}`);
});

运行 node index.js启动服务器，之后打开 Postman 发送请求/user, 请求耗时 885 毫秒。为了加快请求速度，我们增加 Redis 缓存。

第 3 步 — 增加 Redis 缓存

增加缓存，只有初始访问才会从API请求数据，所有后续请求都从缓存中获取数据。

在项目中导入redis模块：

const redis = require ( "redis" );

添加以下代码连接到Redis：

let redisClient;(async () => {redisClient = redis.createClient();redisClient.on("error", (error) => console.error(`Error : ${error}`));await redisClient.connect();
})();

使用redisClient.get()从缓存中获取数据。如果数据存在，我们将isCached设置为 true 并分配cachedResult给result，如果cachedResult为空，则我们调用API获取数据，然后使用redisClient.set()设置到缓存中。

const redisKey = "user";  
let results;  
let isCached = false;  const cachedResult = await redisClient.get(redisKey);  
if (cachedResult) {  isCached = true;  results = JSON.parse(cachedResult);  
} else {  results = await fetchDataFromApi();  if (!results.length) {  throw new Error("请求异常");  }  await redisClient.set(redisKey, JSON.stringify(results));  
}

完整的文件如下：

const express = require("express"); 
const app = express();  
const port = process.env.PORT || 3000;  let redisClient;(async () => {redisClient = redis.createClient();redisClient.on("error", (error) => console.error(`Error : ${error}`));await redisClient.connect();
})();async function fetchDataFromApi(userId) {let apiUrl = 'https://xxxx/api';if (characterId) {apiUrl = `${apiUrl}/user/${userId}`;} else {apiUrl = `${apiUrl}/user`;}const apiResponse = await axios.get(apiUrl);console.log("发送API请求");return apiResponse.data;
}app.get("/user/:id", async (req, res) => {try {const redisKey = `user-${req.params.id}`; let results;let isCached = false;const cachedResult = await redisClient.get(redisKey);if (cachedResult) {isCached = true;results = JSON.parse(cachedResult);} else {results = await fetchDataFromApi(req.params.id);if (!results.length) {throw new Error("请求异常");}await redisClient.set(redisKey, JSON.stringify(results));}return res.status(200).send({fromCache: isCached,data: results,});} catch (error) {console.log(error);res.status(404).send("请求异常");}
});app.get("/user", async (req, res) => {try {const redisKey = "user";let results;let isCached = false;const cachedResult = await redisClient.get(redisKey);if (cachedResult) {isCached = true;results = JSON.parse(cachedResult);} else {results = await fetchDataFromApi();if (!results.length) {throw new Error(请求异常");}await redisClient.set(redisKey, JSON.stringify(results));}return res.status(200).send({fromCache: isCached,data: results,});} catch (error) {console.log(error);res.status(404).send("请求异常");}
});app.listen(port, () => { console.log(`App listening on port ${port}`);
});

保存并运行以下命令：

node index.js

服务启动后，我们通过Postman发送请求，发现第一次请求比较慢，后边的请求速度都变快了，从868毫秒缩短到14毫秒。

到目前为止，我们可以从 API 获取数据，并把数据设置到到缓存中，后续请求从缓存中取数据。
为了防止API端数据变化，但是缓存数据没变的情况，还需要设置缓存有效性。

第 4 步 — 设置缓存有效性

当缓存数据时，要设置合适的过期时间，具体时间可以根据业务情况决定。
在本文中，将缓存持续时间设置为120秒。

在index.js中增加以下内容：

await redisClient.set(redisKey, JSON.stringify(results), {  EX: 120,  NX: true,  
});
  • EX：缓存有效时间（单位：秒）。
  • NX：当设置为时true，set()方法只设置 Redis 中不存在的键。

把以上代码添加到API接口中：

app.get("/user/:id", async (req, res) => {try {const redisKey = `user-${req.params.id}`; results = await fetchDataFromApi(req.params.id);if (!results.length) {throw new Error("请求异常");}await redisClient.set(redisKey, JSON.stringify(results), {  EX: 120,  NX: true,  });return res.status(200).send({fromCache: isCached,data: results,});} catch (error) {console.log(error);res.status(404).send("请求异常");}
});app.get("/user", async (req, res) => {try {const redisKey = "user";results = await fetchDataFromApi(); if (!results.length) {throw new Error("请求异常");}await redisClient.set(redisKey, JSON.stringify(results), {  EX: 120,  NX: true,  });return res.status(200).send({fromCache: isCached,data: results,});} catch (error) {console.log(error);res.status(404).send("请求异常");}
});app.listen(port, () => { console.log(`App listening on port ${port}`);
});

现在创建一个中间件，从缓存中获取数据：

async function cacheData(req, res, next) {try {const characterId = req.params.id;let redisKey = "user";if (characterId) {redisKey = `user-${req.params.id}`;}const cacheResults = await redisClient.get(redisKey);if (cacheResults) {res.send({fromCache: true,data: JSON.parse(cacheResults),});} else {next();}} catch (error) {console.error(error);res.status(404);}
}

把cacheData加入到API调用中

app.get("/user/:id", cacheData, async (req, res) => {  try {  const redisKey = `hogwarts-character-${req.params.id}`;  results = await fetchDataFromApi(req.params.id);  if (!results.length) {  throw new Error("请求异常");  }  await redisClient.set(redisKey, JSON.stringify(results), {  EX: 120,  NX: true,  });  return res.status(200).send({  fromCache: false,  data: results,  });  } catch (error) {  console.log(error);  res.status(404).send("请求异常");  }  
});  app.get("/user", cacheData, async (req, res) => {  try {  const redisKey = "user";  results = await fetchDataFromApi();  if (!results.length) {  throw new Error("请求异常");  }  await redisClient.set(redisKey, JSON.stringify(results), {  EX: 120,  NX: true,  });  return res.status(200).send({  fromCache: false,  data: results,  });  } catch (error) {  console.log(error);  res.status(404).send("请求异常");  }  
});

当访问API时/user，cacheData()首先执行。如果数据被缓存，它将返回响应。如果在缓存中没有找到数据，则会从API请求数据，将其存储在缓存中，并返回响应。

再次利用Postman来验证接口，发现响应时间只有15毫秒左右。

总结

在本文中，我们构建了一个 Node.js 程序，该程序 API 获取数据并使用Redis进行缓存，只有初次请求和缓存过期后才从API获取数据，之后的请求都从缓存中获取数据，大大缩短请求所用的时间。

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

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

相关文章

文档丢失怎么找回？学会这3个方法就足够！

文档丢失怎么找回？学会这3个方法就足够！

场景1：“不是吧！我辛辛苦苦写的文档好像忘记保存就退出了！谁能救救我！帮我找回丢失的文档？” 场景2：“电脑里的文档太多了，每次在清理时都容易误删。有什么方法可以找回我丢失的文档吗&#xff…
阅读更多...
成集云 | 用友T+集成聚水潭ERP（用友T+主管库存）| 解决方案

成集云 | 用友T+集成聚水潭ERP（用友T+主管库存）| 解决方案

源系统成集云目标系统 方案介绍 用友T是一款由用友畅捷通推出的新型互联网企业管理系统，它主要满足成长型小微企业对其灵活业务流程的管控需求，并重点解决往来业务管理、订单跟踪、资金、库存等管理难题。 聚水潭是一款以SaaS ERP为核心，集…
阅读更多...
嵌入式笔试面试刷题(day15)

嵌入式笔试面试刷题(day15)

文章目录 前言一、Linux中的主设备号和次设备号1.查看方法2.主设备号和次设备号的作用 二、软件IIC和硬件IIC的区别三、变量的声明和定义区别四、static在C和C中的区别五、串口总线空闲时候的电平状态总结 前言 本篇文章继续讲解嵌入式笔试面试刷题，希望大家坚持跟…
阅读更多...
pgzrun 拼图游戏制作过程详解（10）

pgzrun 拼图游戏制作过程详解（10）

10. 拼图游戏继续升级——多关卡拼图 初始化列表Photos用来储存拼图文件名，Photo_ID用来统计当下是第几张拼图，Squares储存当下拼图的24张小拼图的文件名，Gird储存当下窗口上显示的24个小拼图及坐标。 Photos["girl_","boy_…
阅读更多...
基于Java+SpringBoot+Vue+Element的OA系统的设计和实现

基于Java+SpringBoot+Vue+Element的OA系统的设计和实现

基于JavaSpringBootVueElement的OA系统的设计和实现 源码传送入口前言主要技术系统设计功能截图数据库设计代码论文目录订阅经典源码专栏Java项目精品实战案例《500套》 源码获取 源码传送入口 前言 在Internet高速发展的今天，我们生活的各个领域都涉及到计算机的…
阅读更多...
AI写作工具,智能ai写作工具

AI写作工具,智能ai写作工具

在信息化时代，内容创作已经成为了许多行业的核心。从营销广告到新闻报道，从博客文章到学术论文，人们需要不断地产生高质量的文字内容。创作是一项耗时耗力的工作，需要丰富的知识和创造性思维。 AI写作工具，是一类基于人…
阅读更多...
基于Spring Boot的医院预约挂号系统设计与实现

基于Spring Boot的医院预约挂号系统设计与实现

前言 💗博主介绍：✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计划导师、全栈领域优质创作者，博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java、小程序技术领域和毕业项目实战✌💗 👇🏻…
阅读更多...
SAP ABAP基础知识 访问外部数据库-开发篇

SAP ABAP基础知识 访问外部数据库-开发篇

前言 本文主要介绍通过ABAP语言访问外部数据库的几种方式 一、外部数据库配置 本文示例中的代码访问了两个外部数据库 MTD : 外部oracle数据库,其中示例表 ZTTEMP 字段( ZZTNO,WERKS) S4Q : 外部HANA数据库(开发系统访问测试系统的数据库), 使用表USR02,ZTTEMP 二、ABAP访问…
阅读更多...
IDEA（2023）解决运行乱码问题

IDEA（2023）解决运行乱码问题

😇作者介绍：一个有梦想、有理想、有目标的，且渴望能够学有所成的追梦人。 🎆学习格言：不读书的人,思想就会停止。——狄德罗 ⛪️个人主页：进入博主主页 🗼专栏系列：无 &#x1f33c…
阅读更多...
【计算机组成原理】读书笔记第三期：内存和磁盘的关系

【计算机组成原理】读书笔记第三期：内存和磁盘的关系

目录 写在开头 内存与磁盘的关系 基本关系 磁盘缓存 虚拟内存 节约内存的编程方法 通过DLL文件实现函数共有 通过调用_stdcall来降低文件程序的大小 磁盘的物理结构 结尾 写在开头 本文继续阅读总结《程序是怎样跑起来的》这本书（作者：矢泽…
阅读更多...
操作系统（5-7分）

操作系统（5-7分）

内容概述 进程管理 进程的状态 前驱图 同步和互斥 PV操作（难点） PV操作由P操作原语和V操作原语组成（原语是不可中断的过程），对信号量进行操作，具体定义如下： P（S）&#…
阅读更多...
【计算机网络】——传输层

【计算机网络】——传输层

//图片取自王道，仅做交流学习 一、传输层提供的服务 物理层、数据链路层、网络层是通信子网。 传输层：它属于面向通信部分的最高层，同时也是用户功能的最低层 为应用层提供通信服务使用网络层的服务 网络层提供主机之间的逻辑通信。 1、传输…
阅读更多...
SpringMVC之JSR303与拦截器

SpringMVC之JSR303与拦截器

目录 一.JSR303 1.什么是JSR303 2.为什么使用JSR303 3.JSR303常用注解 4.快速入门 4.1导入Maven依赖 4.2 配置校验规则 4.3 对服务端数据添加进行校验 4.4 结果测试 二.拦截器 1.什么是拦截器 2.拦截器与过滤器 3.应用场景 4.基本拦截器配置 5 案例演示&#xff0…
阅读更多...
区块链实验室(23) - FISCO中PBFT耗时与流量特征

区块链实验室(23) - FISCO中PBFT耗时与流量特征

前面的实验(区块链实验室(11) - PBFT耗时与流量特征)用仿真的PBFT观察耗时。现在用真实的Fisco网络再次观察其特征。同样地，用相同的网络，即100个节点构成的无标度网络。在每个节点上发起10次交易，记录每次交易的耗时。结果见下图所示。 前半…
阅读更多...
VSCode『SSH』连接服务器『GUI界面』传输

VSCode『SSH』连接服务器『GUI界面』传输

前言 最近需要使用实验室的服务器训练带有 GUI 画面的 AI 算法模型（pygame），但是我是使用 SSH 连接的，不能很好的显示模型训练的效果画面，所以下面将会讲解如何实现 SSH 连接传输 Linux GUI 画面的 注：我们…
阅读更多...
Postman —— HTTP请求基础组成部分

Postman —— HTTP请求基础组成部分

一般来说，所有的HTTP Request都有最基础的4个部分组成：URL、 Method、 Headers和body。 （1）Method 要选择Request的Method是很简单的，Postman支持所有的请求方式。 （2）URL 要组装一条Request…
阅读更多...
华为HCIA（五）

华为HCIA（五）

Vlan id 在802.1Q中 高级ACL不能匹配用户名和源MAC 2.4G频段被分为14个交叠的，错列的20MHz信道，信道编码从1到14，邻近的信道之间存在一定的重叠范围 STA通过Probe获取SSID信息 Snmp报文 网络管理设备异常发生时会发送trap报文 D类地址是…
阅读更多...
基于Java网络书店商城设计实现(源码+lw+部署文档+讲解等)

基于Java网络书店商城设计实现(源码+lw+部署文档+讲解等)

博主介绍：✌全网粉丝30W,csdn特邀作者、博客专家、CSDN新星计划导师、Java领域优质创作者,博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ 🍅文末获取源码联系🍅 👇🏻 精彩专…
阅读更多...
亚马逊云科技 Amazon Lightsail ：一种在云服务器上运行容器的简单方法

亚马逊云科技 Amazon Lightsail ：一种在云服务器上运行容器的简单方法

当向开发人员介绍亚马逊云科技云服务时，通常会花一点时间来介绍并演示 Amazon Lightsail 。它是迄今为止开始使用亚马逊云科技的最简单方法。使用它，您在几分钟内即可在自己的虚拟服务器上运行您的应用程序。而后增加了在 Amazon Lightsail 上部署基于容…
阅读更多...
C语言字符函数和字符串函数(1)

C语言字符函数和字符串函数(1)

大家好，我们又见面了，让大家久等了，我们今天就来学习字符函数和字符串函数。 在开启今天的学习之前呢，我来解决一下一些小伙伴平时找不到库函数使用的烦恼，因为我们cplusplus.com最新版本不能够查询函数，我…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023