1. import java.io.BufferedReader;
  2. import java.io.FileReader;
  3. import java.io.IOException;
  4. import java.util.ArrayList;
  5. import java.util.List;
  6. import java.util.concurrent.Executors;
  7. import java.util.concurrent.ScheduledExecutorService;
  8. import java.util.concurrent.TimeUnit;
  10. public class UrlBootstrapper {
  12. private final String urlListFile;
  13. private final int retryIntervalSeconds;
  14. private final List<String> urls = new ArrayList<>();
  15. private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
  17. public UrlBootstrapper(String urlListFile, int retryIntervalSeconds) {
  18. this.urlListFile = urlListFile;
  19. this.retryIntervalSeconds = retryIntervalSeconds;
  20. }
  22. public void loadUrls() {
  23. try (BufferedReader reader = new BufferedReader(new FileReader(urlListFile))) {
  24. String line;
  25. while ((line = reader.readLine()) != null) {
  26. if (line.trim().length() > 0) { // Avoid empty lines
  27. urls.add(line.trim());
  28. }
  29. }
  30. } catch (IOException e) {
  31. System.err.println("Error reading URL list: " + e.getMessage());
  32. }
  33. }
  35. public void startBootstrapping() {
  36. loadUrls();
  38. if (urls.isEmpty()) {
  39. System.out.println("No URLs to bootstrap.");
  40. scheduler.shutdown();
  41. return;
  42. }
  44. for (String url : urls) {
  45. BootstrappingTask task = new BootstrappingTask(url);
  46. scheduler.scheduleAtFixedRate(task, 0, retryIntervalSeconds, TimeUnit.SECONDS);
  47. }
  48. }
  50. // Inner class to handle the bootstrapping task
  51. private static class BootstrappingTask implements Runnable {
  52. private final String url;
  54. public BootstrappingTask(String url) {
  55. this.url = url;
  56. }
  58. @Override
  59. public void run() {
  60. try {
  61. // Simulate bootstrapping logic (replace with your actual logic)
  62. System.out.println("Bootstrapping URL: " + url);
  63. // Add your URL bootstrapping code here
  64. } catch (Exception e) {
  65. System.err.println("Error bootstrapping URL " + url + ": " + e.getMessage());
  66. }
  67. }
  68. }
  70. public void stopBootstrapping() {
  71. scheduler.shutdown();
  72. }
  74. public static void main(String[] args) {
  75. // Example usage:
  76. String urlListFile = "url_list.txt"; // Replace with your URL list file
  77. int retryIntervalSeconds = 5; // Retry every 5 seconds
  79. UrlBootstrapper bootstrapper = new UrlBootstrapper(urlListFile, retryIntervalSeconds);
  80. bootstrapper.startBootstrapping();
  82. // Keep the program running for a while, then stop the bootstrapping
  83. try {
  84. Thread.sleep(60000); // Run for 60 seconds
  85. } catch (InterruptedException e) {
  86. e.printStackTrace();
  87. }
  89. bootstrapper.stopBootstrapping();
  90. }
  91. }

Add your comment