AWS Lambda无法连接EC2实例上的Redis服务器问题求助

核心问题1：Redis客户端未显式发起连接 #

你使用的是Redis v4+版本，该版本的createClient仅创建客户端实例，不会自动发起连接，必须显式调用.connect()方法才能建立连接。你的代码只创建了客户端但未执行连接操作，因此既不会触发connect成功日志，也不会抛出错误，调用Redis读取操作自然返回null。

核心问题2：Lambda客户端复用逻辑不合理 #

当前每次调用Lambda handler都会执行RedisService.setDefaultRedisClient()，会重复创建Redis客户端实例，既浪费资源，也不符合复用客户端的需求。

修复步骤 #

1. 修改RedisService代码，补充连接逻辑并优化复用

import { RedisClientType, createClient } from 'redis';

export default class RedisService {
    private static _redisClient: RedisClientType | null = null;
    private static _isConnecting = false; // 避免并发调用时重复发起连接

    public static async setDefaultRedisClient() {
        // 如果已有客户端或正在连接，直接返回
        if (this._redisClient || this._isConnecting) return;

        this._isConnecting = true;
        console.log("---- inside setDefaultRedisClient");
        
        this._redisClient = createClient({
            url: `redis://${process.env.REDIS_HOST}:${process.env.REDIS_PORT}/0`,
            password: `${process.env.REDIS_PASSWORD}`
        });

        this._redisClient.on('connect', () => console.log('Redis Client Connected'));
        this._redisClient.on('error', err => console.log('Redis Client Error', err));
        
        // 显式发起连接
        try {
            await this._redisClient.connect();
        } finally {
            this._isConnecting = false;
        }
    }

    public static async getDefaultRedisClient(): Promise<RedisClientType> {
        if(!this._redisClient) {
            await this.setDefaultRedisClient();
        }
        // 确保客户端已连接（处理连接断开的情况）
        if (!this._redisClient.isReady) {
            await this._redisClient.connect();
        }
        return this._redisClient;
    }
}

2. 优化Lambda Handler的复用逻辑

将Redis客户端初始化放到条件判断中，和MongoDB连接逻辑保持一致，避免每次调用重复执行：

import { APIGatewayProxyHandler } from "aws-lambda";
import serverlessExpress from "@vendia/serverless-express";
import ExpressApplication from "./express.app";
import MongoDbConnectionService from "./services/mongodb-connection-service";
import RedisService from "./services/redis-service";

let isInitialized = false;

export const handler: APIGatewayProxyHandler = async (
  event,
  context,
  callback
) => {
  context.callbackWaitsForEmptyEventLoop = false;

  if (!isInitialized) {
    // 并行初始化MongoDB和Redis连接
    await Promise.all([
      MongoDbConnectionService.connect(),
      RedisService.setDefaultRedisClient()
    ]);
    isInitialized = true;
  }

  let serverlessExpressInstance = null;
  const expressApp = new ExpressApplication();
  serverlessExpressInstance = serverlessExpress({ app: expressApp.app });

  return serverlessExpressInstance(event, context, callback);
};

3. 检查VPC网络连通性

• 如果Lambda不在默认VPC中，需将Lambda配置到EC2所在的VPC子网，并为Lambda分配安全组，确保该安全组能访问EC2安全组的Redis端口（默认6379）。
• 若EC2使用私网IP，Lambda必须和EC2在同一个VPC才能访问；若使用公网IP，需确保Lambda有公网访问权限（如配置NAT网关），且EC2安全组允许Lambda的公网IP段访问。

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