laravel队列demo

代码织云鹤
• 阅读 2190

队列我使用的是redis

1.安装composer require "predis/predis:~1.0"
2.配置环境.env QUEUE_CONNECTION这种redis

使用时不需要多配置,只要写好Queue类和其fire方法,在需要的位置出队即可。
代码示例:

入队

use Queue;
Queue::push('\App\Jobs\JobDemo',['message'=>'队列']);

消费

php artisan make:job JobDemo

class JobDemo{

    public function fire($job,$data){
        $job->delete();任务开始前就删除任务,再开始执行任务。
        //业务处理
    }
}

laravel执行出队操作
php artisan queue:work

第一次写文章,写的不大好

点赞
收藏
评论区
推荐文章
Wesley13 Wesley13
3年前
java中比较两个时间的差值
项目背景1.某篇文稿的发布时间是publishDate,例如:2020072118:00:41。2.现要求判断该篇文稿的发布时间是否在近30天之内。publicstaticlongdayDiff(DatecurrentDate,DatepublishDate){LongcurrentTimecurrentDat
22 22
4年前
【数据结构和算法:简单方法】谈一谈优先队列的实现
【系列文章推荐阅读】首先回忆一下队列(详细内容移步至),只要记住八个字即可:先进先出(FIFO),后进后出(LILO)。就像去医院门诊看病排队时一样:先来的先看,看完先走。而优先队列的特性正是“优先”二字,“优先”二字意味着打破了“常规”“规则”。优先队列不再遵守普通队列的先进先出的原则了,如何不遵守呢?最大优先队列:不管入队顺序如何,
Wesley13 Wesley13
3年前
java实现队列的详细代码
一、什么是队列结构一种线性结构,具有特殊的运算法则【只能在一端(队头)删除,在另一端(队尾)插入】。分类:1.顺序队列结构2.链式队列结构基本操作:1.入队列2.出队列  二:准备数据staticfinal intQUEUELEN15;classDATA{          String
Stella981 Stella981
3年前
SpringBoot整合多个RabbitMQ
一、背景​最近项目中需要用到了RabbitMQ来监听消息队列,监听的消息队列的虚拟主机(virtualHost)和队列名(queueName)是不一致的,但是接收到的消息格式相同的。而且可能还存在程序不停机的情况下,动态的增加新的队列(queue)的监听,因此就需要我们自己在程序中实现一种方法实现动态配置RabbitMQ
Wesley13 Wesley13
3年前
IBM MQ8.0配置
因为工作需要使用MQServer,使用HyperV安装的win7操作系统作为载体来搭建MQ环境。经过不断下一步,我们安装好了MQ。然后开始配置:队列管理器名:QM\_JACK服务器连接通道:CNN\_JACK端口:8927接收队列名:QUEUE\_RECV发送队列名:QUEUE\_REPLYMQ用户名:fromsilence(
Stella981 Stella981
3年前
Laravel使用redis保存SESSION
Laravel使用redis保存SESSION首先确认服务器已经安装redis服务,php安装了redis扩展.1.打开config/database.php。在redis配置项中增加session的连接'session''host'
Stella981 Stella981
3年前
ConcurrentQueue队列的基本使用方式
 队列(Queue)代表了一个先进先出的对象集合。当您需要对各项进行先进先出的访问时,则使用队列。当您在列表中添加一项,称为入队,当您从列表中移除一项时,称为出队。  ConcurrentQueue<T队列是一个高效的线程安全的队列,是.NetFramework4.0,System.Collections.Concurren
Stella981 Stella981
3年前
Redis发布订阅(Pub
一、redis做消息队列1\.redis存储的list数据是双向链表实现的,可以作为队列2\.使用lpush和rpop实现入队和出队3\.每次使用lpush和rpop都要发起一次连接,性能不好4\.这是一次生产,一次消费的队列二、发布/订阅模式(publish/subscribe),也是作为消息队列1\.可以一次生产
Stella981 Stella981
3年前
20200202 ActiveMQ 3. Java编码实现ActiveMQ通讯
ActiveMQ3.Java编码实现ActiveMQ通讯3.1.队列(Queue)目的地(Destination)分为:点对点的队列(Queue)一对多的主题(Topic)3.1.1.上手代码1.pom.xml
Easter79 Easter79
3年前
SpringBoot整合多个RabbitMQ
一、背景​最近项目中需要用到了RabbitMQ来监听消息队列,监听的消息队列的虚拟主机(virtualHost)和队列名(queueName)是不一致的,但是接收到的消息格式相同的。而且可能还存在程序不停机的情况下,动态的增加新的队列(queue)的监听,因此就需要我们自己在程序中实现一种方法实现动态配置RabbitMQ
菜园前端 菜园前端
2年前
什么是队列
原文链接:什么是队列?队列是一种遵循先进先出原则的有序集合,添加新元素的一端称为队尾,另一端称为队首。实现功能在JavaScript中没有队列,但是可以通过Array实现队列的所有功能enqueue()入队dequeue()出队top()获取队首值size