快捷導(dǎo)航

使用PHP和Redis實現(xiàn)消息隊列功能

更新時間：2024年03月27日 09:48:32 作者：ayzen1988

這篇文章主要介紹了如何使用PHP和Redis實現(xiàn)消息隊列功能,文中通過示例代碼介紹的非常詳細(xì),對大家學(xué)習(xí)或者使用PHP具有一定的參考學(xué)習(xí)價值,需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧<BR>

前言

今天，我們繼續(xù)講消息隊列，如何使用Redis實現(xiàn)消息隊列的功能。

前期準(zhǔn)備，需要安裝好docker、docker-compose的運行環(huán)境。

PHP的項目運行環(huán)境可以參考下面的文章內(nèi)容。

如何使用docker部署php服務(wù)

前面我們也講了PHP和RabbitMQ實現(xiàn)消息隊列的功能，感興趣的可以查看下面的文章。

如何使用PHP和RabbitMQ實現(xiàn)消息隊列？

一、安裝Redis

1、安裝Redis的步驟可以參考下面的文章內(nèi)容。

Redis不同的持久化方式有什么差異？我們來做個小試驗。

二、安裝PHP的Redis擴(kuò)展

1、打開瀏覽器，找到擴(kuò)展下載地址，PECL :: Package :: redis。

2、進(jìn)入test1項目容器，執(zhí)行如下命令。

docker exec -ti test1 sh

3、下載擴(kuò)展，編譯安裝，執(zhí)行如下命令。

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

4、增加redis擴(kuò)展修改php.ini配置，增加如下內(nèi)容。

extension=redis.so

5、檢查擴(kuò)展是否配置成功，執(zhí)行如下命令。

php -m|grep redis

返回如下內(nèi)容，說明已安裝完成。

6、至此，PHP的Redis擴(kuò)展已安裝完成。

三、測試驗證

1、編寫生產(chǎn)者，代碼內(nèi)容如下。

vim producer.php
<?php
// 創(chuàng)建Redis實例
$redis = new Redis();
 
try {
    // 連接到Redis服務(wù)器
    $redis->connect('redis', 6379);
    echo "成功連接到Redis服務(wù)器！\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服務(wù)器: " . $e->getMessage();
}
 
// 關(guān)閉Redis連接
$redis->close();

2、編寫消費者，代碼內(nèi)容如下。

vim consumer.php
<?php
// 創(chuàng)建Redis實例
$redis = new Redis();
 
try {
    // 連接到Redis服務(wù)器
    $redis->connect('redis', 6379);
    echo "成功連接到Redis服務(wù)器！\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服務(wù)器: " . $e->getMessage();
}
 
// 關(guān)閉Redis連接
$redis->close();

3、啟動消費端，執(zhí)行如下命令。