Redis教程

TP6基于redis的消息队列实现,从0开始,一步一步,包会教程!

本文主要是介绍TP6基于redis的消息队列实现,从0开始,一步一步,包会教程!,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

我是用的PHP框架是thinkphp6,所以使用的相对来说比较匹配的think-queue.尽量把每一步都写出来,经过自己采坑,尽量做到按照步骤下来,基本都能跑通!

官方地址:https://github.com/top-think/think-queue

第一步:安装composer(如果这一步都不会,那么就不用看下去了)

 

第二步:在项目根目录下,安装要用的依赖,执行:composer require topthink/think-queue

 

第三步:本地安装redis服务端。我这里用的是集成工具,自带redis服务,如果没有的话,就去redis的官网:https://redis.io/,下载安装一下,按照教程,启动redis服务,应该也不难的,我试过。

 

第四步:使用phpinfo查看你的PHP是否已经安装redis的扩展,如果没有,那么请注意了,你需要安装redis扩展。具体操作如下:

·使用phpinfo查看你的系统版本以及PHP支持的扩展版本:

 

要注意几个地方 X64,TS,VC,以及你的PHP版本,然后去https://windows.php.net/downloads/pecl/releases/redis/ 这个地址找到对应的redis版本,下载,解压。

·找到php_redis.dll文件,把它放到你的PHP安装目录的ext文件夹下

·编辑php.ini,加入extension=php_redis;这里注意,PHP版本不同有时候写法不一样,也有可能是extension=php_redis.dll,这个你根据php.ini中查看类似写法就好。

·再用phpinfo看一下,发现有redis扩展了,说明装好了。

 

第五步:编写app\queue.php文件,这个文件是自动生成的。

 

 按照这样设置就行,redis的连接根据你自己的实际情况来。

 

第六步:在app下新建文件夹job,然后新建一个php文件,这里就是放怎么去处理消息队列的逻辑,比如新建Job1.php文件

 

 第七步:在任何地方可以将一个数据推入消息队列:think\facade\Queue::push($job, $data = '', $queue = null)

第八步:在命令行执行:php think queue:listen 来监听消息队列,一旦队列里面有数据,就会启动消费进程去消费。这里要注意一点,如果你的逻辑处理起来耗时很长,超过了默认的60秒,那么是会报错的。如果你想要不报错,可以这样起命令:php think queue:listen --timeout=600 (任务执行一次之后还是会一直执行的,可以在代码开头加一段这个

if ($job->attempts() == 1) {
            //这样任务只会执行一次
            $job->delete();
        }

 第九步:如果你想以守护进程的形式常驻这个队列的监听,那么使用supervisor这个我没试过,试过的小伙伴也可以在评论区补充下怎么使用,大家互相学习!

这篇关于TP6基于redis的消息队列实现,从0开始,一步一步,包会教程!的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!