README

Laravel的NSQ队列管理器包，使用Laravel的API

安装

首先，使用Composer安装此包

composer require merkeleon/laravel-nsq

按照Laravel手册中的说明添加新的队列任务

php artisan make:job <JobName> 根据Laravel的规则编辑此文件

将队列驱动设置为NSQ

QUEUE_DRIVER=nsq

设置NSQ服务器的环境选项

NSQSD_URL=127.0.0.1:4150 Nsq守护进程的IP和端口

NSQLOOKUP_URL=127.0.0.1:4161 Nsq查找守护进程的IP和端口

如果您想使用多个服务器，请使用逗号作为分隔符

NSQSD_URL=127.0.0.1:4150,127.0.0.1:4151,127.0.0.1:4152

示例

工作类

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Support\Facades\Config;

class CoolJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public function __construct(...$args)
    {
        $this->queue = 'my-cool-jobs';
        
        // $args code
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        // do the job
    }
}

代码某处

<?php

... code ...

// Push timed task in the queue
CoolJob::dispatch(...$any_args);

... code ...

merkeleon / laravel-nsq

维护者

详细信息

README

安装

示例

工作类

代码某处