laravel配置使用Redis队列

目录

目录

一.安装Redis和扩展配置

二.安装redis的依赖

三.配置laravel队列

四.创建队列

五.启动队列

六.使用队列

七.最终结果

---

一.安装Redis和扩展配置

这里就跳过，可以专门去看安装Redis以及配置PHP扩展的文章

二.安装redis的依赖

laravel根目录下运行命令 composer require predis/predis

安装时报内存溢出

PHP Fatal error: Allowed memory size of 1610612736 bytes exhausted (tried to allocate 4096 bytes)

解决：

php -r "echo ini_get('memory_limit').PHP_EOL;" //命令行执行，获取当前内存限制大小

修改php.ini配置文件

memory_limit = -1

安装完后，再改回来

三.配置laravel队列

修改.env配置，将QUEUE_CONNECTION=sync改为

QUEUE_CONNECTION=redis

四.创建队列

使用命令创建队列，在app/Jobs目录

php artisan make:job TestQueue

TestQueue.php文件

<?phpnamespace App\Jobs;use Illuminate\Bus\Queueable; use Illuminate\Contracts\Queue\ShouldQueue; use Illuminate\Foundation\Bus\Dispatchable; use Illuminate\Queue\InteractsWithQueue; use Illuminate\Queue\SerializesModels; use Illuminate\Support\Facades\Cache;class TestQueue implements ShouldQueue {use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;public $data;/*** Create a new job instance.** @return void*/public function __construct($data){//接收消息return $this->data = $data;}/*** Execute the job.** @return void*/public function handle(){//消费消息Cache::add('data', $this->data);} }

五.启动队列

起一个命令行，开启队列监听，频道为Test

php artisan queue:listen redis --queue=Test

六.使用队列

往Test频道中投递消

Route::get('job', function () {TestQueue::dispatch('队列消息')->onQueue('Test');return 'ok'; });

七.最终结果

最终cache缓存文件中添加了数据

9999999999s:12:"队列消息";

总结

以上是生活随笔为你收集整理的laravel配置使用Redis队列的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。