如何利用 Spring Boot 3.X 和 WebSocket 来实现消息推送功能，并实现动态开启、关闭和取消定时任务的功能？

package com.zs.websocket.demo6.utils; import com.zs.websocket.demo6.handler.ScheduleTask; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; import org.springframework.scheduling.support.CronTrigger; import java.util.HashMap; import java.util.Map; import java.util.concurrent.ScheduledFuture; /** * 定时任务工具类 * @author 未来码匠 */ public class ScheduleUtil { private static final Log logger = LogFactory.getLog(ScheduleUtil.class); private static final ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler(); private static final Map<String, ScheduledFuture<?>> scheduledFutureMap = new HashMap<>(); static{ threadPoolTaskScheduler.initialize(); logger.info("初始化线程池..."); } /** * 根据Cron表达式来启动指定的定时任务 */ public static void start(ScheduleTask scheduleTask, CronTrigger cronTrigger){ if (isExist(scheduleTask.getId())){ logger.info("启动定时任务"+ scheduleTask.getId()+"失败，此任务已存在"); return; } ScheduledFuture<?> scheduledFuture = threadPoolTaskScheduler.schedule(scheduleTask, cronTrigger); scheduledFutureMap.put(scheduleTask.getId(),scheduledFuture); logger.info("启动定时任务"+ scheduleTask.getId()+"，设置cron表达式为"+ cronTrigger.toString()); } /** * 取消指定的定时任务 */ public static void cancel(ScheduleTask scheduleTask){ ScheduledFuture<?> scheduledFuture = scheduledFutureMap.get(scheduleTask.getId()); if(scheduledFuture != null && !scheduledFuture.isCancelled()){ scheduledFuture.cancel(false); } scheduledFutureMap.remove(scheduleTask.getId()); logger.info("取消定时任务"+ scheduleTask.getId()); } /** * 根据Cron表达式来重置指定的定时任务执行时间和相关内容 */ public static void reset(ScheduleTask scheduleTask,CronTrigger cronTrigger){ String id = scheduleTask.getId(); ScheduledFuture<?> scheduledFuture = scheduledFutureMap.get(id); if(scheduledFuture != null && !scheduledFuture.isCancelled()){ scheduledFuture.cancel(false); } scheduledFutureMap.remove(id); //然后启动新的定时任务 scheduledFuture = threadPoolTaskScheduler.schedule(scheduleTask, cronTrigger); scheduledFutureMap.put(id,scheduledFuture); logger.info("重置定时任务"+ id+"，设置cron表达式为"+ cronTrigger.toString()); } /** * 判断指定的定时任务是否存在或已经取消 */ public static Boolean isExist(String id) { ScheduledFuture<?> scheduledFuture = scheduledFutureMap.get(id); return scheduledFuture != null && !scheduledFuture.isCancelled(); } }