在业务系统里,任务提醒本质是“到点做一件事”并“告诉相关人”。Java生态有多种调度工具,但真正生产可用的提醒系统要考虑触发准确、不重复执行、通知可达与故障恢复。下面以一个电商订单三十分钟未支付自动关闭并提醒运营的场景,拆解完整开发路径。

一、调度层的选择与基础实现
单机环境最简单的是JDK自带的ScheduledExecutorService,它基于线程池执行周期任务,适合轻量提醒。下面的代码每六十秒扫描一次待处理订单,找出超时记录并触发提醒。
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class OrderRemindTask {
private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
public void start() {
// 初始延迟0秒,之后每60秒执行一次扫描
scheduler.scheduleAtFixedRate(() -> scanTimeoutOrders(), 0, 60, TimeUnit.SECONDS);
}
private void scanTimeoutOrders() {
// 伪代码:查询创建超过30分钟且未支付的订单
// List<Order> list = orderMapper.selectUnpaidOverThirtyMin();
// for (Order o : list) { remindService.notify(o); }
}
}
这种写法优势是零依赖、易理解,但缺点明显:应用重启就丢任务,多实例部署会重复扫描。因此在集群中,更推荐Spring Scheduler配合分布式锁。使用@Scheduled注解声明周期,再用数据库乐观锁或Redis锁保证只有一个节点执行。
Spring Scheduler的配置非常简洁,在配置类加@EnableScheduling,在方法上写@Scheduled(cron = "0 */1 * * * ?")即可每分钟触发。为避免重复,执行前先往schedule_lock表插入主键为任务名的记录,成功才跑,失败则跳过。这样即使三个节点同时起来,也只有一个能拿到锁。
二、提醒通知的多通道设计
提醒不是只发邮件。用户在线时应推站内信,离线再补短信或邮件。我们可以用策略模式封装通知渠道,根据接收人状态选通道。下面代码展示一个极简的通知分发器。
public interface Notifier {
void send(String target, String content);
}
@Component
public class WebSocketNotifier implements Notifier {
public void send(String target, String content) {
// 通过WebSocket向target用户推送content
}
}
@Service
public class RemindService {
@Autowired
private List<Notifier> notifiers;
public void notify(String user, String msg) {
for (Notifier n : notifiers) {
try {
n.send(user, msg);
} catch (Exception e) {
// 记录失败日志,后续重试
}
}
}
}
多通道带来的好处是可达性提升,但也引入重试与幂等问题。每一条提醒应带唯一业务号,比如订单号加提醒类型,通知端做去重。若WebSocket发送失败,落库为待发邮件,由另一定时任务补偿。这样用户不会因为网络抖动漏掉关键提醒。
另外时区常被忽略。cron默认用服务器时区,若用户跨时区,应将触发时间转为UTC存储,计算时用用户时区偏移。否则出现“凌晨三点提醒开会”的乌龙。建议在订单表存expected_close_time为UTC时间戳,扫描时统一用Instant比较。
三、完整实战与监控要点
把前面拼起来,一个稳健的提醒系统包含:扫描任务、分布式锁、通知策略、失败重试表与监控。下表对比两种调度方案适用度。
| 方案 | 单机可用 | 集群安全 | 改周期成本 |
|---|---|---|---|
| ScheduledExecutorService | 是 | 否 | 改代码重启 |
| Spring Scheduler加锁 | 是 | 是 | 改配置或库 |
监控上,每次提醒写入remind_log,包含触发时间、渠道、状态。用Prometheus暴露“提醒成功数”和“失败数”指标,失败率超阈值告警。曾经有项目因漏写catch导致线程静默退出,扫描停了一天没人知,加监控后十分钟就发现。
最后提醒,任务提醒系统别过度设计。小后台用ScheduledExecutorService加单表足够;中型系统上Spring Scheduler与Redis锁;只有跨语言海量调度才考虑引入Quartz或消息队列延迟消息。理清场景,代码反而简单可靠。
Java任务提醒Spring_Scheduler消息通知修改时间:2026-08-11 01:06:29