Express.js在AWS Beanstalk中，Redis createClient连ElastiCache失败（PING正常）

问题核心分析 #

报错显示createClient实际在尝试连接127.0.0.1:6379，但你明明配置了正确的ElastiCache端点，这说明Redis v4+版本的客户端配置格式不兼容你当前的写法。另外，顶层代码直接用await会触发语法错误，导致程序在connect()调用后直接终止，所以看不到"NOTE: Post connect"日志。

具体修复步骤 #

1. 修正Redis客户端配置格式 #

Redis v4+不再支持顶层的host和port参数，需将配置放到socket对象中，或直接使用url参数：

方式一：通过socket对象配置

let redisClient = createClient({
  socket: {
    host: process.env.REDIS_HOST,
    port: process.env.REDIS_PORT || 6379
  }
});

方式二：通过URL参数配置

const redisUrl = `redis://${process.env.REDIS_HOST}:${process.env.REDIS_PORT || 6379}`;
let redisClient = createClient({ url: redisUrl });

2. 将await代码放入async函数 #

顶层代码不能直接使用await，需把连接逻辑包裹在async函数内：

// 封装Redis连接逻辑
async function connectRedis() {
  try {
    await redisClient.connect();
    console.log("NOTE: Post connect");
  } catch (error) {
    console.error("Error connecting to Redis CLIENT:", error); // 注意修正原代码中err的拼写错误
  }
}

// 执行连接函数
connectRedis();

3. 集群端点额外配置 #

你的ElastiCache端点包含clustercfg，说明是集群模式，需开启客户端的集群支持：

let redisClient = createClient({
  socket: {
    host: process.env.REDIS_HOST,
    port: process.env.REDIS_PORT || 6379
  },
  cluster: true // 启用集群模式
});

修正后的核心代码示例 #

import * as dotenv from "dotenv";
dotenv.config();
import express from "express";
import { createClient } from "redis";
import net from "net";

const app = express();

console.log("NOTE: Pre createClient");
console.log("*** HOST = ", process.env.REDIS_HOST);
console.log("*** PORT = ", process.env.REDIS_PORT);

// 保留原有的Socket PING测试代码...

// 修正后的Redis客户端配置
let redisClient = createClient({
  socket: {
    host: process.env.REDIS_HOST,
    port: process.env.REDIS_PORT || 6379
  },
  cluster: true
});

redisClient.on("connect", () => {
  console.log("Connected to Redis");
});
redisClient.on("error", (error) => {
  console.error("Error connecting to Redis", error);
});

console.log("NOTE: Pre connect");
console.log("*** redisClient = ", JSON.stringify(redisClient));

// async函数执行连接
async function connectRedis() {
  try {
    await redisClient.connect();
    console.log("NOTE: Post connect");
  } catch (error) {
    console.error("Error connecting to Redis CLIENT:", error);
  }
}

connectRedis();

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