Laravel利用队列处理
本文主要讲述如何利用 Laravel 框架的队列系统来管理异步任务和设置周期性执行的任务,从而加强应用程序的效能和可靠性。
Laravel队列的优势
异步执行:将任务添加到队列中后,可以立即返回响应给用户,而任务会在后台异步执行。
提高并发:由于任务被放入队列,可以同时处理多个任务,提高了应用的并发处理能力。
容错处理:当任务执行失败时,Laravel会将任务重新放入队列,确保任务能够被成功执行。
安全稳定:通过将任务放入队列,能够避免一些敏感操作或者耗时操作阻塞正常的哀求流程。
微服务化支持:可以通过队列服务与其他微服务进行解耦合,提高应用的可扩展性。
配置驱动
根目次 config 文件夹下 queue.php ,配置 redis 驱动
- //框架默认驱动我们设置为redis
- 'default' => env('QUEUE_CONNECTION', 'redis'),
- //connections里面有多种驱动 文件 数据库 redis,这里我们使用redis
- 'redis' => [
- 'driver' => 'redis',
- 'connection' => 'default',
- 'queue' => env('REDIS_QUEUE', 'default'),
- 'retry_after' => env('QUEUE_RETRY_AFTER',90),
- 'block_for' => null,
- 'after_commit' => false,
- ],
复制代码 利用队列
利用 Laravel 自带的 Artisan 命令创建任务类
- php artisan make:job Test
复制代码 组装任务类
- <?php
- namespace App\Jobs;
- use Illuminate\Bus\Queueable;
- use Illuminate\Contracts\Queue\ShouldBeUnique;
- use Illuminate\Contracts\Queue\ShouldQueue;
- use Illuminate\Foundation\Bus\Dispatchable;
- use Illuminate\Queue\InteractsWithQueue;
- use Illuminate\Queue\SerializesModels;
- class Test implements ShouldQueue
- {
- use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
-
- protected $test;
- /**
- * Create a new job instance.
- *
- * @return void
- */
- public function __construct($test)
- {
- $this->test = $test;
- }
- /**
- * Execute the job.
- *
- * @return void
- */
- public function handle()
- {
- //处理队列的逻辑
- echo $this->test;
- }
- }
复制代码 利用队列的 dispatch 方法来将任务分发到队列中,等待异步处理
- //传入任务类需要的参数
- Test::dispatch($test);
复制代码 启动队列,设置需要启动的队列名称,tries=3 是指队列失败后重试三次
- php artisan queue:work --queue=test --tries=3
复制代码 防止队列在后台被杀死,我们可以安装 supervisor 然后配置队列命令即可
注: 每次修改队列代码后,需要重新启动队列不然代码不生效,这个坑是各人非常轻易遇到的
结论
Laravel的队列处理可以显著提拔应用程序的并发性和用户体验,通过异步执行耗时任务,利用户响应更快。
– 欢迎点赞、关注、转发、收藏【我码玄黄】,gonghao同名
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。 |