In PHP forums, how do I consume message queues?

In PHP forums, consuming message queues is essential for processing tasks asynchronously. By utilizing a message queue service like RabbitMQ or Redis, you can efficiently manage requests without blocking your application. Below is a simple example demonstrating how to consume messages from a queue in PHP.


    <?php
    // Required Libraries
    require 'vendor/autoload.php';
    
    use PhpAmqpLib\Connection\AMQPStreamConnection;
    use PhpAmqpLib\Message\AMQPMessage;

    // Establish connection to RabbitMQ server
    $connection = new AMQPStreamConnection('localhost', 5672, 'user', 'password');
    $channel = $connection->channel();

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

    echo ' [*] Waiting for messages. To exit press CTRL+C', <br>

    // Callback function to process the messages
    $callback = function($msg) {
        echo ' [x] Received ', $msg->body, <br>
        sleep(substr_count($msg->body, '.')); // Simulate work
        echo ' [x] Done', <br>
    };

    // Start consuming messages
    $channel->basic_consume('task_queue', '', false, true, false, false, $callback);

    while($channel->is_consuming()) {
        $channel->wait();
    }

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

PHP message queue RabbitMQ Redis asynchronous processing task management PHP forums queue consumer

In PHP forums, how do I consume message queues?

Popular Topics

Recent Languages

In PHP forums, how do I consume message queues?

Related Questions

Popular Topics

Recent Languages