1. <?php
  3. /**
  4. * Simple message queue retrier.
  5. *
  6. * This script assumes a simple message queue implementation where messages
  7. * are stored in an array. It retries failed operations a specified
  8. * number of times.
  9. *
  10. * @param array $queue An array representing the message queue. Each element
  11. * is an associative array containing the message data and
  12. * a 'attempts' key indicating the number of retry attempts.
  13. * @param int $maxAttempts The maximum number of retry attempts allowed.
  14. * @param callable $processMessage A callable (function) that processes a single message.
  15. * @return array An array containing the results of processing each message,
  16. * including success/failure status and any error messages.
  17. */
  18. function processQueue(array $queue, int $maxAttempts, callable $processMessage): array
  19. {
  20. $results = [];
  22. foreach ($queue as $message) {
  24. $attempts = $message['attempts'] ?? 0; // Default to 0 attempts if not set
  26. $success = false;
  27. $errorMessage = null;
  29. $attempt = 0;
  30. while (!$success && $attempt < $maxAttempts) {
  31. $attempt++;
  33. try {
  34. $result = $processMessage($message);
  35. $success = true;
  36. } catch (Exception $e) {
  37. $errorMessage = "Attempt " . $attempt . " failed: " . $e->getMessage();
  38. }
  40. if (!$success) {
  41. $message['attempts'] = $attempts + 1; // Increment attempts
  42. usleep(100000); // Sleep for 100ms before retrying (optional)
  43. }
  44. }
  46. $results[] = [
  47. 'message' => $message,
  48. 'success' => $success,
  49. 'errorMessage' => $errorMessage,
  50. 'attempted' => $attempt
  51. ];
  52. }
  54. return $results;
  55. }
  57. /**
  58. * Example usage (replace with your actual message processing logic).
  59. */
  60. if (count($argv) > 1) {
  61. $queueData = json_decode(file_get_contents($argv[1]), true);
  62. if (is_array($queueData)) {
  63. $results = processQueue($queueData, 3, function ($message) {
  64. // Simulate a message processing operation
  65. if (rand(0, 2) == 0) {
  66. throw new Exception("Simulated processing error");
  67. }
  68. return "Message processed successfully: " . json_encode($message);
  69. });
  71. echo json_encode($results, JSON_PRETTY_PRINT); // Output results
  72. } else {
  73. echo "Invalid queue data format.\n";
  74. }
  75. } else {
  76. echo "Usage: php script.php <queue_data_file>\n";
  77. }
  78. ?>

Add your comment