15分钟后如何使我的Spring Scheduler重新触发一次响应失败

如何解决15分钟后如何使我的Spring Scheduler重新触发一次响应失败

我已经使用java spring boot task scheduler 创建了一个调度程序作业，该任务一个接一个地执行，也能够从DB获取cron表达式，但是这里的挑战是要指定no尝试在意外响应或失败的情况下尝试。我在下面给出了示例代码。

    TaskScheduler taskScheduler;
    private ScheduledFuture<?> job1;
    private ScheduledFuture<?> job2;
    private volatile boolean job1Flag = false;
    

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
        threadPoolTaskScheduler.setPoolSize(10);// Set the pool of threads
        threadPoolTaskScheduler.setThreadNamePrefix("scheduler-thread");
        threadPoolTaskScheduler.initialize();
        scheduleJob1(threadPoolTaskScheduler);// Assign the job1 to the scheduler
        scheduleJob2(threadPoolTaskScheduler);// Assign the job2 to the scheduler
        
        this.taskScheduler = threadPoolTaskScheduler;// this will be used in later part of the article during refreshing
                                                        // the cron expression dynamically
        taskRegistrar.setTaskScheduler(threadPoolTaskScheduler);
    }

    private void scheduleJob1(TaskScheduler scheduler) {
        job1 = scheduler.schedule(new Runnable() {
            @Override
            public void run() {
                try {
                    HttpURLConnection con = (HttpURLConnection) new URL("http://localhost:8040/getsqldatastream")
                            .openConnection();
                    con.setRequestMethod("POST");
                    con.setDoOutput(true);
                    con.setConnectTimeout(20 * // minutes to sleep
                    60 * // seconds to a minute
                    1000); // set timeout to 1 second
                    BufferedReader reader = new BufferedReader(new InputStreamReader(con.getInputStream()));
                    String output;
                    JSONObject outStream = new JSONObject();
                    while ((output = reader.readLine()) != null) {
                        JSONObject outPut = new JSONObject(output);
                        outStream = outPut;
                    }
                    int outputStatuscode = outStream.getInt("statusCode");
                    if ((con.getResponseCode() == HttpURLConnection.HTTP_OK) && outputStatuscode == 200) {
                        
                        job1Flag = true;// setting the flag true to mark it complete
                    }
                } catch (IOException e1) {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName() + " The Task1 executed at " + new Date());
                try {
                    Thread.sleep(10000);
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        },new Trigger() {
            @Override
            public Date nextExecutionTime(TriggerContext triggerContext) {
                String cronExp = "* 33 22 * * ?";// Can be pulled from a db
                return new CronTrigger(cronExp).nextExecutionTime(triggerContext);
            }
        });
    }

   private void scheduleJob2(TaskScheduler scheduler) {
        job2 = scheduler.schedule(new Runnable() {
            @Override
            public void run() {
                synchronized (this) {
                    while (!job1Flag) {
//                      System.out.println(Thread.currentThread().getName()
//                              + " waiting for job1 to complete to execute " + new Date());
                        try {
                            wait(10000);// add any number of seconds to wait
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
                System.out.println(Thread.currentThread().getName() + " The Task2 executed at " + new Date());
                job1Flag = false;
                
            }
        },new Trigger() {
            @Override
            public Date nextExecutionTime(TriggerContext triggerContext) {
                String cronExp = "* 0/5 * * * ?";// Can be pulled from a db . This will run
                                                                            // every minute
                return new CronTrigger(cronExp).nextExecutionTime(triggerContext);
            }
        });
    }

在我的情况下，根据上述代码cron表达式设置为在晚上10:33之前运行，并且只有在响应符合预期的情况下，标记值才变为true。如果在给定时间完成之前快速返回响应，它将一次又一次轮询。在这里，我必须告诉我的调度程序，以防接下来发生成功响应，而在失败响应或flagvalue仍然为false的情况下，经过15分钟后再尝试一次，但不要超过此时间。我们应该如何为任务计划程序设置尝试限制。