下面由thinkphp框架教程栏目给大家介绍使用thinkphp5中thinkphp-queue的方法,希望对需要的朋友有所帮助!
最近小编收到群里面的小伙伴在使用ThinkPHP5.0的框架时,不知道如何使用php-queue(实在尴尬,网上很多这方面的教程)。哈哈,不想参考也没关系,小编就具体地走一遍吧~~关于什么是队列?队列的解决什么?队列有哪些场景?…等等这些问题,开发者请自行先去了解,还有本案例只针对ThinkPHP框架进行具体操作哦。
1、安装 thinkphp-queue
推荐使用composer进行安装,切换到项目的根目录,执行: composer require topthink/think-queue
2、配置消息队列的存储环境
立即学习“PHP免费学习笔记(深入)”;
配置文件位于 applicationextraqueue.php,如图:
使用Redis驱动,如果Redis环境还没有安装,请自行安装哦,很简单的,或者也可以使用其他类型驱动,如图:
3、任务的创建
我们在index模块下,Index.php文件,建立一个名为 queue 的方法(一定要这样么?当然不是,本教程,只是例子,你可以新建模块,方法名也可以是其他),如图:
4、任务消息的消费以及删除处理
我们在 index模块下创建一个 job 文件,该文件用来处理消费模式,如图:
在 Demo 这个类下,创建一个 fire 方法,该方法是消息队列默认调用的方法。如图:
© 版权声明
文章版权归作者所有,未经允许请勿转载。
THE END