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

沈宾

前言

今天，我们继续讲消息队列，如何使用Redis实现消息队列的功能。
前期准备，需要安装好docker、docker-compose的运行环境。
PHP的项目运行环境可以参考下面的文章内容。
如何使用docker部署php服务
前面我们也讲了PHP和RabbitMQ实现消息队列的功能，感兴趣的可以查看下面的文章。
如何使用PHP和RabbitMQ实现消息队列？

一、安装Redis

1、安装Redis的步骤可以参考下面的文章内容。
Redis不同的持久化方式有什么差异？我们来做个小试验。

二、安装PHP的Redis扩展

1、打开浏览器，找到扩展下载地址，PECL :: Package :: redis。

2、进入test1项目容器，执行如下命令。

1. docker exec -ti test1 sh

复制代码

3、下载扩展，编译安装，执行如下命令。

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

复制代码

4、增加redis扩展修改php.ini配置，增加如下内容。

1. extension=redis.so

复制代码

5、检查扩展是否配置成功，执行如下命令。

1. php -m|grep redis

复制代码

返回如下内容，说明已安装完成。

6、至此，PHP的Redis扩展已安装完成。

三、测试验证

1、编写生产者，代码内容如下。

1. vim producer.php
   
2. <?php
   
3. // 创建Redis实例
   
4. $redis = new Redis();
   
5. 
   
6. try {
   
7.     // 连接到Redis服务器
   
8.     $redis->connect('redis', 6379);
   
9.     echo "成功连接到Redis服务器！\r\n";
   
10. 
    
11.     // 将消息入队（添加到列表的尾部）
    
12.     $datetime = date('Y/m/d H:i:s');
    
13.     $message = 'Hello Max!';
    
14.     $redis->rPush('message_queue', $message);
    
15.     echo "消息已入队,datetime={$datetime},message={$message}\r\n";
    
16. } catch (RedisException $e) {
    
17.     // 处理连接错误
    
18.     echo "无法连接到Redis服务器: " . $e->getMessage();
    
19. }
    
20. 
    
21. // 关闭Redis连接
    
22. $redis->close();

复制代码

2、编写消费者，代码内容如下。

1. vim consumer.php
   
2. <?php
   
3. // 创建Redis实例
   
4. $redis = new Redis();
   
5. 
   
6. try {
   
7.     // 连接到Redis服务器
   
8.     $redis->connect('redis', 6379);
   
9.     echo "成功连接到Redis服务器！\r\n";
   
10. 
    
11.     while (true) {
    
12.         // 可以使用BLPOP命令来阻塞等待消息
    
13.         $message = $redis->blPop('message_queue', 0); // 0表示无限等待
    
14.         if ($message !== null) {
    
15.             $datetime = date('Y/m/d H:i:s');
    
16.             list($queue, $msg) = $message;
    
17.             echo "消息出列,datetime={$datetime},queue=${queue},message=${msg}\r\n";
    
18.         }
    
19.         usleep(100);
    
20.     }
    
21. } catch (RedisException $e) {
    
22.     // 处理连接错误
    
23.     echo "无法连接到Redis服务器: " . $e->getMessage();
    
24. }
    
25. 
    
26. // 关闭Redis连接
    
27. $redis->close();

复制代码

3、启动消费端，执行如下命令。

1. php consumer.php

复制代码

正常情况会返回如下内容，开始监听消息。

4、运行生产端，执行如下命令。

1. php producer.php

复制代码

正常情况会返回如下内容。

5、再看消费端接收到的消息，正常返回如下内容。

上面的截图是执行了三次生产端，生成了三条消息。
6、至此，PHP和Redis实现消息队列的功能已验证完成。

总结

其实PHP和Redis实现消息队列的功能，使用的是Redis的List这种数据结构。
使用rPush入列、blPop出列，实现队列的先进先出（FIFO）。
也可以使用lPush入列、blPop出列，来实现队列的先进后出（FILO）。
实现PHP和Redis消息队列的功能，其实就以下三个步骤。
1、安装Redis。
2、安装PHP的Redis扩展。
3、编写生产者、消费者代码进行测试验证。
上面的代码只是做个简单的示例，如果运用到实际的项目当中需要做进一步的优化。
到此这篇关于使用PHP和Redis实现消息队列功能的文章就介绍到这了,更多相关PHP Redis消息队列内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

来源:https://www.jb51.net/program/318671cql.htm
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！