1. import java.io.IOException;
  2. import java.util.concurrent.Executors;
  3. import java.util.concurrent.ScheduledExecutorService;
  4. import java.util.concurrent.TimeUnit;
  6. public class RecordBootstrapper {
  8. private final String userRecordScriptPath;
  9. private final long retryIntervalSeconds;
  10. private final int maxRetries;
  12. public RecordBootstrapper(String userRecordScriptPath, long retryIntervalSeconds, int maxRetries) {
  13. this.userRecordScriptPath = userRecordScriptPath;
  14. this.retryIntervalSeconds = retryIntervalSeconds;
  15. this.maxRetries = maxRetries;
  16. }
  18. public void startBootstrapping() {
  19. ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
  21. scheduler.scheduleAtFixedRate(this::bootstrapRecord, 0, retryIntervalSeconds, TimeUnit.SECONDS);
  23. // Handle potential shutdown gracefully (optional, but recommended)
  24. Runtime.getRuntime().addShutdownHook(new Thread(() -> {
  25. scheduler.shutdown();
  26. try {
  27. if (!scheduler.awaitTermination(60, TimeUnit.SECONDS)) {
  28. scheduler.shutdownNow();
  29. }
  30. } catch (InterruptedException e) {
  31. scheduler.shutdownNow();
  32. Thread.currentThread().interrupt();
  33. }
  34. }));
  35. }
  37. private void bootstrapRecord() {
  38. try {
  39. executeScript(userRecordScriptPath);
  40. } catch (IOException e) {
  41. System.err.println("Error executing script: " + e.getMessage());
  42. // Retry logic
  43. if (getRemainingRetries() > 0) {
  44. System.out.println("Retrying in " + retryIntervalSeconds + " seconds...");
  45. } else {
  46. System.err.println("Max retries reached. Failed to execute script.");
  47. }
  48. }
  49. }
  51. private void executeScript(String scriptPath) throws IOException {
  52. // Simulate script execution (replace with actual script execution logic)
  53. System.out.println("Executing script: " + scriptPath);
  54. // Replace with your script execution logic (e.g., using ProcessBuilder)
  55. // Example:
  56. // Process process = Runtime.getRuntime().exec("java -jar " + scriptPath);
  57. // process.waitFor();
  58. }
  60. private int getRemainingRetries() {
  61. // Implement retry counter logic here (e.g., using a class variable or external storage)
  62. return maxRetries; // Placeholder - replace with actual retry counter
  63. }
  65. public static void main(String[] args) {
  66. // Example Usage
  67. String scriptPath = "/path/to/user_record_script.sh"; // Replace with your script path
  68. long retryInterval = 5; // Retry every 5 seconds
  69. int maxRetries = 3; // Maximum number of retries
  71. RecordBootstrapper bootstrapper = new RecordBootstrapper(scriptPath, retryInterval, maxRetries);
  72. bootstrapper.startBootstrapping();
  73. }
  74. }

Add your comment