laravel队列如何一直执行

2023年 8月 6日 20.6k 0

在使用 Laravel 的开发中,队列常常是必不可少的一部分。它能够极大的提高应用程序的并发处理能力,让大量的任务能够得到有效的管理和处理。但是在实际开发中,我们经常会遇到这样一个问题:队列不稳定,任务多时队列突然停止了,或者任务出现异常时队列也无法自动重启。这时我们就需要一些技巧,让队列能够稳定的运行下去。下面就介绍几种方法,帮助大家解决这些问题。

一、supervisor 守护进程

supervisor 是一款用 Python 写的进程控制系统,是 Linux 服务器上管理进程的一种常见的工具,可以帮助我们在后台不停的监控一个进程,如果这个进程因某种原因退出了,那么它能够随着宿主进程重新启动。这就能保证你的队列一直能够运行下去。

安装 supervisor

Centos 系统执行

yum install -y supervisor

Ubuntu 系统执行

apt-get install -y supervisor

打开配置文件

vim /etc/supervisord.conf

加入我们的 laravel-queue 配置节

[program:laravel-queue]command=php /path/to/artisan queue:work redis --sleep=3 --tries=3directory=/path/to/your/projectautostart=trueautorestart=trueuser=www-data

说明:

  • program:定义进程的名称
  • command:定义运行命令
  • autostart:开机自启动
  • autorestart:自动重启
  • user:运行进程的用户

保存修改后加载配置

supervisorctl reload

启动队列

supervisorctl start laravel-queue

这样就可以实现对队列的守护进程了。如果队列停止了,这个进程就会自动重启,从而保证队列一直在运行。当然,配置文件中也可以通过配置运行多个 work 进程,提高队列处理能力。

二、使用 Hashicorp 的 Nomad 集成 Marathon

Hashicorp 的 Nomad 与 Marathon 操作类似,它们都是用于分布式任务编排的一款开源的工具。Nomad 通过抽象化任务的位置和决策,能够对一组不同类型的任务进行编排。Nomad 与 Marathon 相比具有轻量、用户体验度高、易于配置的优势。

使用 Nomad 需要 docker 环境,如果你没有安装 docker,可以先通过 apt-get 安装:

apt-get install -y docker.io

  • 创建 Nomad Job
  • 在项目根目录下创建 job.nomad 文件,通过配置创建一个 Nomad Job:

    job "laravel_app" { datacenters = ["dc1"] type = "service"

    group "app" {

    task "laravel-queue" {
    driver = "docker"

    config {
    image = "your_docker_image"
    command = ["php", "artisan", "queue:work", "--tries", "1", "--timeout", "30"]
    args = [
    "--queue=critical,high,default,email,chat,sms",
    "--sleep=3"
    ]
    ports = ["http"]
    }

    resources {
    cpu = 500
    memory = 128
    network {
    mbits = 10
    port "http" {}
    }
    }

    service {
    name = "laravel-queue"
    port = "http"
    check {
    type = "http"
    path = "/status"
    interval = "10s"
    timeout = "2s"
    }
    }

    restart {
    attempts = 10
    interval = "5m"
    delay = "25s"
    mode = "failures"
    }
    }

    登录后复制

    }}

    以上的配置文件在单机模式下使用的是 docker 运行,在生产环境下根据实际情况进行修改。

  • 启动 Nomad Job
  • 执行以下命令,启动 Nomad Job:

    nomad run job.nomad

    至此就完成了队列的启动。Nomad 会在一个节点上运行我们的 Job,同时可以对该 Job 进行监控;当任务出现问题,Nomad 可以快速的重启任务并更新状态。Nomad Job 可以在集群中的不同节点间自动迁移,这样可以减轻某个节点的负载,提高了总体应用程序的的鲁棒性。

    三、使用 AWS SQS

    AWS 的 SQS(Simple Queue Service)是一款用于消息队列的服务,它可以在分布式应用程序之间高效地传递和处理消息,并允许应用程序之间的消息处理能力实现水平伸缩。在 Laravel 框架中,SQS 可以非常方便地集成到我们的应用程序中,只需要安装支持 SQS 的 Laravel Queue 包即可。同时,在 AWS 的 SQS 中,每一个队列都有一个最小可生命周期(TTL),如果在该时间段内未被执行成功,则该任务会被 SQS 删掉。这样可以保证一个任务最终一定会被执行成功。

    安装 SQS

    在 Laravel 中集成 SQS 相对比较简单,只需要安装支持 SQS 的 Laravel Queue 包即可。可以直接通过 Composer 安装:

    composer require "aws/aws-sdk-php ^3.0"

    配置 SQS

    在 .env 配置文件中添加以下内容:

    QUEUE_DRIVER=sqsAWS_ACCESS_KEY_ID=your_aws_access_keyAWS_SECRET_ACCESS_KEY=your_aws_secret_keyAWS_DEFAULT_REGION=us-west-2SQS_PREFIX=your_queue_prefix

    替换 your_aws_access_key、your_aws_secret_key 和 your_queue_prefix 为你自己的。

    启动队列

    php artisan queue:work sqs --queue=default --tries=3 --sleep=3 --timeout=60

    以上命令会启动一个 SQS 队列,并使用默认的 default 队列,其中 --tries 参数表示队列任务出错尝试的次数,--sleep 表示队列处理完任务休息的时间,--timeout 表示队列任务超时时的自动重试时间。队列会不断循环获取任务并执行:

    出现错误时,队列会自动重试,直至队列任务出错尝试的次数用完或者执行成功为止。

    总结

    在本文中,我们介绍了几种让 Laravel 队列一直执行的方法,通过守护进程、任务编排、第三方服务等方式,可以为队列提供更加稳定、高效的运行支持。每种方法都有各自的优点和适用范围,具体选择哪一种方法,需要根据自己的实际情况来做出决策。

    以上就是laravel队列如何一直执行的详细内容,更多请关注每日运维网(www.mryunwei.com)其它相关文章!

    相关文章

    JavaScript2024新功能:Object.groupBy、正则表达式v标志
    PHP trim 函数对多字节字符的使用和限制
    新函数 json_validate() 、randomizer 类扩展…20 个PHP 8.3 新特性全面解析
    使用HTMX为WordPress增效:如何在不使用复杂框架的情况下增强平台功能
    为React 19做准备:WordPress 6.6用户指南
    如何删除WordPress中的所有评论

    发布评论