如何在Next-Auth中使用自定义Redis而非Upstash实现会话持久化？

核心思路 #

NextAuth允许通过实现SessionStore接口自定义会话存储，无需依赖Upstash官方适配器。你可以基于已有的ioredis客户端，实现会话的创建、读取、更新和删除逻辑，从而在Nginx负载均衡的多节点Next.js应用下实现会话持久化。

步骤1：实现自定义Redis会话存储 #

基于你的ioredis客户端，编写符合NextAuth要求的会话存储逻辑：

import Redis from "ioredis";

// 初始化自定义Redis客户端（使用你已有的配置）
const redisClient = new Redis({
  host: "你的Redis主机地址",
  port: 你的Redis端口,
  password: "你的Redis密码（如有）",
  // 其他自定义配置，如数据库编号、连接超时等
});

// 实现NextAuth SessionStore接口
const customRedisSessionStore = {
  // 创建会话
  async createSession(session) {
    const sessionKey = `next-auth:session:${session.sessionToken}`;
    // 设置会话过期时间与session.expires同步
    const expireSeconds = Math.floor((session.expires.getTime() - Date.now()) / 1000);
    await redisClient.set(sessionKey, JSON.stringify(session), "EX", expireSeconds);
    return session;
  },

  // 读取会话
  async getSession(sessionToken) {
    const sessionKey = `next-auth:session:${sessionToken}`;
    const sessionStr = await redisClient.get(sessionKey);
    if (!sessionStr) return null;
    
    try {
      return JSON.parse(sessionStr);
    } catch (err) {
      // 清除无效的会话数据
      await redisClient.del(sessionKey);
      return null;
    }
  },

  // 更新会话
  async updateSession(session) {
    const sessionKey = `next-auth:session:${session.sessionToken}`;
    const exists = await redisClient.exists(sessionKey);
    if (!exists) return null;

    const expireSeconds = Math.floor((session.expires.getTime() - Date.now()) / 1000);
    await redisClient.set(sessionKey, JSON.stringify(session), "EX", expireSeconds);
    return session;
  },

  // 删除会话
  async deleteSession(sessionToken) {
    const sessionKey = `next-auth:session:${sessionToken}`;
    await redisClient.del(sessionKey);
  },
};

步骤2：修改NextAuth配置 #

将原有的UpstashRedisAdapter替换为自定义存储，并调整会话策略：

import NextAuth from "next-auth";
import CredentialsProvider from "next-auth/providers/credentials";

export default NextAuth({
  providers: [
    CredentialsProvider({
      name: "Credentials",
      credentials: {
        username: { label: "Username", type: "text" },
        password: { label: "Password", type: "password" },
      },
      async authorize(credentials) {
        // 对接你的Django认证接口逻辑
        const authRes = await fetch("你的Django登录验证接口", {
          method: "POST",
          body: JSON.stringify({
            username: credentials?.username,
            password: credentials?.password,
          }),
          headers: { "Content-Type": "application/json" },
        });

        const user = await authRes.json();
        // 验证通过则返回用户信息，否则返回null
        return authRes.ok && user ? user : null;
      },
    }),
  ],
  session: {
    strategy: "database", // 启用持久化会话策略
    store: customRedisSessionStore, // 绑定自定义Redis存储
    maxAge: 24 * 60 * 60, // 会话有效期（1天，可按需调整）
  },
  jwt: {
    enabled: false, // 关闭JWT模式，使用自定义会话存储
  },
  adapter: null, // 移除Upstash适配器
  callbacks: {
    async session({ session, user }) {
      // 自定义会话数据，比如添加用户ID等关键信息
      session.user.id = user.id;
      return session;
    },
  },
});

关键注意事项 #

• Redis客户端单例：确保redisClient是全局单例，避免每次请求创建新连接导致资源浪费。
• 会话键前缀：使用next-auth:session:前缀区分NextAuth会话键，方便后续Redis数据管理。
• 错误处理：在getSession中添加JSON解析错误处理，自动清除无效会话数据。
• 会话同步：确保会话过期时间与session.expires严格同步，避免出现过期会话残留。

内容的提问来源于stack exchange，提问作者Sumodh Nair