在Java应用中监听Redis键过期事件并同步数据库的实践指南

notify-keyspace-events Ex

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- 如果你使用Spring Data JPA进行数据库操作，也需要引入相关依赖 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <scope>runtime</scope>
</dependency>

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;

@Configuration
public class RedisListenerConfig {

    /**
     * 配置Redis消息监听容器
     * 它是Spring Data Redis中用于处理Redis消息的核心组件。
     * 它负责管理到Redis的连接，并调度消息到注册的监听器。
     */
    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        // 可以在这里添加其他配置，例如任务执行器等
        return container;
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.stereotype.Service;

@Configuration // 确保这个配置类被Spring扫描到
public class RedisKeyExpirationListenerConfiguration {

    @Autowired
    private YourDatabaseService yourDatabaseService; // 注入你的数据库服务

    /**
     * 注册键过期事件监听器。
     * KeyExpirationEventMessageListener 会自动订阅 __keyevent@*__:expired 频道。
     */
    @Bean
    public KeyExpirationEventMessageListener keyExpirationEventMessageListener(RedisMessageListenerContainer listenerContainer) {
        return new KeyExpirationEventMessageListener(listenerContainer) {
            @Override
            public void onMessage(Message message, byte[] pattern) {
                // message.getBody() 包含了过期键的名称
                String expiredKey = new String(message.getBody());
                System.out.println("Redis Key Expired: " + expiredKey);

                // 根据业务逻辑处理过期键
                // 假设我们的缓存键格式是 "company:<companyId>:accountDate"
                if (expiredKey.startsWith("company:")) {
                    try {
                        String[] parts = expiredKey.split(":");
                        if (parts.length > 1) {
                            String companyId = parts[1];
                            // 调用服务层更新数据库
                            yourDatabaseService.updateCompanyAccountDate(companyId);
                            System.out.println("成功触发数据库更新，公司ID: " + companyId);
                        }
                    } catch (Exception e) {
                        System.err.println("处理过期键 '" + expiredKey + "' 时发生错误: " + e.getMessage());
                        // 记录错误，考虑重试机制或发送到死信队列
                    }
                }
                // 可以根据不同的键前缀处理不同的业务逻辑
                // else if (expiredKey.startsWith("product:")) { ... }
            }
        };
    }
}

import org.springframework.stereotype.Service;
// import org.springframework.beans.factory.annotation.Autowired;
// import com.example.yourproject.repository.CompanyRepository; // 假设你的公司仓库

import java.util.Date;

@Service
public class YourDatabaseService {

    // @Autowired
    // private CompanyRepository companyRepository; // 如果使用JPA，注入你的Repository

    /**
     * 更新公司账户的访问日期。
     * 这是一个模拟的数据库更新方法，实际应用中会调用Repository进行持久化操作。
     */
    public void updateCompanyAccountDate(String companyId) {
        // 在这里实现你的数据库更新逻辑
        // 例如：
        // Company company = companyRepository.findById(Long.parseLong(companyId)).orElse(null);
        // if (company != null) {
        //     company.setLastAccessDate(new Date()); // 更新日期字段
        //     companyRepository.save(company); // 保存更改
        //     System.out.println("数据库中公司ID: " + companyId + " 的访问日期已更新。");
        // } else {
        //     System.out.println("未找到公司ID: " + companyId + "，无法更新。");
        // }

        System.out.println("模拟：正在为公司ID " + companyId + " 更新数据库中的访问日期字段...");
        // 实际应用中替换为真实的数据库操作
    }
}