基于Redis实现PHP消息队列
2021-04-26 23:27
1056 查看
所谓消息队列,即在消息的传输过程中保存消息的容器。最常见的使用场景是,通过引入消息队列来对耗时的任务就行异步处理,以及应对高并发问题,即所谓的削峰作用。在以PHP为主要开发语言的项目中,我们可以选择的软件有很多,最常使用的有三种:基于
Redis的
List数据类型来用PHP实现入列出列,基于
Memcached的扩展应用
MemcacheQ,还有更强大和流行的
RabbitMQ。
基于
Redis来实现消息队列,主要是用到
Redis中的
List数据类型。下面分别介绍下
Redis的
List列表的使用 以及 基于
Redis的PHP轻量级消息队列
php-resque。
phpredis扩展: https://github.com/phpredis/phpredis
1. Redis
的 List
列表的使用
<?php/** * 基于Redis-List实现的简单消息队列 * @author <mail@phpha.com> *///实例化$redis = new Redis();//连接服务端$redis->connect('127.0.0.1', 6379);//入列$redis->lPush('TestQueue', 'phpha.com'); $redis->lPush('TestQueue', 'www.phpha.com'); $redis->lPush('TestQueue', 'blog.phpha.com');//出列for($i = 1; $i <= 4; $i++){ //输出队列内信息 $result = $redis->rPop('TestQueue'); var_dump($result); }
输出如下:
string(9) "phpha.com"string(13) "www.phpha.com"string(14) "blog.phpha.com"bool(false)
说明:以上按照先进先出的原则,分别出列了所有的数据。如果列表内数据为空,则
Redis::rPop()返回
false。
2. 基于 Redis
的PHP轻量级消息队列 php-resque
2.1 php-resque
中的 3 种角色
Job
:一个Job
就是一个需要再队列中执行的任务,比如发送短信邮件等Queue
:也就是消息队列,基于Redis
实现Worker
:负责从消息队列中取出任务并执行,以守护进行方式在后台运行
2.2 php-resque
任务执行流程
- 创建
Job
:在PHP中是独立的Class
(包含所有的业务逻辑处理) - 加入
Queue
:将Job
对应的Class
以及实例化所需的参数一起放入队列中 - 创建
Worker
:创建后台守护进程来定时检查队列中的任务并执行
说明:在
php-resque中,还有一个很重要的设计:一个
Worker,可以处理一个队列,也可以处理很多个队列,并且可以通过增加
Worker的进程/线程数来加快队列的执行速度。
相关文章推荐
- php基于Redis消息队列实现的消息推送的方法
- php基于Redis消息队列实现的消息推送的方法
- PHP基于Redis消息队列实现发布微博的方法
- PHP中利用redis实现消息队列处理高并发请求--简洁代码实现效果
- 基于PHP使用rabbitmq实现消息队列
- php 实现 redis 队列,等待有新消息入列
- PHP中利用redis实现消息队列处理高并发请求
- 消息列队 php 基于redis 实现
- php和redis怎么实现消息队列
- 基于PHP使用rabbitmq实现消息队列
- php+redis实现消息队列
- PHP使用Redis实现消息队列
- 基于Redis实现分布式消息队列(3)
- 基于Redis的消息队列php-resque
- PHP使用php-resque库配合Redis实现MQ消息队列的教程
- 基于redis+mysql+php的简单队列实现
- PHP使用php-resque库配合Redis实现MQ消息队列的教程
- php+redis消息队列抢购实现
- 基于Redis实现的延迟消息队列
- php+redis消息队列实现抢购功能