In PHP microservices, how do I consume message queues?

In PHP microservices, consuming message queues such as RabbitMQ, Kafka, or AWS SQS is essential for building scalable applications. This process allows microservices to communicate asynchronously and handle tasks efficiently.

To consume messages from a queue, you need to use a specific library based on the message broker you are using. Below is an example of consuming messages from a RabbitMQ queue using PHP:


        <?php
        require_once __DIR__ . '/vendor/autoload.php';

        use PhpAmqpLib\Connection\AMQPStreamConnection;
        use PhpAmqpLib\Message\AMQPMessage;

        // Create a connection to RabbitMQ server
        $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
        $channel = $connection->channel();

        // Declare a queue
        $channel->queue_declare('task_queue', false, true, false, false, false, null);

        echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";

        $callback = function($msg) {
            echo ' [x] Received ', $msg->body, "\n";
            // Simulate message processing time
            sleep(substr_count($msg->body, '.'));
            echo " [x] Done\n";
        };

        // Set up consumer
        $channel->basic_consume('task_queue', '', false, true, false, false, $callback);

        // Wait for incoming messages
        while($channel->is_consuming()) {
            $channel->wait();
        }

        $channel->close();
        $connection->close();
        ?>

PHP Microservices Message Queues RabbitMQ Kafka AWS SQS Asynchronous Communication

In PHP microservices, how do I consume message queues?

Popular Topics

Recent Languages

In PHP microservices, how do I consume message queues?

Related Questions

Popular Topics

Recent Languages