使用PHP和Redis实现消息队列功能

docker exec -ti test1 sh

wget https://pecl.php.net/get/redis-6.0.2.tgz
tar -xzvf redis-6.0.2.tgz
cd redis-6.0.2/
phpize
./configure --with-php-config=/usr/local/php/bin/php-config
make && make install

extension=redis.so

php -m|grep redis

vim producer.php
<?php
// 创建Redis实例
$redis = new Redis();
 
try {
    // 连接到Redis服务器
    $redis->connect('redis', 6379);
    echo "成功连接到Redis服务器！\r\n";
 
    // 将消息入队（添加到列表的尾部）
    $datetime = date('Y/m/d H:i:s');
    $message = 'Hello Max!';
    $redis->rPush('message_queue', $message);
    echo "消息已入队,datetime={$datetime},message={$message}\r\n";
} catch (RedisException $e) {
    // 处理连接错误
    echo "无法连接到Redis服务器: " . $e->getMessage();
}
 
// 关闭Redis连接
$redis->close();

vim consumer.php
<?php
// 创建Redis实例
$redis = new Redis();
 
try {
    // 连接到Redis服务器
    $redis->connect('redis', 6379);
    echo "成功连接到Redis服务器！\r\n";
 
    while (true) {
        // 可以使用BLPOP命令来阻塞等待消息
        $message = $redis->blPop('message_queue', 0); // 0表示无限等待
        if ($message !== null) {
            $datetime = date('Y/m/d H:i:s');
            list($queue, $msg) = $message;
            echo "消息出列,datetime={$datetime},queue=${queue},message=${msg}\r\n";
        }
        usleep(100);
    }
} catch (RedisException $e) {
    // 处理连接错误
    echo "无法连接到Redis服务器: " . $e->getMessage();
}
 
// 关闭Redis连接
$redis->close();

php consumer.php

php producer.php