1. import java.io.IOException;
  2. import java.net.URI;
  3. import java.net.http.HttpClient;
  4. import java.net.http.HttpRequest;
  5. import java.net.http.HttpResponse;
  6. import java.time.Duration;
  7. import java.util.concurrent.Executors;
  8. import java.util.concurrent.ScheduledExecutorService;
  9. import java.util.concurrent.TimeUnit;
  11. public class MaintenanceTaskBinder {
  13. private final String targetUrl;
  14. private final long retryIntervalSeconds;
  15. private final int maxRetries;
  16. private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
  18. public MaintenanceTaskBinder(String targetUrl, long retryIntervalSeconds, int maxRetries) {
  19. this.targetUrl = targetUrl;
  20. this.retryIntervalSeconds = retryIntervalSeconds;
  21. this.maxRetries = maxRetries;
  22. }
  24. public void performMaintenanceTask() {
  25. int retryCount = 0;
  26. while (retryCount <= maxRetries) {
  27. try {
  28. // Create HTTP request
  29. HttpRequest request = HttpRequest.get(URI.create(targetUrl));
  31. // Execute HTTP request
  32. HttpResponse<String> response = HttpClient.newHttpClient().send(request, HttpResponse.BodyHandlers.ofString());
  34. // Check response status code
  35. if (response.statusCode() >= 200 && response.statusCode() < 300) {
  36. System.out.println("Maintenance task successful.");
  37. return; // Task successful, exit the loop
  38. } else {
  39. System.out.println("Maintenance task failed with status code: " + response.statusCode());
  40. retryCount++;
  42. if (retryCount > maxRetries) {
  43. System.out.println("Maximum retries reached. Maintenance task failed.");
  44. return;
  45. }
  47. // Schedule retry
  48. scheduler.schedule(() -> performMaintenanceTask(), retryIntervalSeconds, TimeUnit.SECONDS);
  49. }
  50. } catch (IOException e) {
  51. System.err.println("IO Error: " + e.getMessage());
  52. retryCount++;
  53. if (retryCount > maxRetries) {
  54. System.out.println("Maximum retries reached. Maintenance task failed.");
  55. return;
  56. }
  57. scheduler.schedule(() -> performMaintenanceTask(), retryIntervalSeconds, TimeUnit.SECONDS);
  59. } catch (Exception e) {
  60. System.err.println("Unexpected error: " + e.getMessage());
  61. retryCount++;
  62. if (retryCount > maxRetries) {
  63. System.out.println("Maximum retries reached. Maintenance task failed.");
  64. return;
  65. }
  66. scheduler.schedule(() -> performMaintenanceTask(), retryIntervalSeconds, TimeUnit.SECONDS);
  67. }
  68. }
  69. }
  71. public void startMaintenance() {
  72. performMaintenanceTask();
  73. }
  75. public void stop() {
  76. scheduler.shutdown();
  77. try {
  78. scheduler.awaitTermination(1, TimeUnit.MINUTES);
  79. } catch (InterruptedException e) {
  80. Thread.currentThread().interrupt();
  81. }
  82. }
  83. }

Add your comment