1. import org.json.JSONObject;
  2. import java.util.concurrent.ThreadLocalRandom;
  4. public class JsonRetry {
  6. /**
  7. * Retries the operation on the JSON object a specified number of times.
  8. *
  9. * @param jsonObject The JSON object to operate on.
  10. * @param maxRetries The maximum number of retry attempts.
  11. * @param delayMillis The delay in milliseconds between retries.
  12. * @param operation The operation to perform on the JSON object. Takes a JSONObject and returns void.
  13. * @throws Exception if the operation fails after maxRetries attempts.
  14. */
  15. public static void retryJsonOperation(JSONObject jsonObject, int maxRetries, long delayMillis, Operation operation) throws Exception {
  16. for (int i = 0; i <= maxRetries; i++) {
  17. try {
  18. operation.perform(jsonObject); // Perform the operation
  19. return; // Success, exit the retry loop
  20. } catch (Exception e) {
  21. if (i == maxRetries) {
  22. throw e; // Re-throw the exception if max retries reached
  23. }
  25. long randomDelay = ThreadLocalRandom.current().nextLong(delayMillis); // Introduce random delay
  26. try {
  27. Thread.sleep(randomDelay); // Wait before retrying
  28. } catch (InterruptedException ie) {
  29. Thread.currentThread().interrupt(); // Restore interrupted status
  30. throw new Exception("Retry interrupted", ie);
  31. }
  32. System.out.println("Retry attempt " + (i + 1) + " of " + maxRetries + " failed. Retrying in " + delayMillis + "ms...");
  33. }
  34. }
  35. }
  38. /**
  39. * Functional interface for the operation to be performed on the JSON object.
  40. */
  41. @FunctionalInterface
  42. public interface Operation {
  43. void perform(JSONObject jsonObject);
  44. }
  47. public static void main(String[] args) throws Exception {
  48. // Example Usage
  49. JSONObject jsonObject = new JSONObject();
  50. jsonObject.put("name", "Example");
  51. jsonObject.put("value", 123);
  53. // Define an operation to perform
  54. Operation myOperation = (jsonObject) -> {
  55. System.out.println("Performing operation on JSON object: " + jsonObject.toString());
  56. // Simulate a potential failure
  57. if (ThreadLocalRandom.current().nextBoolean()) {
  58. throw new RuntimeException("Simulated failure");
  59. }
  60. System.out.println("Operation completed successfully.");
  61. };
  63. // Retry the operation with 3 retries and a 1-second delay
  64. retryJsonOperation(jsonObject, 3, 1000, myOperation);
  65. }
  66. }

Add your comment