• 欢迎来到本博客,希望可以y一起学习与分享

Laravel队列使用RabbitMQ驱动

PHP benz 7个月前 (03-03) 8次浏览 0个评论 扫描二维码

前言

Laravel队列默认使用的是sync作为队列驱动(可以看config/queue.php配置文件),使用RabbitMQ作为驱动,需要引入vladimir-yuldashev/laravel-queue-rabbitmq包,这个貌似仅仅作为laravel队列的RabbitMQ驱动适配包,如果需要完全使用RabbitMQ,需要使用php-amqplib/php-amqplib这个包,这个包是个通用包,并不适配laravel。

整合 RabbitMQ 消息队列(laravel 5.6)

laravel-queue-rabbitmq文档
1、Composer 安装 laravel-queue-rabbitmq

2、在 config/app.php 文件中,providers 中添加:

3、在 app/config/queue.php 配置文件中的 connections 数组中加入以下配置

4、修改 .env 文件

5、创建任务类

执行之后会生成一个文件 app/Jobs/Queue.php

例子:

6、生产,把数据放进 mq 队列

7、消费队列
执行命令进行消费:

或者

--queue:监听队列名

效果如下:

参考:

Laravel5.6 整合 RabbitMQ 消息队列


文章 Laravel队列使用RabbitMQ驱动 转载需要注明出处
喜欢 (0)

您必须 登录 才能发表评论!