laravel使用队列的简单步骤

2018-08-28 10:00:24

最近需要导入大量的excel文件,数量达到十万之多。

而我又不想修改服务器的超时时间,因为这样可能影响服务器的堵塞。


而php又没有很好的异步。


后来发现了令laravel最为骄傲的部分,队列。具体文档参考下方链接。


laravel队列介绍


简单操作如下:

Laravel5提供了完善的队列功能,只需要简单的配置即可使用。这里简单记录下关于异步队列的用法。 配置 关于队列的定义,这里就不作介绍了。我们要使用异步队列就有两个关键:

     1.存储队列的地方

     2.执行任务的服务 。

打开 config/queue.php,这是Laravel5关于队列的配置文件。首先我们可以通过 default参数指定默认队列驱动,默认配置是 sync, 这是同步队列,我们要做异步队列首先就要改变这里。

假设我们用 database作为驱动,队列任务将会存放在数据库中,而我们后面会另外启动一个后台服务来处理队列任务,这就是异步方式了。 'default' => 'database' 修改完配置后,我们需要创建一个表来存放队列任务,Laravel5已经在自带artisan命令中内置了一个指令用来生成数据迁移,只需要两条命令即可,当然你得实现配置好数据库连接。

 php artisan queue:table  php artisan migrate 这样就自动在数据库中创建了 jobs 表。 


启动队列监听服务 通过下面这条指令启动队列监听服务,它会自动处理 jobs 表中的队列任务: php artisan queue:work

在linux中,如果想让它在后台执行,可以这样: nohup php artisan queue:listen & 添加队列任务 关于队列任务的添加,手册里说的比较详细,这里就简单举个例子吧。 首先,通过artisan创建一个队列命令: php artisan make:command SendEmail --queued 这样会生成 app/Commands/SendEmail.php这个类文件,这个类会被标识为队列命令,你可以在 handle方法中写自己的业务逻辑。 在控制器中,可以简单通过 Bus::dispatch分发任务: Bus::dispatch(new /App/Commands/SendEmail()); 你会发现任务不会立即执行,而是被放到 jobs 表中,由队列监听服务处理。 更详细的用法建议参考 command bus 和 queue 相关的手册章节。 


因为 php artisan queue:work 不是守候进程,我们采用

再linux我们采用supervisor 来进行我们的守候进程。具体supervisor的配置,我laravel队列supervisor的配置参考下一篇文章。

  • 2019-02-25 10:05:41

    Android Socket连接(模拟心跳包,断线重连,发送数据等)

    因为是要保证全局只能有一个连接,而且我们还需要在不同的Activity中发指令,因此肯定不能在需要发指令的界面中都去连接socket,这样一来不好管理,性能也不好,重复代码也会比较多,所以想了一下还是把socket放到service中比较好,发指令功能都放在service中即可。

  • 2019-02-28 15:54:24

    HTTP协议缓存策略深入详解之ETAG妙用

      HTTP协议规格说明定义ETag为“被请求变量的实体值” 。另一种说法是,ETag是一个可以与Web资源关联的记号(token)。典型的Web资源可以一个Web页,但也可能是JSON或XML文档。服务器单独负责判断记号是什么及其含义,并在HTTP响应头中将其传送到客户端。

  • 2019-02-28 16:46:26

    android获取视频、图片时添加防盗链

    使用HTTP协议时,可以利用头信息中的Referer做防盗链。 我们在一些网站的网页里访问图片的时候,在图片本站是可以正常看到的,但在外头就不能看到了,这是因为在http的header信息中的referer元素。

  • 2019-03-02 11:29:17

    MySQL学习之索引顺序

    这个问题比较简单,MySQL本身会对条件和索引进行判断,这样写可以用到索引,没有问题。

  • 2019-03-06 11:24:19

    MySQL查看数据库表容量大小

    本文介绍MySQL查看数据库表容量大小的命令语句,提供完整查询语句及实例,方便大家学习使用。

  • 2019-03-13 09:38:11

    写入MySQL报错超出 max_allowed_packet 的问题

    MySQL会根据配置文件会限制server接受的数据包的大小。如果写入大数据时,因为默认的配置太小,插入和更新操作会因为 max_allowed_packet 参数限制,而导致失败。