基于Spring Boot与Angular的提醒推送通知实现方案咨询

别再纠结每秒轮询数据库啦——这种做法既浪费服务器资源，又没法保证实时性。咱们换个事件驱动+定时调度的思路，给你拆解每个组件的设计逻辑：

1. Spring Boot后端核心实现 #

a. 用调度器替代数据库轮询 #

直接用Spring自带的@Scheduled或者更灵活的Quartz来管理定时任务，步骤很简单：

• 当用户创建/更新提醒（比如11点的会议）时，把这个任务直接注册到调度器里。比如用Quartz的话，创建JobDetail和Trigger，触发时间设为提醒的触发点（比如会议前10分钟）。
• 调度器会在精准时间触发任务，完全不用傻等每秒查库。如果提醒被删除或修改，记得从调度器移除旧任务，再注册新的就行。
• 应用启动时，从数据库加载所有未触发的提醒，重新注册到调度器，避免重启后丢失任务。

b. WebSocket实时推送配置 #

用Spring WebSocket（搭配STOMP协议更适合复杂场景）实现推送：

• 先配置WebSocket端点，比如/ws/notifications，前端通过这个地址建立连接。
• 当定时任务触发时，用SimpMessagingTemplate把提醒推送给指定用户——可以让用户订阅专属主题，比如/user/{userId}/notifications，确保消息只推给对应的人。

c. 数据库的辅助优化 #

• 给提醒表加个status字段（比如PENDING/TRIGGERED/CANCELLED），任务触发后更新状态，防止重复推送。
• 持久化未触发的任务，保证应用重启后能恢复调度。

2. Angular前端处理逻辑 #

• 用@stomp/stompjs库连接WebSocket，订阅用户专属的提醒主题。
• 收到推送后，用浏览器的Notification API弹出系统通知（记得先获取用户权限），或者在页面内展示提醒卡片。
• 用户操作提醒（增删改）时，调用后端API，让后端同步处理调度任务的变更。

3. 避坑小技巧 #

• 集群部署注意：如果后端是集群模式，要防止定时任务重复触发——可以用Quartz的集群模式，或者用Redis锁指定一个调度节点。
• 时间同步：确保服务器时间准确，避免因时间差导致提醒不准。
• 离线补发：如果推送时用户离线，把消息存在数据库的消息队列里，等用户重新连接后再补发。

简单代码示例 #

后端定时任务触发推送

@Component
public class ReminderJob implements Job {

    @Autowired
    private SimpMessagingTemplate messagingTemplate;

    @Autowired
    private ReminderRepository reminderRepo;

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        Long reminderId = (Long) context.getJobDetail().getJobDataMap().get("reminderId");
        Reminder reminder = reminderRepo.findById(reminderId).orElseThrow();
        
        // 推送给指定用户
        messagingTemplate.convertAndSendToUser(
            reminder.getUserId(),
            "/notifications",
            "您有一个会议即将开始：" + reminder.getTitle()
        );
        
        // 更新提醒状态
        reminder.setStatus(ReminderStatus.TRIGGERED);
        reminderRepo.save(reminder);
    }
}

前端WebSocket连接示例

import { Component, OnInit } from '@angular/core';
import { Stomp } from '@stomp/stompjs';
import * as SockJS from 'sockjs-client';

@Component({
  selector: 'app-notifications',
  templateUrl: './notifications.component.html'
})
export class NotificationsComponent implements OnInit {
  private stompClient: any;

  ngOnInit(): void {
    this.connectWebSocket();
  }

  private connectWebSocket(): void {
    const socket = new SockJS('/ws');
    this.stompClient = Stomp.over(socket);
    this.stompClient.connect({}, (frame: any) => {
      // 订阅用户专属主题
      this.stompClient.subscribe(`/user/${localStorage.getItem('userId')}/notifications`, (message: any) => {
        const reminderContent = message.body;
        // 弹出系统通知
        if (Notification.permission === 'granted') {
          new Notification('会议提醒', { body: reminderContent });
        }
      });
    });
  }
}

这种设计完全摆脱了每秒查库的低效模式，资源利用率更高，实时性也能得到保障。

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