Node.js Express中Redis连接失败时切换会话存储至内存缓存的方案

我有一个集成了Session与Redis的Node.js Express应用，目前运行正常。当Redis连接失败（如URL或密码错误）时，希望将app.use(session())中的store参数切换为false，使用默认内存缓存。但服务器与会话设置在Redis.connect()完成前就已创建，请问如何修改现有配置实现该需求？

错误信息 #

Server running at http://127.0.0.1:2002/
error
Error: connect ECONNREFUSED 127.0.0.2:6379
    at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1605:16) {
  errno: -111,
  code: 'ECONNREFUSED',
  syscall: 'connect',
  address: '127.0.0.2',
  port: 6379
}

应用代码（index.js） #

const { RedisStore } = require('connect-redis');
const { createClient } = require('redis');

const express = require('express');
const session = require('express-session');

...

let client = createClient({ url: 'MY_URL', password: 'MY_PW' });

var session_store = new RedisStore({ client: client });

(async () => {
  try {
    await client.connect();
    await client.ping();
  } catch (error) {
    console.error('error');
    console.error(error);
  }
})();

const app = express();

...

app.use(session({
  store: session_store,
  //store: false,
  secret: 'MY_SECRET',
  key: 'MY_KEY',
  resave: false,
  saveUninitialized: false,
  cookie: cookie_config
}));

...

module.exports = app;

const server = http.createServer(app);

server.listen(port, hostname, () => {
  console.log(`Server running at http://${hostname}:${port}/`);
});

环境配置 #

node.js v20.12.1

"connect-redis": "^8.0.1",
"express": "^4.18.2",
"express-session": "^1.17.3",
"redis": "^4.7.0",

核心思路是先确认Redis连接结果，再初始化Session中间件并启动服务器，避免服务器提前启动导致无法动态切换存储方式。具体修改如下：

修改后完整代码 #

const { RedisStore } = require('connect-redis');
const { createClient } = require('redis');
const express = require('express');
const session = require('express-session');
const http = require('http');

// 省略其他配置（如cookie_config）
...

// 异步初始化服务器
async function initServer() {
  let sessionStore = null;
  const redisClient = createClient({ url: 'MY_URL', password: 'MY_PW' });

  try {
    await redisClient.connect();
    await redisClient.ping();
    console.log('Redis连接成功，使用Redis存储Session');
    sessionStore = new RedisStore({ client: redisClient });
  } catch (error) {
    console.error('Redis连接失败，切换为默认内存存储Session');
    console.error(error);
    // 设为false或不赋值，express-session自动使用内存存储
    sessionStore = false;
  }

  const app = express();

  // 其他中间件配置
  ...

  // 配置Session中间件
  app.use(session({
    store: sessionStore,
    secret: 'MY_SECRET',
    key: 'MY_KEY',
    resave: false,
    saveUninitialized: false,
    cookie: cookie_config
  }));

  // 路由配置
  ...

  const hostname = '127.0.0.1';
  const port = 2002;
  const server = http.createServer(app);

  server.listen(port, hostname, () => {
    console.log(`Server running at http://${hostname}:${port}/`);
  });
}

// 启动初始化流程
initServer();

关键说明 #

• 将原本的自执行异步函数改为initServer异步函数，确保Redis连接结果确定后再进行后续配置
• Redis连接成功时创建RedisStore实例，失败时将sessionStore设为false（或直接不赋值），express-session会自动切换为默认内存存储
• 所有Express配置、Session中间件注册、服务器启动均放在Redis连接结果确定之后，保证store参数能正确切换

内容的提问来源于stack exchange，提问作者Philipp M