Spring Boot项目中如何实现邮件通知订阅自动过期置为false？

针对你提出的需求，结合Spring Boot + Java + Postgres技术栈，以下是几种实用的实现方案：

一、调整数据库表结构 #

首先需要扩展原有用户表，新增字段支持临时时长管理：

• notify_expire_time：TIMESTAMP类型，存储通知到期时间（永久订阅时设为NULL）
• notify_duration_type：VARCHAR(20)可选，记录订阅时长类型（如WEEK/MONTH/PERMANENT，方便后续维护）

修改表的PostgreSQL语句示例：

ALTER TABLE user_account 
ADD COLUMN notify_expire_time TIMESTAMP,
ADD COLUMN notify_duration_type VARCHAR(20);

二、具体实现方案 #

方案1：Spring Task定时任务（中小项目首选） #

通过Spring自带定时任务定期扫描更新到期记录，实现简单无需额外中间件。

1. 开启定时任务支持
   在Spring Boot启动类添加注解：

@SpringBootApplication
@EnableScheduling
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

2. 编写定时任务逻辑
   创建任务类，每天凌晨执行扫描更新（可按需调整频率）：

@Component
public class NotifyExpireTask {

    @Autowired
    private UserAccountRepository userAccountRepository;

    // 每天凌晨1点执行
    @Scheduled(cron = "0 0 1 * * ?")
    public void expireNotify() {
        LocalDateTime now = LocalDateTime.now();
        // 更新所有到期且仍开启通知的用户
        userAccountRepository.updateHasEmailNotifyByExpireTime(now, false);
    }
}

3. Repository层方法（JPA示例）

public interface UserAccountRepository extends JpaRepository<UserAccount, Long> {

    @Modifying
    @Query("UPDATE UserAccount u SET u.hasEmailNotify = :status WHERE u.notifyExpireTime < :expireTime AND u.hasEmailNotify = true")
    void updateHasEmailNotifyByExpireTime(@Param("expireTime") LocalDateTime expireTime, @Param("status") Boolean status);
}

方案2：PostgreSQL内置定时任务（数据库层面处理） #

利用Postgres的pg_cron扩展，直接在数据库执行定时更新，减轻应用服务器负担。

1. 安装pg_cron扩展（需管理员权限）

CREATE EXTENSION IF NOT EXISTS pg_cron;

2. 创建定时更新任务
   每天凌晨1点执行更新：

SELECT cron.schedule(
    'expire-email-notify',
    '0 1 * * *',
    $$UPDATE user_account 
      SET has_email_notify = false 
      WHERE notify_expire_time < NOW() 
        AND has_email_notify = true$$
);

方案3：延迟消息队列（高时效性场景） #

如果需要到期后立即取消通知，可使用延迟消息队列（如RabbitMQ延迟队列、Redis延迟队列）精准触发更新。

以RabbitMQ为例：

1. 配置延迟交换机和队列

@Configuration
public class RabbitMQConfig {

    public static final String DELAY_EXCHANGE = "notify.delay.exchange";
    public static final String DELAY_QUEUE = "notify.delay.queue";
    public static final String DELAY_ROUTING_KEY = "notify.delay.key";

    @Bean
    public CustomExchange delayExchange() {
        Map<String, Object> args = new HashMap<>();
        args.put("x-delayed-type", "direct");
        return new CustomExchange(DELAY_EXCHANGE, "x-delayed-message", true, false, args);
    }

    @Bean
    public Queue delayQueue() {
        return new Queue(DELAY_QUEUE, true);
    }

    @Bean
    public Binding delayBinding() {
        return BindingBuilder.bind(delayQueue())
                .to(delayExchange())
                .with(DELAY_ROUTING_KEY)
                .noargs();
    }
}

2. 用户选择时长时发送延迟消息

@Service
public class NotifyService {

    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Autowired
    private UserAccountRepository userAccountRepository;

    public void setNotifyDuration(Long userId, String duration) {
        LocalDateTime expireTime = calculateExpireTime(duration);
        // 更新用户表的到期时间和通知状态
        userAccountRepository.updateNotifyExpireTime(userId, expireTime, true);

        if (!"PERMANENT".equals(duration)) {
            long delay = ChronoUnit.MILLIS.between(LocalDateTime.now(), expireTime);
            // 发送延迟消息
            rabbitTemplate.convertAndSend(RabbitMQConfig.DELAY_EXCHANGE, RabbitMQConfig.DELAY_ROUTING_KEY, userId, message -> {
                message.getMessageProperties().setHeader("x-delay", delay);
                return message;
            });
        }
    }

    private LocalDateTime calculateExpireTime(String duration) {
        return switch (duration) {
            case "WEEK" -> LocalDateTime.now().plusWeeks(1);
            case "MONTH" -> LocalDateTime.now().plusMonths(1);
            default -> null;
        };
    }
}

3. 消费延迟消息执行更新

@Component
public class NotifyExpireConsumer {

    @Autowired
    private UserAccountRepository userAccountRepository;

    @RabbitListener(queues = RabbitMQConfig.DELAY_QUEUE)
    public void handleExpireNotify(Long userId) {
        UserAccount user = userAccountRepository.findById(userId).orElse(null);
        if (user != null && user.getNotifyExpireTime().isBefore(LocalDateTime.now()) && user.getHasEmailNotify()) {
            user.setHasEmailNotify(false);
            userAccountRepository.save(user);
        }
    }
}

三、注意事项 #

• 用户中途修改订阅时长时，需同步更新notify_expire_time；若使用延迟队列，需取消原有延迟消息（可通过唯一消息ID实现）
• 永久订阅时将notify_expire_time设为NULL，避免定时任务误处理
• 定时任务执行频率需根据业务量调整，避免数据库压力过大

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