一、Redis 基础

Redis 可以说是最最最简单的数据库了。大部分数据库的读写操作都是在硬盘上的，而 Redis 是在内存上的。所以读写速度会比其他传统数据库要快。但缺点是数据不能持久化，一旦断电重启，数据就没了。当然，Redis 也是可以将数据持久化的，但我觉得这样做的成本有点高，如果要将数据持久化不如直接用传统数据库。

Redis 可能用得最多的地方就是存储 session ，用来记录用户登录状态之类的操作。这类数据就算丢失了也不会对用户有多大影响。

要使用 Redis ，首先就要安装它。windows版下载链接放在这里：

 

 

 我下载了 .msi 格式的安装包，下载后直接双击运行，一直点 “下一步” 就能安装成功。

在安装时记得勾选将 Redis 添加到全局环境。

安装成功后，打开终端，输入一下命令

  1. redis-cli

 

 

 进入交互模式就证明安装成功了，此时可以输入指令操作 Redis 了。

127.0.0.1 是本机 IP；6379 是 Redis 默认的端口号。

写入数据使用 set 指令

  1. set key value

key 是键名，value 是值。

我设置了一个 name ，值为 zhangsan。

输入完按回车键，返回 OK 证明写入成功。 

读取数据使用 get 。

  1. get key

key 是键名。

 

如果查到就返回值。

如果你不清楚当前存了什么 key ，可以使用 keys * 来查询所有 key

  1. keys *

 

 

 如果你有多个 key ，用上面的语句可以将所有 key 都列出来。

删除使用 del 。

  1. del key

 

我把刚刚创建的 name 这条数据给删掉了。

此时使用 get 或者 keys * 都差不回 name 这条数据了。

 

以上就是 Redis 的基础用法。

二、NodeJS 操作 Redis

我用默认模板初始化项目。

  1. npm init -y
  1. npm install redis

如果你想用旧版语法，可以安装指定版本。

比如 2.8 版

  1. npm install redis@2.8

安装好 Redis 后就可以用 NodeJS 来连接了。

新建一个 js 文件。

v2.8语法

  1. const redis = require('redis') // 引入 redis
  3. // 创建客户端
  4. const redisClient = redis.createClient('6379', '127.0.0.1') // 端口，主机
  6. // 监听错误信息
  7. redisClient.on('error', err => {
  8.   console.error(err) // 打印监听到的错误信息
  9. })

v4.2 语法

  1. const redis = require('redis') // 引入 redis
  2.  
  3. const redisClient = redis.createClient() // 创建客户端
  5. // 监听错误信息
  6. redisClient.on('err', err => {
  7.   console.log('redis client error: ', err)
  8. })
  10. // 连接
  11. redisClient.connect(6379, '127.0.0.1')

写入数据使用 set 方法

v2.8

  1. redisClient.set('name', 'zhangsan', redis.print)

第三个参数 redis.print 是打印方法，在执行完上面的命令，控制台会打印一条信息。

比如执行成功，会打印 Reply: OK

v4.2

  1. const redis = require('redis') // 引入 redis
  3. // 创建客户端
  4. const redisClient = redis.createClient()
  6. // 监听错误信息
  7. redisClient.on('err', err => {
  8.   console.log('redis client error: ', err)
  9. })
  11. // 创建连接，是个 promise
  12. redisClient.connect(6379, '127.0.0.1')
  13.   .then(() => {
  14.     redisClient.set('name', 'zhangsan')
  15.       .then(val => {
  16.         console.log(val)
  17.       })
  18.   })

上面的代码意思是，使用 client.connect 连接，成功后再执行 set 操作。

你也可以将上面的代码改成 async 和 await 语法。

使用 get 方法可以读取数据

v2.8

  1. // 省略部分代码
  3. redisClient.get('name', (err, val) => {
  4.   if (err) {
  5.     console.error(err)
  6.     return
  7.   }
  8.   console.log(val)
  9. })

v4.2

  1. const redis = require('redis') // 引入 redis
  3. // 创建客户端
  4. const redisClient = redis.createClient()
  6. // 创建连接，是个 promise
  7. redisClient.connect(6379, '127.0.0.1')
  8.   .then(() => {
  9.     redisClient.get('name')
  10.       .then(val => {
  11.         console.log(val)
  12.       })
  13.   })

如果查找到就返回对应的值，否则返回 null。

使用 del 方法删除

v2.8

  1. // 省略部分代码
  3. redisClient.del('name', (err, val) => {
  4.   if (err) {
  5.     console.error(err)
  6.     return
  7.   }
  8.   console.log(val)
  9. })

v4.2

  1. const redis = require('redis') // 引入 redis
  3. // 创建客户端
  4. const redisClient = redis.createClient()
  6. // 创建连接，是个 promise
  7. redisClient.connect(6379, '127.0.0.1')
  8.   .then(() => {
  9.     redisClient.del('name')
  10.       .then(val => {
  11.         console.log(val)
  12.       })
  13.   })

用完就断，用 quit 方法可以断开连接。

在断开连接这件事上，v2.8 和 v4.2 的语法相同

  1. redisClient.quit()

v2.8

  1. const express = require("express");
  2. const fetch = require("node-fetch");
  3. const redis = require("redis");
  5. const PORT = process.env.PORT || 5000;
  6. const REDiS_PORT = process.env.REDiS_PORT || 6379;
  8. const app = express();
  9. const client = redis.createClient(REDiS_PORT);
  11. // Cache middleware
  12. function cache(req, res, next) {
  13.   const { username } = req.params;
  14.   client.get(username, (err, data) => {
  15.     if (err) throw err;
  16.     if (data !== null) {
  17.       // 缓存中有数据，返回缓存中的数据
  18.       res.send(setResponse(username, data));
  19.     } else {
  20.       // 否则继续之前的请求
  21.       next();
  22.     }
  23.   });
  24. }
  26. // 设置响应
  27. function setResponse(username, repos) {
  28.   return `<h2>${username} has ${repos} Github repositories</h2>`;
  29. }
  30. // 获取github仓库数量
  31. async function getRepos(req, res, next) {
  32.   try {
  33.     console.log("Fetching Data...");
  34.     const { username } = req.params;
  35.     const response = await fetch(`https://api.github.com/users/${username}`);
  36.     const data = await response.json();
  37.     const repos = data.public_repos;
  38.     // 存到redis
  39.     // 三个参数分别是键、有效期、值
  40.     client.setex(username, 3600, repos);
  42.     res.send(setResponse(username, repos));
  43.   } catch (error) {
  44.     console.error(error);
  45.     res.status = 500;
  46.   }
  47. }
  48. // 使用中间件，加上第二个参数cache
  49. app.get("/repos/:username", cache, getRepos);
  51. app.listen(5000, () => {
  52.   console.log(`App listening on port ${PORT}`);
  53. });

v4.2

  1. const express = require("express");
  2. const fetch = require("node-fetch");
  3. const redis = require("redis");
  5. const PORT = process.env.PORT || 5000;
  6. const REDiS_PORT = process.env.REDiS_PORT || 6379;
  8. const app = express();
  9. const client = redis.createClient();
  10. client.connect(REDiS_PORT).then(() => {
  11.     // 使用中间件，加上第二个参数cache
  12.     app.get("/repos/:username", cache, getRepos);
  14.     app.listen(5000, () => {
  15.         console.log(`App listening on port ${PORT}`);
  16.     });
  17. })
  19. // Cache middleware
  20. function cache(req, res, next) {
  21.     const { username } = req.params;
  22.     client.get(username).then(data => {
  23.         console.log('data', data);
  24.         if (data !== null) {
  25.             // 缓存中有数据，返回缓存中的数据
  26.             res.send(setResponse(username, data));
  27.         } else {
  28.             // 否则继续之前的请求
  29.             next();
  30.         }
  31.     });
  32. }
  34. // 设置响应
  35. function setResponse(username, repos) {
  36.     return `<h2>${username} has ${repos} Github repositories</h2>`;
  37. }
  38. // 获取github仓库数量
  39. async function getRepos(req, res, next) {
  40.     try {
  41.         console.log("Fetching Data...");
  42.         const { username } = req.params;
  43.         const response = await fetch(`https://api.github.com/users/${username}`);
  44.         const data = await response.json();
  45.         const repos = data.public_repos;
  46.         // 存到redis
  47.         // 三个参数分别是键、有效期、值
  48.         client.setex(username, 3600, repos);
  50.         res.send(setResponse(username, repos));
  51.     } catch (error) {
  52.         console.error(error);
  53.         res.status = 500;
  54.     }
  55. }

 参照：https://zhuanlan.zhihu.com/p/537632389

https://juejin.cn/post/7084061592660213790

集群：https://blog.51cto.com/u_15067247/4024249

版权声明：本文为vickylinj原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/vickylinj/p/16515297.html