Spring Cloud AWS是否仍支持Amazon ElastiCache for Redis？3.1.0集成方案咨询

Spring Cloud AWS 3.x版本起，移除了对ElastiCache Redis的内置自动配置支持，官方推荐通过Spring Data Redis配合标准配置来完成集成，以下是具体方案：

核心方案：Spring Data Redis直接集成 #

这是最简洁、官方认可的集成方式，步骤如下：

1. 添加依赖
   根据项目构建工具引入Spring Data Redis核心依赖：

• Maven（pom.xml）：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

• Gradle（build.gradle）：

implementation 'org.springframework.boot:spring-boot-starter-data-redis'

2. 配置ElastiCache连接信息
   在application.properties或application.yml中填入ElastiCache集群的端点、端口等参数：

# 基础单节点/主从模式配置
spring.data.redis.host=你的ElastiCache集群端点
spring.data.redis.port=6379

# 若使用Redis集群模式，替换为集群节点配置
# spring.data.redis.cluster.nodes=节点1:6379,节点2:6379,节点3:6379

# 若集群开启了密码认证，添加以下配置
# spring.data.redis.password=你的Redis认证密码

# 若需要SSL加密传输（需ElastiCache已启用SSL）
# spring.data.redis.ssl.enabled=true

3. 使用Spring Data Redis API操作缓存
   直接注入StringRedisTemplate或RedisTemplate即可完成缓存读写，示例代码：

import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;

@Service
public class CacheService {
    private final StringRedisTemplate redisTemplate;

    public CacheService(StringRedisTemplate redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    // 写入缓存
    public void putCacheValue(String key, String value) {
        redisTemplate.opsForValue().set(key, value);
    }

    // 读取缓存
    public String getCacheValue(String key) {
        return redisTemplate.opsForValue().get(key);
    }
}

进阶方案：结合AWS SDK动态获取集群信息（可选） #

如果需要动态查询ElastiCache集群的端点信息（而非硬编码配置），可以引入AWS SDK for ElastiCache实现：

1. 添加AWS SDK依赖

• Maven：

<dependency>
    <groupId>software.amazon.awssdk</groupId>
    <artifactId>elasticache</artifactId>
</dependency>

• Gradle：

implementation 'software.amazon.awssdk:elasticache'

2. 通过SDK获取集群端点
   编写工具类查询ElastiCache集群的实时端点：

import software.amazon.awssdk.services.elasticache.ElastiCacheClient;
import software.amazon.awssdk.services.elasticache.model.DescribeCacheClustersRequest;
import org.springframework.stereotype.Component;

@Component
public class ElastiCacheEndpointProvider {
    private final ElastiCacheClient elasticacheClient;

    public ElastiCacheEndpointProvider(ElastiCacheClient elasticacheClient) {
        this.elasticacheClient = elasticacheClient;
    }

    // 根据集群ID获取主节点端点
    public String getPrimaryNodeEndpoint(String clusterId) {
        var request = DescribeCacheClustersRequest.builder()
                .cacheClusterId(clusterId)
                .showCacheNodeInfo(true)
                .build();
        var response = elasticacheClient.describeCacheClusters(request);
        return response.cacheClusters().get(0).cacheNodes().get(0).endpoint().address();
    }
}

后续可将该端点注入Redis配置类，实现动态更新连接信息。

关键注意事项 #

• 确保应用所在VPC与ElastiCache集群的VPC网络连通，安全组规则允许应用访问Redis端口（默认6379）。
• 若使用Redis集群模式，需配置所有集群节点地址，Spring Data Redis会自动处理分片路由。

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