1. <?php
  3. /**
  4. * Teardown function for message queue processes.
  5. *
  6. * This function iterates through configured message queues and gracefully
  7. * terminates their associated processes. Includes defensive checks
  8. * to prevent errors and ensure proper cleanup.
  9. */
  10. function teardownMessageQueues(): void
  11. {
  12. // Configuration: Replace with your actual queue configuration.
  13. $queues = [
  14. 'queue1' => ['process_path' => '/usr/local/bin/queue1', 'pid_file' => '/var/run/queue1.pid'],
  15. 'queue2' => ['process_path' => '/usr/local/bin/queue2', 'pid_file' => '/var/run/queue2.pid'],
  16. ];
  18. foreach ($queues as $queueName => $queueConfig) {
  19. $processPath = $queueConfig['process_path'];
  20. $pidFile = $queueConfig['pid_file'];
  22. // Defensive check: Ensure process path exists.
  23. if (!file_exists($processPath)) {
  24. error_log("ERROR: Process path '$processPath' does not exist for queue '$queueName'. Skipping.");
  25. continue;
  26. }
  28. // Defensive check: Ensure PID file exists.
  29. if (!file_exists($pidFile)) {
  30. error_log("WARNING: PID file '$pidFile' does not exist for queue '$queueName'. Skipping.");
  31. continue;
  32. }
  34. // Read the PID from the PID file.
  35. if (file_exists($pidFile)) {
  36. $pid = (int) file_get_contents($pidFile); // Cast to integer for safety.
  37. } else {
  38. error_log("ERROR: Could not read PID from '$pidFile' for queue '$queueName'. Skipping.");
  39. continue;
  40. }
  43. // Check if the process exists.
  44. if (ps($pid)) { // Using ps() to check if PID is valid
  45. try {
  46. // Terminate the process gracefully.
  47. echo "Terminating process '$queueName' (PID: $pid)...\n";
  48. kill($pid, SIGTERM); // Send SIGTERM first
  49. usleep(500000); // Wait 0.5 seconds for graceful shutdown
  51. if (kill($pid, SIGKILL) === false) {
  52. error_log("ERROR: Failed to kill process '$queueName' (PID: $pid) using SIGKILL.");
  53. } else {
  54. echo "Process '$queueName' (PID: $pid) terminated successfully.\n";
  55. }
  56. } catch (Exception $e) {
  57. error_log("ERROR: Exception occurred while terminating process '$queueName' (PID: $pid): " . $e->getMessage());
  58. }
  59. } else {
  60. echo "Process '$queueName' (PID: $pid) does not exist. Skipping.\n";
  61. }
  62. }
  64. echo "Message queue teardown completed.\n";
  65. }
  67. // Example usage:
  68. // teardownMessageQueues();
  70. ?>

Add your comment