1. <?php
  3. // Simple message queue environment setup in PHP
  5. // Using Redis as a lightweight message broker. Install: composer require predis/predis
  7. require 'vendor/autoload.php'; //Ensure Predis is installed
  9. use Predis\Client;
  11. // Configuration
  12. $redisHost = '127.0.0.1'; // Redis server host
  13. $redisPort = 6379; // Redis server port
  14. $queueName = 'experiment_queue'; // Name of the message queue
  16. try {
  17. // Connect to Redis
  18. $redis = new Client([
  19. 'scheme' => 'tcp',
  20. 'host' => $redisHost,
  21. 'port' => $redisPort,
  22. ]);
  24. // Create the queue if it doesn't exist
  25. if (!$redis->exists($queueName)) {
  26. $redis->rpush($queueName, 'initial_message'); // Add an initial message
  27. echo "Queue '$queueName' created and initialized.\n";
  28. } else {
  29. echo "Queue '$queueName' already exists.\n";
  30. }
  32. // Function to enqueue a message
  33. function enqueueMessage($message) {
  34. $redis->rpush($queueName, $message);
  35. echo "Message enqueued: " . $message . "\n";
  36. }
  38. // Function to dequeue a message
  39. function dequeueMessage() {
  40. $message = $redis->lpop($queueName);
  41. if ($message) {
  42. echo "Message dequeued: " . $message . "\n";
  43. return $message;
  44. } else {
  45. echo "Queue is empty.\n";
  46. return null;
  47. }
  48. }
  52. } catch (\Exception $e) {
  53. echo "Error connecting to Redis: " . $e->getMessage() . "\n";
  54. }
  56. ?>

Add your comment