在Koa2中集成Redis客户端-GX博客-分享个人 Full-Stack JavaScript 项目开发经验、前端在线工具、Sass、Bootstrap、Grunt、Gulp、webpack、React、Node.js、Git、Koa、MySQL、Nginx、Docker、Kubernetes、Jenkins、SEO、网络安全、CentOS 7

在Koa2中集成Redis客户端

创建 2020-08-16 16:38，修改 2020-08-29 12:54，作者 leeguangxing.cn，阅读数：1812

Redis 是一个高效的开源内存数据结构存储系统，非常适合于类似 Session 信息这样的高频读写和有时效性的键值对数据存储。本文将会介绍如果在 Koa2 应用中集成 Redis 客户端以连接 Redis 集群，其中还包括容器信号的处理方式等。

创建一个客户端实例库

这里客户端采用的是 NodesRedis 的 npm 库，它是一个高性能的 Node.js Redis 客户端库。它的 API 全部是非堵塞异步的，并且实例方法跟 Redis 命令一致，参数传递方式非常友好。下面是 lib/redis/index.js 的一个例子：

1
2
const redis = require('redis');
const config = require('../../config/index');
const {host, port, no_ready_check, total_retry_time} = config.redis;
const client = redis.createClient({
  host,
  port,
  no_ready_check,
  retry_strategy: function (options) {
    // 超出重连时间后，不再重连
    if (options.total_retry_time > total_retry_time) {
      // 当 redis 服务器响应为拒绝连接时，结束重连
      if (options.error && options.error.code === 'ECONNREFUSED') {
        return new Error("The Redis server refused the connection.");
      }
      return new Error("Redis retry time exhausted");
    } else {
      // 不超过 3000 毫秒重连一次
      return Math.min(options.attempt * 100, 3000);
    }
  }
});
client.on('error', function (error) {
  console.error(error);
});
client.on('connect', function () {
  console.log('Redis connected.')
});
client.on('reconnecting', function () {
  console.log('Redis reconnecting......')
});
client.on('ready', function () {
  process.send('ready');
});
module.exports = client;
הההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההה
XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX

从上面代码中可以看到，客户端的连接配置来自于一份应用程序的全局配置。它是一个 "唯一来源" 原则的良好实践，开发环境下大可以直接使用开发配置，甚至将配置提交到版本控制系统就可以了。其它开发成员直接从版本控制系统中得到开发配置。当部署到生产环境时，运维人员直接将生产环境配置以 Secret 卷方式挂载到容器内即可。与环境变量相比，内存文件系统亦更为安全。

从上面代码中，我们还处理了如下事情：

no_ready_check 在连接 Redis 集群代理时需要设置为 true，因为目前代码还不支持 INFO 命令。
设置了重连策略。
监听关键的事件并输出日志到标准输出流。
当准备就绪时，发出 ready 信号给 Node.js 线程管理工具 PM2。

接下来是将客户端实例添加到 app 上下文中：

1
2
/* ==========================================================================
   创建 Redis 实例于 app 上下文中
   ========================================================================== */
app.context.redis = require("./lib/redis");
הההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההה
XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX

当接收到 PM2 SIGINT 信号时，优雅地关闭所有连接，并退出进程：

1
2
/* ==========================================================================
    PM2 SIGINT 信号处理
   ========================================================================== */
process.on('SIGINT', function () {
  let flag = false;
  const callback = () => {
    flag ? process.exit(0) : flag = true;
  };
  app.context.mysql.destroy(callback);
  app.context.redis.quit(callback);
});
הההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההההה
XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX

Redis 是很好的 Session 外部存储解决方案，Session 以及请求序列号等键值对存储机制是防止如跨域请求伪造和重放攻击等的基础。以上就是 Koa2 集成 Redis 客户端的全部内容。

GX博客

在Koa2中集成Redis客户端

创建一个客户端实例库

版权声明：

寄语

最近发表或修改

最热文章