如何通过AWS SQS发送缓存驱逐信号，实现Spring Boot多Redis集群同步？

完全可以通过SQS消息触发Redis缓存驱逐，你设计的SNS+SQS扇出模式非常适合这种跨Redis集群的缓存同步场景，既能保证消息可靠投递，又能实现多集群的并行处理。下面结合Spring Boot的@CacheEvict给出具体实现步骤：

1. 定义缓存驱逐消息结构 #

先定义一个包含缓存操作必要信息的消息体，确保跨服务能正确解析：

public class CacheEvictMessage {
    private String cacheName; // 对应@CacheEvict的cacheNames
    private String cacheKey; // 对应@CacheEvict的key（为空则清空整个缓存）

    // 构造器、Getter、Setter省略
}

2. 本地缓存驱逐时同步发送SNS消息 #

在原本使用@CacheEvict的业务方法中，额外添加发送SNS消息的逻辑，把驱逐信号广播出去：

@Service
public class UserService {
    private final AmazonSNS amazonSNS;
    private static final String CACHE_EVICT_TOPIC_ARN = "arn:aws:sns:us-east-1:1234567890:cache-evict-topic";
    private final ObjectMapper objectMapper;

    public UserService(AmazonSNS amazonSNS, ObjectMapper objectMapper) {
        this.amazonSNS = amazonSNS;
        this.objectMapper = objectMapper;
    }

    @CacheEvict(cacheNames = "userCache", key = "#userId")
    public void updateUserInfo(String userId, UserInfo updatedInfo) {
        // 执行用户信息更新的业务逻辑
        // 发送缓存驱逐信号到SNS主题
        CacheEvictMessage evictMsg = new CacheEvictMessage("userCache", userId);
        try {
            amazonSNS.publish(CACHE_EVICT_TOPIC_ARN, objectMapper.writeValueAsString(evictMsg));
        } catch (JsonProcessingException e) {
            // 处理序列化异常，比如记录日志
            e.printStackTrace();
        }
    }
}

3. 配置SQS消费者监听并触发跨集群驱逐 #

创建SQS监听类，接收来自SNS的消息后，调用当前服务连接的Redis集群（X或Y）执行缓存驱逐操作：

@Service
public class CacheEvictListener {
    private final CacheManager cacheManager; // 该CacheManager对应当前服务连接的Redis集群（X或Y）
    private final ObjectMapper objectMapper;

    public CacheEvictListener(CacheManager cacheManager, ObjectMapper objectMapper) {
        this.cacheManager = cacheManager;
        this.objectMapper = objectMapper;
    }

    @SqsListener("cache-evict-queue") // 监听对应SQS队列
    public void handleCacheEvictMessage(String messageBody) {
        try {
            CacheEvictMessage evictMsg = objectMapper.readValue(messageBody, CacheEvictMessage.class);
            Cache targetCache = cacheManager.getCache(evictMsg.getCacheName());
            if (targetCache != null) {
                if (evictMsg.getCacheKey() != null) {
                    targetCache.evict(evictMsg.getCacheKey()); // 驱逐指定键
                } else {
                    targetCache.clear(); // 清空整个缓存
                }
            }
        } catch (JsonProcessingException e) {
            // 处理消息解析异常，可将消息转入死信队列后续排查
            e.printStackTrace();
        }
    }
}

4. Spring Boot与AWS服务集成配置 #

依赖引入 #

在pom.xml中添加AWS消息依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-aws-messaging</artifactId>
</dependency>

配置AWS参数 #

在application.properties中配置AWS凭证和区域：

cloud.aws.credentials.access-key=your-access-key
cloud.aws.credentials.secret-key=your-secret-key
cloud.aws.region.static=your-region-id

关键注意事项 #

• 幂等性保障：SQS可能存在重复投递，好在缓存驱逐操作天然幂等（驱逐不存在的键不会产生副作用），无需额外处理。
• 集群隔离优化：如果不同集群只需要同步特定缓存，可以给每个集群创建独立的SQS队列，让SNS主题同时推送到多个队列，对应集群的服务只监听自己的队列。
• 错误处理：配置SQS死信队列，将消费失败的消息转入死信队列，避免无限重试影响服务稳定性。

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